Function newNetworkThreadsMessagesCommand

internal/cli/network.go:485–531

(deps commandDeps, workspaceRef *string)

}

func newNetworkThreadsMessagesCommand(deps commandDeps, workspaceRef *string) *cobra.Command {
	var flags networkThreadsFlags
	cmd := &cobra.Command{
		Use:   sessionMessagesKey,
		Short: "List messages in one public thread",
		RunE: func(cmd *cobra.Command, _ []string) error {
			client, err := clientFromDeps(deps)
			if err != nil {
				return err
			}
			workspace, err := resolveNetworkWorkspaceRef(cmd, deps, client, workspaceRef)
			if err != nil {
				return err
			}
			messages, err := client.NetworkThreadMessages(cmd.Context(), NetworkConversationMessagesQuery{
				WorkspaceRef: workspace,
				Channel:      strings.TrimSpace(flags.channel),
				ThreadID:     strings.TrimSpace(flags.threadID),
				Limit:        flags.limit,
				Before:       strings.TrimSpace(flags.before),
				After:        strings.TrimSpace(flags.after),
				Kind:         strings.TrimSpace(flags.kind),
				WorkID:       strings.TrimSpace(flags.workID),
			})
			if err != nil {
				return err
			}
			return writeCommandOutputWithJSONL(cmd, networkThreadMessagesBundle(messages), messages)
		},
	}
	registerNetworkMessageReadFlags(
		cmd,
		&flags.channel,
		networkSurfaceThread,
		"Public thread id",
		&flags.threadID,
		&flags.limit,
		&flags.before,
		&flags.after,
		&flags.kind,
		&flags.workID,
	)
	cmd.Flags().Lookup(networkSurfaceThread).Usage = "Public thread id"
	mustMarkFlagRequired(cmd, networkChannelKey)
	mustMarkFlagRequired(cmd, networkSurfaceThread)
	return cmd
}

type networkThreadPromoteFlags struct {
	channel         string