Function newNetworkSendCommand

internal/cli/network.go:857–922

(deps commandDeps, workspaceRef *string)

}

func newNetworkSendCommand(deps commandDeps, workspaceRef *string) *cobra.Command {
	var flags networkSendFlags
	cmd := &cobra.Command{
		Use:   networkSendKey,
		Short: "Send one envelope through the daemon-owned network runtime",
		RunE: func(cmd *cobra.Command, _ []string) error {
			body, err := parseNetworkJSONValue("--body", flags.bodyRaw)
			if err != nil {
				return err
			}
			ext, err := parseNetworkJSONObjectMap("--ext", flags.extRaw)
			if err != nil {
				return err
			}
			if err := validateNetworkSendNoRawClaimToken(body, ext); err != nil {
				return err
			}
			expiresAt, err := parseNetworkExpiresAt(flags.expiresAtRaw)
			if err != nil {
				return err
			}
			if err := validateNetworkSendFlags(flags); err != nil {
				return err
			}
			client, err := clientFromDeps(deps)
			if err != nil {
				return err
			}
			workspace, err := resolveNetworkWorkspaceRef(cmd, deps, client, workspaceRef)
			if err != nil {
				return err
			}

			message, err := client.NetworkSend(cmd.Context(), NetworkSendRequest{
				WorkspaceID: workspace,
				SessionID:   strings.TrimSpace(flags.sessionID),
				Channel:     strings.TrimSpace(flags.channel),
				Surface:     strings.TrimSpace(flags.surface),
				ThreadID:    strings.TrimSpace(flags.threadID),
				DirectID:    strings.TrimSpace(flags.directID),
				Kind:        strings.TrimSpace(flags.kind),
				To:          strings.TrimSpace(flags.to),
				Mentions:    trimSpawnAtoms(flags.mentions),
				Body:        body,
				WorkID:      strings.TrimSpace(flags.workID),
				ReplyTo:     strings.TrimSpace(flags.replyTo),
				TraceID:     strings.TrimSpace(flags.traceID),
				CausationID: strings.TrimSpace(flags.causationID),
				ExpiresAt:   expiresAt,
				ID:          strings.TrimSpace(flags.id),
				Ext:         ext,
			})
			if err != nil {
				return err
			}
			return writeCommandOutput(cmd, networkSendBundle(message))
		},
	}