Function closeConnection

apps/cloud/src/observability/memory-metrics.ts:170–193

(
  connection: SseConnection,
  reason: CloseReason,
  maxQueueSize: number,
)

};

const closeConnection = (
  connection: SseConnection,
  reason: CloseReason,
  maxQueueSize: number,
): void => {
  if (connection.closed) return;
  connection.closed = true;
  activeSse.delete(connection.id);
  const now = Date.now();
  console.log(
    `${LOG_PREFIX} ${JSON.stringify({
      event: "sse_close",
      connectionId: connection.id,
      reason,
      ageMs: now - connection.startedAt,
      bytesForwarded: connection.bytes,
      chunksForwarded: connection.chunks,
      lastWriteAgeMs: now - connection.lastWriteAt,
      colo: connection.colo,
      scriptVersion: connection.scriptVersion,
    })}`,
  );
  maybeEmitPeriodicSnapshot(now, maxQueueSize);
};

const sseHeaders = (headers: Headers): Headers => {
  const next = new Headers(headers);