Class AsyncCacheStore

test/interceptors/cache-async-store.js:18–48

* Wraps a MemoryCacheStore to simulate an async remote store: * - get() always returns a Promise * - body is returned as a Readable stream instead of an array

 * - body is returned as a Readable stream instead of an array
 */
class AsyncCacheStore {
  #inner

  constructor () {
    this.#inner = new MemoryCacheStore()
  }

  async get (key) {
    const result = this.#inner.get(key)
    if (!result) return undefined

    const { body, ...rest } = result
    const readable = new Readable({ read () {} })
    if (body) {
      for (const chunk of body) {
        readable.push(chunk)
      }
    }
    readable.push(null)

    return { ...rest, body: readable }
  }

  createWriteStream (key, value) {
    return this.#inner.createWriteStream(key, value)
  }

  delete (key) {
    return this.#inner.delete(key)
  }
}

describe('cache interceptor with async store', () => {
  test('stale-while-revalidate 304 refreshes cache with async store', async () => {