Files
OmniRoute/open-sse/services/sessionPool/sessionFactory.ts
diegosouzapw d22564df4d fix(session-pool): round-robin fingerprints in SessionFactory
createSession() used rotator.random() despite its docstring saying 'next
available fingerprint'. Random draws collide in a small profile pool,
producing duplicate fingerprints (and duplicate sess-<fp>-<ms> ids) across
a warm pool — flaky tests and look-alike sessions. Switch to rotator.next()
so each pooled session gets a distinct fingerprint, as documented.
2026-05-31 07:05:21 -03:00

58 lines
1.8 KiB
TypeScript

/**
* SessionFactory — Creates initialized Session instances
*
* For zero-auth providers (Pollinations, Puter): just assigns a fingerprint.
* For cookie-based providers (ChatGPT Web, DeepSeek Web): would launch
* headless Playwright, solve Turnstile, and extract cookies.
*
* Currently only zero-auth is implemented. Cookie-based provider support
* is planned for Phase 3.
*/
import { FingerprintRotator } from "./fingerprintRotator.ts";
import { Session } from "./session.ts";
import type { PoolConfig } from "./types.ts";
export class SessionFactory {
private rotator = new FingerprintRotator();
constructor(private config: PoolConfig) {}
/**
* Create a new session with the next available fingerprint.
* For zero-auth providers, this is a lightweight operation
* (just picks a fingerprint). For cookie-based providers this
* would involve Playwright browser automation.
*/
createSession(): Session {
// Round-robin so each session in a warm pool gets a distinct fingerprint
// (a pool of look-alike sessions defeats the purpose). The rotator still
// exposes random() for callers that want unpredictability over time.
const fingerprint = this.rotator.next();
return new Session(
fingerprint,
this.config.cooldownBase,
this.config.cooldownMax,
this.config.cooldownJitter,
);
}
/** Reset the fingerprint rotator (e.g., after config change) */
resetRotator(): void {
this.rotator.reset();
}
/** Number of available fingerprint profiles */
get profileCount(): number {
return this.rotator.count;
}
/** Build headers from session fingerprint */
buildHeaders(
session: Session,
extra?: Record<string, string>,
): Record<string, string> {
return session.buildHeaders(extra);
}
}