Function deriveWebhookOperationId

server/src/training-agent/webhooks.ts:127–139

(
  toolName: string,
  response: Record<string, unknown>,
  requestIdempotencyKey: string | undefined,
  principal: string,
)

 *  idempotency cache uses (`scopedPrincipal(auth, accountScope)`), so both
 *  caches partition identically. */
export function deriveWebhookOperationId(
  toolName: string,
  response: Record<string, unknown>,
  requestIdempotencyKey: string | undefined,
  principal: string,
): string {
  for (const field of ['media_buy_id', 'creative_id', 'activation_id', 'signal_activation_id', 'task_id', 'list_id', 'account_id']) {
    const v = response[field];
    if (typeof v === 'string' && v.length > 0) return `${principal}|${toolName}.${v}`;
  }
  if (requestIdempotencyKey) return `${principal}|${toolName}.${requestIdempotencyKey}`;
  return `${principal}|${toolName}.${randomUUID()}`;
}

export function deriveRegisteredWebhookDeliveryOperationId(
  toolName: string,