import { strictEqual } from 'node:assert'
import { once } from 'node:events'
import { cacheStores } from 'undici'

const body = Buffer.from('abc')
const maxEntrySize = body.byteLength
const now = Date.now()

const value = {
  statusCode: 200,
  statusMessage: 'OK',
  headers: {},
  cachedAt: now,
  staleAt: now + 60_000,
  deleteAt: now + 120_000
}

const key = (path) => ({
  origin: 'https://example.com',
  method: 'GET',
  path,
  headers: {}
})

const store = new cacheStores.SqliteCacheStore({ maxEntrySize })

const stream = store.createWriteStream(key('/stream'), value)
stream.end(body)
await once(stream, 'close')

strictEqual(store.get(key('/stream')).body.toString(), 'abc')

store.close()

const body = Buffer.from('abc')
const maxEntrySize = body.byteLength