Function newNetworkSubscriptionModeCommand

internal/cli/network.go:1024–1063

(
	deps commandDeps,
	workspaceRef *string,
	use string,
	mode string,
	short string,
)

}

func newNetworkSubscriptionModeCommand(
	deps commandDeps,
	workspaceRef *string,
	use string,
	mode string,
	short string,
) *cobra.Command {
	var flags networkSubscriptionFlags
	cmd := &cobra.Command{
		Use:   use,
		Short: short,
		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
			}
			subscription, err := client.SetNetworkSubscription(
				cmd.Context(),
				workspace,
				strings.TrimSpace(flags.channel),
				NetworkSubscriptionRequest{
					ThreadID:       strings.TrimSpace(flags.threadID),
					PeerID:         strings.TrimSpace(flags.peerID),
					Mode:           mode,
					KeywordFilters: trimSpawnAtoms(flags.keywordFilters),
				},
			)
			if err != nil {
				return err
			}
			return writeCommandOutput(cmd, networkSubscriptionBundle(subscription))
		},
	}
	registerNetworkSubscriptionMutationFlags(cmd, &flags, true)
	return cmd
}

func newNetworkUnmuteCommand(deps commandDeps, workspaceRef *string) *cobra.Command {
	var flags networkSubscriptionFlags