123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120
import { ICacheAdapter } from './adapter.ts'// Not in deps.ts to allow optional dep loadingimport {  connect,  Redis,  RedisConnectOptions,  RedisValue} from 'https://deno.land/x/redis@v0.25.1/mod.ts'
/** Redis Cache Adapter for using Redis as a cache-provider. */export class RedisCacheAdapter implements ICacheAdapter {  _redis: Promise<Redis>  redis?: Redis  ready: boolean = false  readonly _expireIntervalTimer: number = 5000  private _expireInterval?: number
  constructor(options: RedisConnectOptions) {    this._redis = connect(options)    this._redis.then(      (redis) => {        this.redis = redis        this.ready = true        this._startExpireInterval()      },      () => {        // TODO: Make error for this      }    )  }
  private _startExpireInterval(): void {    this._expireInterval = setInterval(() => {      this.redis?.scan(0, { pattern: '*:expires' }).then(([_, names]) => {        for (const name of names) {          this.redis?.hvals(name).then((vals) => {            for (const val of vals) {              const expireVal: {                name: string                key: string                at: number              } = JSON.parse(val)              const expired = new Date().getTime() > expireVal.at              if (expired) this.redis?.hdel(expireVal.name, expireVal.key)            }          })        }      })    }, this._expireIntervalTimer)  }
  async _checkReady(): Promise<void> {    if (!this.ready) await this._redis  }
  async get<T>(cacheName: string, key: string): Promise<T | undefined> {    await this._checkReady()    const cache = await this.redis?.hget(cacheName, key)    if (cache === undefined) return    try {      return JSON.parse(cache) as T    } catch (e) {      return cache as unknown as T    }  }
  async set<T>(    cacheName: string,    key: string,    value: T,    expire?: number  ): Promise<void> {    await this._checkReady()    await this.redis?.hset(      cacheName,      key,      typeof value === 'object'        ? JSON.stringify(value)        : (value as unknown as RedisValue)    )    if (expire !== undefined) {      await this.redis?.hset(        `${cacheName}:expires`,        key,        JSON.stringify({          name: cacheName,          key,          at: new Date().getTime() + expire        })      )    }  }
  async delete(cacheName: string, ...keys: string[]): Promise<boolean> {    await this._checkReady()    return ((await this.redis?.hdel(cacheName, ...keys)) ?? 0) === keys.length  }
  async array<T>(cacheName: string): Promise<T[] | undefined> {    await this._checkReady()    const data = await this.redis?.hvals(cacheName)    return data?.map((e: string) => JSON.parse(e))  }
  async keys(cacheName: string): Promise<string[] | undefined> {    await this._checkReady()    return this.redis?.hkeys(cacheName)  }
  async deleteCache(cacheName: string): Promise<boolean> {    await this._checkReady()    return (await this.redis?.del(cacheName)) !== 0  }
  async size(cacheName: string): Promise<number | undefined> {    await this._checkReady()    return this.redis?.hlen(cacheName)  }}