Function startEvent

server/modules/updateAudit.js:418–464

(traceContext, stage, payload = {}, status = "started")

}

async function startEvent(traceContext, stage, payload = {}, status = "started") {
  if (!traceContext) {
    return null;
  }

  const eventPayload = sanitizePayload(payload);
  const startedAt = new Date();
  const event = {
    runId: traceContext.runId || null,
    sequence: traceContext.nextSequence || 1,
    stage,
    status,
    startedAt,
    payload: eventPayload,
  };

  const mutableTraceContext = traceContext;
  mutableTraceContext.nextSequence = event.sequence + 1;

  try {
    if (db.UpdateRunEvent && traceContext.runId) {
      const createdEvent = await db.UpdateRunEvent.create({
        runId: traceContext.runId,
        sequence: event.sequence,
        stage,
        status,
        startedAt,
        payload: eventPayload,
      });
      event.id = createdEvent.id;
    }
  } catch (error) {
    emitAuditInternalError("[updateAudit] failed to create event", error);
  }

  emitStructuredAuditLog("event_started", {
    runId: traceContext.runId,
    traceId: traceContext.traceId,
    rootTraceId: traceContext.rootTraceId,
    sequence: event.sequence,
    stage,
    status,
    payload: eventPayload,
  });

  return event;
}

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