Function findSessionMatching

server/src/training-agent/state.ts:465–491

(predicate: (s: SessionState) => boolean)

 * persisted store (listed in pages of 100).
 */
export async function findSessionMatching(predicate: (s: SessionState) => boolean): Promise<SessionState | null> {
  const ctx = requestCtx.getStore();
  if (ctx) {
    for (const session of ctx.sessions.values()) {
      if (predicate(session)) return session;
    }
  }
  const store = storeInstance;
  if (!store) return null;
  try {
    const page = await store.list<Record<string, unknown>>(SESSIONS_COLLECTION, { limit: 100 });
    for (const row of page.items ?? []) {
      const sessionKey = typeof row.__sessionKey === 'string' ? row.__sessionKey : undefined;
      const session = deserializeSession(row);
      if (predicate(session)) {
        if (ctx && sessionKey) {
          ctx.sessions.set(sessionKey, session);
          ctx.snapshots.set(sessionKey, stableStringify(serializeSession(session, sessionKey)));
        }
        return session;
      }
    }
  } catch (err) {
    logger.warn({ err }, 'findSessionMatching: store list failed');
  }
  return null;
}

export function findMediaBuyAcrossSessions(mediaBuyId: string): Promise<SessionState | null> {
  return findSessionMatching(s => s.mediaBuys.has(mediaBuyId));