Function newChannelSendCommand

internal/cli/agent_kernel.go:183–250

(deps commandDeps)

}

func newChannelSendCommand(deps commandDeps) *cobra.Command {
	var bodyRaw string
	var idempotencyKey string
	flags := coordinationMetadataFlags{kind: string(contract.CoordinationMessageStatus)}

	cmd := &cobra.Command{
		Use:   "send <channel>",
		Short: "Send one task-run coordination message",
		Args:  exactOneNonBlankArg(),
		Example: `  # Send a non-authoritative status message for a run
  agh ch send coord-run-123 \
    --task-id task-123 \
    --run-id run-123 \
    --kind status \
    --correlation-id run-123 \
    --body '{"status":"investigating"}'

  # Report a blocker in the same task-bound channel
  agh ch send coord-run-123 \
    --task-id task-123 \
    --run-id run-123 \
    --kind blocker \
    --correlation-id run-123 \
		--body '{"blocked_by":"missing credentials"}'`,
		RunE: func(cmd *cobra.Command, args []string) error {
			channel := strings.TrimSpace(args[0])
			flags.kindExplicit = cmd.Flags().Changed(agentKernelKindKey)
			body, err := parseNetworkJSONValue("--body", bodyRaw)
			if err != nil {
				return err
			}
			metadata, err := flags.metadata(channel, contract.CoordinationMessageStatus, true)
			if err != nil {
				return err
			}
			if metadata.MessageKind == contract.CoordinationMessageReply {
				return errors.New("cli: use `agh ch reply --to-message` for reply messages")
			}
			request := AgentChannelSendRequest{
				Body:           body,
				Metadata:       metadata,
				IdempotencyKey: strings.TrimSpace(idempotencyKey),
			}
			if err := contract.ValidateNoRawClaimTokenField(request); err != nil {
				return err
			}

			client, err := clientFromDeps(deps)
			if err != nil {
				return err
			}
			credentials, err := requireAgentCommandIdentity(cmd.Context(), deps, client, agentActionCLI("ch.send"))
			if err != nil {
				return err
			}
			message, err := client.AgentChannelSend(cmd.Context(), channel, request, credentials)
			if err != nil {
				return err