SessionCacheStrategy

import { CachedSession, Logger, SessionCacheStrategy, VendurePlugin } from '@vendure/core';import { Redis, RedisOptions } from 'ioredis';export interface RedisSessionCachePluginOptions {  namespace?: string;  redisOptions?: RedisOptions;}const loggerCtx = 'RedisSessionCacheStrategy';const DEFAULT_NAMESPACE = 'vendure-session-cache';const DEFAULT_TTL = 86400;export class RedisSessionCacheStrategy implements SessionCacheStrategy {  private client: Redis;  constructor(private options: RedisSessionCachePluginOptions) {}  init() {    this.client = new Redis(this.options.redisOptions as RedisOptions);    this.client.on('error', err => Logger.error(err.message, loggerCtx, err.stack));  }  async destroy() {    await this.client.quit();  }  async get(sessionToken: string): Promise<CachedSession | undefined> {    try {      const retrieved = await this.client.get(this.namespace(sessionToken));      if (retrieved) {        try {          return JSON.parse(retrieved);        } catch (e: any) {          Logger.error(`Could not parse cached session data: ${e.message}`, loggerCtx);        }      }    } catch (e: any) {      Logger.error(`Could not get cached session: ${e.message}`, loggerCtx);    }  }  async set(session: CachedSession) {    try {      await this.client.set(this.namespace(session.token), JSON.stringify(session), 'EX', DEFAULT_TTL);    } catch (e: any) {      Logger.error(`Could not set cached session: ${e.message}`, loggerCtx);    }  }  async delete(sessionToken: string) {    try {      await this.client.del(this.namespace(sessionToken));    } catch (e: any) {      Logger.error(`Could not delete cached session: ${e.message}`, loggerCtx);    }  }  clear() {    // not implemented  }  private namespace(key: string) {    return `${this.options.namespace ?? DEFAULT_NAMESPACE}:${key}`;  }}@VendurePlugin({  configuration: config => {    config.authOptions.sessionCacheStrategy = new RedisSessionCacheStrategy(      RedisSessionCachePlugin.options,    );    return config;  },})export class RedisSessionCachePlugin {  static options: RedisSessionCachePluginOptions;  static init(options: RedisSessionCachePluginOptions) {    this.options = options;    return this;  }}

interface SessionCacheStrategy extends InjectableStrategy {    set(session: CachedSession): void | Promise<void>;    get(sessionToken: string): CachedSession | undefined | Promise<CachedSession | undefined>;    delete(sessionToken: string): void | Promise<void>;    clear(): void | Promise<void>;}

type CachedSessionUser = {    id: ID;    identifier: string;    verified: boolean;    channelPermissions: UserChannelPermissions[];}

type CachedSession = {    cacheExpiry: number;    id: ID;    token: string;    expires: Date;    activeOrderId?: ID;    authenticationStrategy?: string;    user?: CachedSessionUser;    activeChannelId?: ID;    apiType?: ApiType;}