Function cleanupUpstreamWsSession

server.js:153–163

()

  };

  const cleanupUpstreamWsSession = () => {
    const cleanup = globalThis.__cchCleanupResponsesWsSession;
    if (typeof cleanup !== "function") return;
    try {
      cleanup(responsesWsSessionId);
    } catch (err) {
      log("warn", "ws_upstream_session_cleanup_failed", {
        error: String(err && err.message ? err.message : err),
      });
    }
  };

  const dropPendingFrames = () => {
    if (pending.length > 0) {