Function newNetworkDirectsListCommand

internal/cli/network.go:628–661

(deps commandDeps, workspaceRef *string)

}

func newNetworkDirectsListCommand(deps commandDeps, workspaceRef *string) *cobra.Command {
	var flags networkDirectsFlags
	cmd := &cobra.Command{
		Use:   networkListKey,
		Short: "List direct rooms in a channel",
		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
			}
			directs, err := client.NetworkDirects(cmd.Context(), NetworkDirectsQuery{
				WorkspaceRef: workspace,
				Channel:      strings.TrimSpace(flags.channel),
				PeerID:       strings.TrimSpace(flags.peerID),
				Limit:        flags.limit,
				After:        strings.TrimSpace(flags.after),
			})
			if err != nil {
				return err
			}
			return writeCommandOutputWithJSONL(cmd, networkDirectsBundle(directs), directs)
		},
	}
	cmd.Flags().StringVar(&flags.channel, networkChannelKey, "", "Target channel")
	cmd.Flags().StringVar(&flags.peerID, "peer", "", "Peer id filter")
	cmd.Flags().IntVar(&flags.limit, "limit", 0, "Maximum number of direct rooms to return")
	cmd.Flags().StringVar(&flags.after, "after", "", "Cursor after which to list direct rooms")
	mustMarkFlagRequired(cmd, networkChannelKey)
	return cmd
}

func newNetworkDirectsResolveCommand(deps commandDeps, workspaceRef *string) *cobra.Command {
	var flags networkDirectsFlags