Function taskBridgeNotificationRows

internal/cli/task.go:3385–3413

(subscription *TaskBridgeNotificationSubscriptionRecord)

}

func taskBridgeNotificationRows(subscription *TaskBridgeNotificationSubscriptionRecord) []keyValue {
	return []keyValue{
		{Label: taskSubscriptionValue, Value: stringOrDash(subscription.SubscriptionID)},
		{Label: taskTaskValue, Value: stringOrDash(subscription.TaskID)},
		{Label: taskBridgeValue, Value: stringOrDash(subscription.BridgeInstanceID)},
		{Label: taskScopeValue, Value: stringOrDash(string(subscription.Scope))},
		{Label: taskWorkspaceValue, Value: stringOrDash(subscription.WorkspaceID)},
		{Label: taskPeerValue, Value: stringOrDash(subscription.PeerID)},
		{Label: taskThreadValue, Value: stringOrDash(subscription.ThreadID)},
		{Label: taskGroupValue, Value: stringOrDash(subscription.GroupID)},
		{Label: taskModeValue, Value: stringOrDash(string(subscription.DeliveryMode))},
		{Label: "Cursor Consumer", Value: stringOrDash(subscription.Cursor.ConsumerID)},
		{Label: "Cursor Stream", Value: stringOrDash(subscription.Cursor.StreamName)},
		{Label: "Cursor Subject", Value: stringOrDash(subscription.Cursor.SubjectID)},
		{Label: "Cursor Last Sequence", Value: int64OrDash(subscription.Cursor.LastSequence)},
		{Label: "Cursor Last Delivery", Value: stringOrDash(subscription.Cursor.LastDeliveryID)},
		{
			Label: "Cursor Last Delivered",
			Value: stringOrDash(formatTimePtr(subscription.Cursor.LastDeliveredAt)),
		},
		{Label: "Cursor Last Error", Value: stringOrDash(subscription.Cursor.LastError)},
		{
			Label: "Cursor Updated",
			Value: stringOrDash(formatTimePtr(subscription.Cursor.UpdatedAt)),
		},
		{Label: taskCreatedByValue, Value: stringOrDash(formatTaskActor(subscription.CreatedBy))},
		{Label: taskUpdatedValue, Value: stringOrDash(formatTime(subscription.UpdatedAt))},
	}
}

func taskBridgeNotificationSubscriptionDeleteBundle(
	taskID string,