Function finishEvent

server/modules/updateAudit.js:466–509

(traceContext, event, status = "success", payload = {})

}

async function finishEvent(traceContext, event, status = "success", payload = {}) {
  if (!traceContext || !event) {
    return null;
  }

  const finishedAt = new Date();
  const mergedPayload = sanitizePayload({
    ...(event.payload || {}),
    ...payload,
  });
  const durationMs = getDurationMs(event.startedAt, finishedAt);

  try {
    if (db.UpdateRunEvent && event.id) {
      await db.UpdateRunEvent.update({
        status,
        finishedAt,
        durationMs,
        payload: mergedPayload,
      }, { where: { id: event.id } });
    }
  } catch (error) {
    emitAuditInternalError("[updateAudit] failed to update event", error);
  }

  emitStructuredAuditLog("event_finished", {
    runId: traceContext.runId,
    traceId: traceContext.traceId,
    rootTraceId: traceContext.rootTraceId,
    sequence: event.sequence,
    stage: event.stage,
    status,
    durationMs,
    payload: mergedPayload,
  });

  return {
    ...event,
    status,
    finishedAt,
    durationMs,
    payload: mergedPayload,
  };
}

async function completeRun(traceContext, options = {}) {
  if (!traceContext) {