Function clearNamespacedCache

src/cache.ts:187–222

(cache: Cache, namespace: string)

}

async function clearNamespacedCache(cache: Cache, namespace: string) {
  const namespacePrefix = `${namespace}:`;

  for (const store of cache.stores) {
    if (!store.iterator) {
      throw new Error(
        `[Cache] Cannot clear namespace ${namespace} because a cache store does not support key iteration.`,
      );
    }

    const keysToDelete: string[] = [];
    for await (const [key] of store.iterator(undefined)) {
      if (typeof key === 'string' && key.startsWith(namespacePrefix)) {
        keysToDelete.push(key);
      }
    }

    if (keysToDelete.length === 0) {
      continue;
    }

    try {
      if (store.deleteMany) {
        await store.deleteMany(keysToDelete);
      } else {
        await Promise.all(keysToDelete.map((key) => store.delete(key)));
      }
    } catch (err) {
      throw new Error(
        `[Cache] Failed to clear ${keysToDelete.length} keys for namespace "${namespace}": ${(err as Error).message}`,
      );
    }
  }

  return true;
}

/**
 * Run a function with isolated cache namespace.