Function newTaskNotificationSubscribeCommand

internal/cli/task.go:773–817

(deps commandDeps)

}

func newTaskNotificationSubscribeCommand(deps commandDeps) *cobra.Command {
	input := taskNotificationSubscribeInput{}
	cmd := &cobra.Command{
		Use:   "subscribe <task-id>",
		Short: "Subscribe a bridge target to task terminal notifications",
		Args:  exactOneNonBlankArg(),
		RunE: func(cmd *cobra.Command, args []string) error {
			client, err := clientFromDeps(deps)
			if err != nil {
				return err
			}
			request, err := buildTaskBridgeNotificationSubscriptionRequest(input)
			if err != nil {
				return err
			}
			subscription, err := client.CreateTaskBridgeNotificationSubscription(
				cmd.Context(),
				args[0],
				request,
			)
			if err != nil {
				return err
			}
			return writeCommandOutput(cmd, taskBridgeNotificationSubscriptionBundle(&subscription))
		},
	}
	cmd.Flags().
		StringVar(&input.SubscriptionID, "subscription-id", "", "Idempotent subscription ID")
	cmd.Flags().StringVar(&input.BridgeInstanceID, "bridge", "", "Bridge instance ID")
	cmd.Flags().
		StringVar(&input.ScopeRaw, taskScopeKey, string(bridgepkg.ScopeGlobal), "Bridge scope: global or workspace")
	cmd.Flags().
		StringVar(&input.WorkspaceID, "workspace", "", "Workspace ID for workspace bridge scope")
	cmd.Flags().StringVar(&input.PeerID, "peer", "", "Bridge peer ID")
	cmd.Flags().StringVar(&input.ThreadID, "thread", "", "Bridge thread ID")
	cmd.Flags().StringVar(&input.GroupID, "group", "", "Bridge group ID")
	cmd.Flags().StringVar(
		&input.DeliveryModeRaw,
		"mode",
		string(bridgepkg.DeliveryModeReply),
		"Delivery mode: reply or direct-send",
	)
	mustMarkFlagRequired(cmd, "bridge")
	return cmd
}

func newTaskNotificationListCommand(deps commandDeps) *cobra.Command {
	var (