Class SessionStore

src/lib/session-store.ts:20–179

type SessionSubscriber = (session: SessionData) => void;

class SessionStore {
  private sessions = new Map<string, SessionData>();
  private subscribers = new Map<string, Set<SessionSubscriber>>();
  private cleanupInterval: NodeJS.Timeout | null = null;

  constructor() {
    // Start automatic cleanup every 5 minutes
    this.startAutoCleanup();
  }

  /**
   * Create a new session
   */
  createSession(sessionId: string, containerId: string): SessionData {
    const session: SessionData = {
      sessionId,
      containerId,
      buildStatus: 'idle',
      previewReady: false,
      createdAt: Date.now(),
      lastActivity: Date.now(),
    };

    this.sessions.set(sessionId, session);
    logger.info(`Session created: ${sessionId} (container: ${containerId})`);

    return session;
  }

  /**
   * Get session data by sessionId
   */
  getSession(sessionId: string): SessionData | undefined {
    const session = this.sessions.get(sessionId);
    if (session) {
      // Update last activity
      session.lastActivity = Date.now();
      this.sessions.set(sessionId, session);
    }
    return session;
  }

  /**
   * Update session data
   */
  updateSession(sessionId: string, updates: Partial<SessionData>): void {
    const session = this.sessions.get(sessionId);
    if (!session) {
      logger.warn(`Attempted to update non-existent session: ${sessionId}`);
      return;
    }

    const updatedSession = {
      ...session,
      ...updates,
      lastActivity: Date.now(),
    };