dashpresshq/dashpress

import type { ConfigApiService } from "../config/config.service";
import { AbstractConfigDataPersistenceService } from "./AbstractConfigDataPersistenceService";
import type { ConfigDomain } from "./types";

export class MemoryConfigDataPersistenceAdaptor<
  T
> extends AbstractConfigDataPersistenceService<T> {
  private static data: Record<string, Record<string, any>> = {};

  constructor(configDomain: ConfigDomain, configApiService: ConfigApiService) {
    super(configDomain, configApiService);
  }

  getItemLastUpdated() {
    return null;
  }

  static getDomainData(configDomain: ConfigDomain) {
    if (!MemoryConfigDataPersistenceAdaptor.data[configDomain]) {
      MemoryConfigDataPersistenceAdaptor.data = {
        ...MemoryConfigDataPersistenceAdaptor.data,
        [configDomain]: {},
      };
    }
    return MemoryConfigDataPersistenceAdaptor.data[configDomain];
  }

  async _resetToEmpty() {
    MemoryConfigDataPersistenceAdaptor.data[this._configDomain] = {};
  }

  private persistDomainData(data: Record<string, T>) {
    MemoryConfigDataPersistenceAdaptor.data[this._configDomain] = data;
  }

  async getAllAsKeyValuePair() {
    return MemoryConfigDataPersistenceAdaptor.getDomainData(this._configDomain);
  }

  async getAllItems() {
    return Object.values(await this.getAllAsKeyValuePair());
  }

  async getAllItemsIn(itemIds: string[]) {
    const allItems = MemoryConfigDataPersistenceAdaptor.getDomainData(
      this._configDomain
    );

    return Object.fromEntries(
      itemIds.map((itemId) => [itemId, allItems[itemId]])
    );
  }

  async _getItem(key: string) {
    const currentItem = MemoryConfigDataPersistenceAdaptor.getDomainData(
      this._configDomain
    )[key];
    if (currentItem) {
      return currentItem;
    }
    return undefined;
  }

  async _persistItem(key: string, data: T) {
    const domainData = MemoryConfigDataPersistenceAdaptor.getDomainData(
      this._configDomain
    );
    domainData[key] = data;
    this.persistDomainData(domainData);
  }

  async _removeItem(key: string): Promise<void> {
    const domainData = MemoryConfigDataPersistenceAdaptor.getDomainData(
      this._configDomain
    );

    delete domainData[key];

    this.persistDomainData(domainData);
  }

  async saveAllItems(keyField: keyof T, data: T[]) {
    this.persistDomainData(
      Object.fromEntries(data.map((datum) => [datum[keyField], datum]))
    );
  }
}