MCPcopy Create free account
hub / github.com/compozy/agh / newNetworkDirectsResolveCommand

Function newNetworkDirectsResolveCommand

internal/cli/network.go:663–699  ·  view source on GitHub ↗
(deps commandDeps, workspaceRef *string)

Source from the content-addressed store, hash-verified

661}
662
663func 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
701func newNetworkDirectsShowCommand(deps commandDeps, workspaceRef *string) *cobra.Command {
702 var flags networkDirectsFlags

Callers 1

newNetworkDirectsCommandFunction · 0.85

Calls 6

clientFromDepsFunction · 0.85
writeCommandOutputFunction · 0.85
networkDirectBundleFunction · 0.85
mustMarkFlagRequiredFunction · 0.85
NetworkDirectResolveMethod · 0.65

Tested by

no test coverage detected