Class SessionStore

api/src/services/sessionStore.ts:9–119

const SESSION_TTL = parseInt(process.env.SESSION_TTL || "604800");

class SessionStore {
  /**
   * Save session data to Redis
   * @param sessionId The session ID
   * @param session Session data
   * @returns Promise that resolves when the session is saved
   */
  async saveSession(sessionId: string, session: UserSession): Promise<void> {
    await redis.set(`session:${sessionId}`, JSON.stringify(session));
    await redis.expire(`session:${sessionId}`, SESSION_TTL);
  }

  /**
   * Get session data from Redis
   * @param sessionId The session ID
   * @returns Session data or null if not found
   */
  async getSession(sessionId: string): Promise<UserSession | null> {
    const data = await redis.get(`session:${sessionId}`);
    if (!data) return null;

    try {
      const session = JSON.parse(data) as UserSession;

      // Convert date strings back to Date objects
      if (session.expiresAt) {
        session.expiresAt = new Date(session.expiresAt);
      }
      if (session.createdAt) {
        session.createdAt = new Date(session.createdAt);
      }

      return session;
    } catch (error) {
      console.error("Error parsing session data:", error);
      return null;
    }
  }

  /**
   * Remove a session from Redis
   * @param sessionId The session ID
   */
  async removeSession(sessionId: string): Promise<void> {
    await redis.del(`session:${sessionId}`);
  }

  /**
   * Update an existing session with new data
   * @param sessionId The session ID
   * @param updatedData The updated session data
   */
  async updateSession(
    sessionId: string,
    updatedData: Partial<UserSession>
  ): Promise<void> {
    const session = await this.getSession(sessionId);
    if (!session) return;