(deps commandDeps)
| 89 | ) |
| 90 | |
| 91 | func newNetworkCommand(deps commandDeps) *cobra.Command { |
| 92 | var workspaceRef string |
| 93 | cmd := &cobra.Command{ |
| 94 | Use: networkNetworkKey, |
| 95 | Short: "Operate the daemon-owned network runtime", |
| 96 | } |
| 97 | |
| 98 | cmd.AddCommand(newNetworkStatusCommand(deps)) |
| 99 | cmd.PersistentFlags(). |
| 100 | StringVar(&workspaceRef, "workspace", "", "Workspace root, name, or ID for scoped network data") |
| 101 | cmd.AddCommand(newNetworkPeersCommand(deps, &workspaceRef)) |
| 102 | cmd.AddCommand(newNetworkChannelsCommand(deps, &workspaceRef)) |
| 103 | cmd.AddCommand(newNetworkThreadsCommand(deps, &workspaceRef)) |
| 104 | cmd.AddCommand(newNetworkDirectsCommand(deps, &workspaceRef)) |
| 105 | cmd.AddCommand(newNetworkWorkCommand(deps, &workspaceRef)) |
| 106 | cmd.AddCommand(newNetworkSendCommand(deps, &workspaceRef)) |
| 107 | cmd.AddCommand(newNetworkInboxCommand(deps, &workspaceRef)) |
| 108 | cmd.AddCommand(newNetworkSubscriptionsCommand(deps, &workspaceRef)) |
| 109 | cmd.AddCommand( |
| 110 | newNetworkSubscriptionModeCommand( |
| 111 | deps, |
| 112 | &workspaceRef, |
| 113 | "subscribe", |
| 114 | "full", |
| 115 | "Subscribe one peer to full delivery", |
| 116 | ), |
| 117 | ) |
| 118 | cmd.AddCommand( |
| 119 | newNetworkSubscriptionModeCommand(deps, &workspaceRef, "mute", "mute", "Mute one peer's network delivery"), |
| 120 | ) |
| 121 | cmd.AddCommand( |
| 122 | newNetworkSubscriptionModeCommand( |
| 123 | deps, |
| 124 | &workspaceRef, |
| 125 | "digest-mode", |
| 126 | "digest", |
| 127 | "Set one peer to digest delivery", |
| 128 | ), |
| 129 | ) |
| 130 | cmd.AddCommand(newNetworkUnmuteCommand(deps, &workspaceRef)) |
| 131 | return cmd |
| 132 | } |
| 133 | |
| 134 | func resolveNetworkWorkspaceRef( |
| 135 | cmd *cobra.Command, |
no test coverage detected