Method metadata

internal/cli/agent_kernel.go:346–383

(
	channel string,
	defaultKind contract.CoordinationMessageKind,
	required bool,
)

}

func (f coordinationMetadataFlags) metadata(
	channel string,
	defaultKind contract.CoordinationMessageKind,
	required bool,
) (contract.CoordinationMessageMetadataPayload, error) {
	metadataExt, err := parseNetworkJSONObjectMap("--metadata-ext", f.extRaw)
	if err != nil {
		return contract.CoordinationMessageMetadataPayload{}, err
	}

	kindOverride := f.kindExplicit &&
		contract.CoordinationMessageKind(strings.TrimSpace(f.kind)) != defaultKind
	if !required &&
		strings.TrimSpace(f.taskID) == "" &&
		strings.TrimSpace(f.runID) == "" &&
		strings.TrimSpace(f.workflowID) == "" &&
		strings.TrimSpace(f.coordinationChannelID) == "" &&
		strings.TrimSpace(f.correlationID) == "" &&
		len(metadataExt) == 0 &&
		!kindOverride {
		return contract.CoordinationMessageMetadataPayload{}, nil
	}

	kind := contract.CoordinationMessageKind(firstCLIValue(f.kind, string(defaultKind)))
	metadata := contract.CoordinationMessageMetadataPayload{
		TaskID:                strings.TrimSpace(f.taskID),
		RunID:                 strings.TrimSpace(f.runID),
		WorkflowID:            strings.TrimSpace(f.workflowID),
		CoordinationChannelID: firstCLIValue(f.coordinationChannelID, channel),
		MessageKind:           kind,
		CorrelationID:         firstCLIValue(f.correlationID, f.runID),
		Ext:                   metadataExt,
	}
	if err := metadata.Validate(); err != nil {
		return contract.CoordinationMessageMetadataPayload{}, err
	}
	return metadata, nil
}

func requireAgentCommandIdentity(
	ctx context.Context,