(deps commandDeps, workspaceRef *string)
| 661 | } |
| 662 | |
| 663 | func newNetworkDirectsResolveCommand(deps commandDeps, workspaceRef *string) *cobra.Command { |
| 664 | var flags networkDirectsFlags |
| 665 | cmd := &cobra.Command{ |
| 666 | Use: "resolve", |
| 667 | Short: "Create or return the deterministic direct room for two peers", |
| 668 | RunE: func(cmd *cobra.Command, _ []string) error { |
| 669 | client, err := clientFromDeps(deps) |
| 670 | if err != nil { |
| 671 | return err |
| 672 | } |
| 673 | workspace, err := resolveNetworkWorkspaceRef(cmd, deps, client, workspaceRef) |
| 674 | if err != nil { |
| 675 | return err |
| 676 | } |
| 677 | direct, err := client.NetworkDirectResolve( |
| 678 | cmd.Context(), |
| 679 | workspace, |
| 680 | strings.TrimSpace(flags.channel), |
| 681 | NetworkDirectResolveRequest{ |
| 682 | SessionID: strings.TrimSpace(flags.session), |
| 683 | PeerID: strings.TrimSpace(flags.peerID), |
| 684 | }, |
| 685 | ) |
| 686 | if err != nil { |
| 687 | return err |
| 688 | } |
| 689 | return writeCommandOutput(cmd, networkDirectBundle(direct)) |
| 690 | }, |
| 691 | } |
| 692 | cmd.Flags().StringVar(&flags.session, "session", "", "Local source session id") |
| 693 | cmd.Flags().StringVar(&flags.channel, networkChannelKey, "", "Target channel") |
| 694 | cmd.Flags().StringVar(&flags.peerID, "peer", "", "Remote peer id") |
| 695 | mustMarkFlagRequired(cmd, "session") |
| 696 | mustMarkFlagRequired(cmd, networkChannelKey) |
| 697 | mustMarkFlagRequired(cmd, "peer") |
| 698 | return cmd |
| 699 | } |
| 700 | |
| 701 | func newNetworkDirectsShowCommand(deps commandDeps, workspaceRef *string) *cobra.Command { |
| 702 | var flags networkDirectsFlags |
no test coverage detected