Function newNetworkThreadsPromoteCommand

internal/cli/network.go:543–582

(deps commandDeps, workspaceRef *string)

}

func newNetworkThreadsPromoteCommand(deps commandDeps, workspaceRef *string) *cobra.Command {
	var flags networkThreadPromoteFlags
	cmd := &cobra.Command{
		Use:   networkPromoteCommandUse,
		Short: "Promote one thread message into a durable task",
		RunE: func(cmd *cobra.Command, _ []string) error {
			metadata, err := parseOptionalNetworkMetadata(cmd, flags.metadataRaw)
			if err != nil {
				return err
			}
			client, err := clientFromDeps(deps)
			if err != nil {
				return err
			}
			workspace, err := resolveNetworkWorkspaceRef(cmd, deps, client, workspaceRef)
			if err != nil {
				return err
			}
			promoted, err := client.PromoteNetworkThreadTask(
				cmd.Context(),
				workspace,
				strings.TrimSpace(flags.channel),
				strings.TrimSpace(flags.threadID),
				PromoteNetworkThreadTaskRequest{
					OriginMessageID: strings.TrimSpace(flags.originMessageID),
					Title:           strings.TrimSpace(flags.title),
					Description:     strings.TrimSpace(flags.description),
					Priority:        strings.TrimSpace(flags.priority),
					Metadata:        metadata,
				},
			)
			if err != nil {
				return err
			}
			return writeCommandOutput(cmd, networkThreadPromotionBundle(&promoted))
		},
	}
	registerNetworkThreadPromoteFlags(cmd, &flags)
	return cmd
}

func registerNetworkThreadPromoteFlags(cmd *cobra.Command, flags *networkThreadPromoteFlags) {
	cmd.Flags().StringVar(&flags.channel, networkChannelKey, "", "Target channel")