Function newChannelReplyCommand

internal/cli/agent_kernel.go:252–322

(deps commandDeps)

}

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

	cmd := &cobra.Command{
		Use:   agentKernelReplyKey,
		Short: "Reply to a received coordination message",
		Example: `  # Reply to one received coordination message
  agh ch reply --to-message msg-123 --body '{"answer":"ready for review"}'

  # Add explicit correlation metadata when replying from outside an inherited delivery
  agh ch reply \
    --to-message msg-123 \
    --task-id task-123 \
    --run-id run-123 \
    --coordination-channel-id coord-run-123 \
    --correlation-id run-123 \
    --body '{"answer":"ready for review"}'`,
		RunE: func(cmd *cobra.Command, _ []string) error {
			flags.kindExplicit = cmd.Flags().Changed(agentKernelKindKey)
			if flags.kindExplicit &&
				contract.CoordinationMessageKind(strings.TrimSpace(flags.kind)) != contract.CoordinationMessageReply {
				return errors.New("cli: --kind must be reply for `agh ch reply`")
			}
			body, err := parseNetworkJSONValue("--body", bodyRaw)
			if err != nil {
				return err
			}
			metadata, err := flags.metadata("", contract.CoordinationMessageReply, false)
			if err != nil {
				return err
			}
			if !zeroCLIAgentCoordinationMetadata(metadata) &&
				metadata.MessageKind != contract.CoordinationMessageReply {
				return errors.New("cli: --kind must be reply for `agh ch reply`")
			}
			request := AgentChannelReplyRequest{
				ReplyToMessageID: strings.TrimSpace(toMessage),
				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.reply"))
			if err != nil {
				return err
			}
			message, err := client.AgentChannelReply(cmd.Context(), request, credentials)
			if err != nil {