Function newNetworkInboxCommand

internal/cli/network.go:943–970

(deps commandDeps, workspaceRef *string)

}

func newNetworkInboxCommand(deps commandDeps, workspaceRef *string) *cobra.Command {
	var sessionID string

	cmd := &cobra.Command{
		Use:   "inbox",
		Short: "Show queued inbound messages for one session",
		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.NetworkInbox(cmd.Context(), workspace, strings.TrimSpace(sessionID))
			if err != nil {
				return err
			}
			return writeCommandOutput(cmd, networkInboxBundle(messages))
		},
	}

	cmd.Flags().StringVar(&sessionID, "session", "", "Target session id")
	mustMarkFlagRequired(cmd, "session")
	return cmd
}

type networkSubscriptionFlags struct {
	channel        string