Function runWithSessionContext

server/src/training-agent/state.ts:84–87

(fn: () => Promise<T>)

/** Wrap a request so getSession()/flushDirtySessions() use a per-request cache. */
export function runWithSessionContext<T>(fn: () => Promise<T>): Promise<T> {
  const ctx: RequestSessionCtx = { sessions: new Map(), snapshots: new Map() };
  return requestCtx.run(ctx, fn);
}

/**
 * Persist sessions that were actually mutated during the current request.