import type { CacheStack } from './cache-stack';
import { CacheBusMessageType } from '../../types/main';
import { CacheWritten } from '../../events/cache/cache-written';
import type { CacheEntryOptions } from '../cache-entry/cache-entry-options';

export class CacheStackWriter {
  constructor(protected cacheStack: CacheStack) {}

  /**
   * Write a value in the cache stack
   * - Set value in local cache
   * - Set value in remote cache
   * - Publish a message to the bus
   * - Emit a CacheWritten event
   */
  async set(key: string, value: any, options: CacheEntryOptions) {
    const item = this.cacheStack.serialize({
      value,
      logicalExpiration: options.logicalTtlFromNow(),
      earlyExpiration: options.earlyExpireTtlFromNow(),
    });

    this.cacheStack.l1?.set(key, item, options);
    await this.cacheStack.l2?.set(key, item, options);
    await this.cacheStack.publish({ type: CacheBusMessageType.Set, keys: [key] });

    this.cacheStack.emit(new CacheWritten(key, value, this.cacheStack.name));
    return true;
  }
}