session-desktop/ts/session/revocation_list/pro_revocation_list.ts

import { isNumber } from 'lodash/fp';
import { SettingsKey } from '../../data/settings-key';
import { Storage } from '../../util/storage';
import {
  ProRevocationItemsSchema,
  type ProRevocationItemsType,
} from '../apis/pro_backend_api/schemas';

let cachedProRevocationListTicket = 0;
let cachedProRevocationListItems: ProRevocationItemsType = [];

function getTicket() {
  if (cachedProRevocationListTicket !== 0) {
    return cachedProRevocationListTicket;
  }
  const ticketFromDb = Storage.get(SettingsKey.proRevocationListTicket);

  const lastFetchTicket = isNumber(ticketFromDb) ? ticketFromDb : 0;
  if (!lastFetchTicket) {
    cachedProRevocationListTicket = lastFetchTicket;
  }
  return lastFetchTicket;
}

async function setTicket(ticket: number) {
  cachedProRevocationListTicket = ticket;
  await Storage.put(SettingsKey.proRevocationListTicket, ticket);
}

async function getListItems(): Promise<ProRevocationItemsType> {
  if (cachedProRevocationListItems.length) {
    return cachedProRevocationListItems;
  }
  const itemsFromDb = Storage.get(SettingsKey.proRevocationListItems);

  if (!itemsFromDb) {
    cachedProRevocationListItems = [];
    return cachedProRevocationListItems;
  }
  const parsed = ProRevocationItemsSchema.safeParse(itemsFromDb);
  if (parsed.success) {
    cachedProRevocationListItems = parsed.data;
    return cachedProRevocationListItems;
  }
  window.log.error(
    'failed to parse pro revocation list items from storage, removing item. error:',
    parsed.error
  );
  await Storage.remove(SettingsKey.proRevocationListItems);
  cachedProRevocationListItems = [];
  return cachedProRevocationListItems;
}

async function setListItems(items: ProRevocationItemsType) {
  cachedProRevocationListItems = items;
  await Storage.put(SettingsKey.proRevocationListItems, JSON.stringify(items));
}

function clear() {
  cachedProRevocationListTicket = 0;
  cachedProRevocationListItems = [];
}

function isB64HashRevoked(genIndexHashBase64: string) {
  const found = cachedProRevocationListItems.find(m => m.gen_index_hash_b64 === genIndexHashBase64);
  // Note: the revocation list is the list of revoked genIndexHashBase64 that are currently revoked.
  // We do not care about the expiry_unix_ts_ms here as all we care about is the presence of the genIndexHashBase64 in the list.
  return found;
}

export const ProRevocationCache = {
  getTicket,
  setTicket,
  getListItems,
  setListItems,
  clear,
  isB64HashRevoked,
};