lib/cache/memory-cache-store.js

@@ -79,7 +79,13 @@ class MemoryCacheStore {
     const entry = this.#entries.get(topLevelKey)?.find((entry) => (
       entry.deleteAt > now &&
       entry.method === key.method &&
-      (entry.vary == null || Object.keys(entry.vary).every(headerName => entry.vary[headerName] === key.headers[headerName]))
+      (entry.vary == null || Object.keys(entry.vary).every(headerName => {
+        if (entry.vary[headerName] === null) {
+          return key.headers[headerName] === undefined
+        }
+
+        return entry.vary[headerName] === key.headers[headerName]
+      }))
     ))
 
     return entry == null

lib/cache/sqlite-cache-store.js

@@ -411,10 +411,6 @@ module.exports = class SqliteCacheStore {
       let matches = true
 
       if (value.vary) {
-        if (!headers) {
-          return undefined
-        }
-
         const vary = JSON.parse(value.vary)
 
         for (const header in vary) {
@@ -440,18 +436,21 @@ module.exports = class SqliteCacheStore {
  * @returns {boolean}
  */
 function headerValueEquals (lhs, rhs) {
+  if (lhs == null && rhs == null) {
+    return true
+  }
+
+  if ((lhs == null && rhs != null) ||
+      (lhs != null && rhs == null)) {
+    return false
+  }
+
   if (Array.isArray(lhs) && Array.isArray(rhs)) {
     if (lhs.length !== rhs.length) {
       return false
     }
 
-    for (let i = 0; i < lhs.length; i++) {
-      if (rhs.includes(lhs[i])) {
-        return false
-      }
-    }
-
-    return true
+    return lhs.every((x, i) => x === rhs[i])
   }
 
   return lhs === rhs

lib/util/cache.js

@@ -264,7 +264,7 @@ function parseVaryHeader (varyHeader, headers) {
     return headers
   }
 
-  const output = /** @type {Record<string, string | string[] | undefined>} */ ({})
+  const output = /** @type {Record<string, string | string[] | null>} */ ({})
 
   const varyingHeaders = typeof varyHeader === 'string'
     ? varyHeader.split(',')
@@ -273,7 +273,7 @@ function parseVaryHeader (varyHeader, headers) {
   for (const header of varyingHeaders) {
     const trimmedHeader = header.trim().toLowerCase()
 
-    output[trimmedHeader] = headers[trimmedHeader]
+    output[trimmedHeader] = headers[trimmedHeader] ?? null
   }
 
   return output

test/cache-interceptor/utils.js

@@ -214,6 +214,40 @@ describe('parseVaryHeader', () => {
       'another-one': '123'
     })
   })
+
+  test('handles missing headers with null', () => {
+    const result = parseVaryHeader('Accept-Encoding, Authorization', {})
+    deepStrictEqual(result, {
+      'accept-encoding': null,
+      authorization: null
+    })
+  })
+
+  test('handles mix of present and missing headers', () => {
+    const result = parseVaryHeader('Accept-Encoding, Authorization', {
+      authorization: 'example-value'
+    })
+    deepStrictEqual(result, {
+      'accept-encoding': null,
+      authorization: 'example-value'
+    })
+  })
+
+  test('handles array input', () => {
+    const result = parseVaryHeader(['Accept-Encoding', 'Authorization'], {
+      'accept-encoding': 'gzip'
+    })
+    deepStrictEqual(result, {
+      'accept-encoding': 'gzip',
+      authorization: null
+    })
+  })
+
+  test('preserves existing * behavior', () => {
+    const headers = { accept: 'text/html' }
+    const result = parseVaryHeader('*', headers)
+    deepStrictEqual(result, headers)
+  })
 })
 
 describe('isEtagUsable', () => {

test/issue-3959.js

@@ -2,11 +2,12 @@ const { describe, test, after } = require('node:test')
 const assert = require('node:assert')
 const { createServer } = require('node:http')
 const MemoryCacheStore = require('../lib/cache/memory-cache-store.js')
+const SqliteCacheStore = require('../lib/cache/sqlite-cache-store.js')
 const { request, Agent, setGlobalDispatcher } = require('..')
 const { interceptors } = require('..')
 
 describe('Cache with Vary headers', () => {
-  test('should cache response when Vary header exists but request header is missing', async () => {
+  async function runCacheTest (store) {
     let requestCount = 0
     const server = createServer((req, res) => {
       requestCount++
@@ -19,7 +20,6 @@ describe('Cache with Vary headers', () => {
     const port = server.address().port
     const url = `http://localhost:${port}`
 
-    const store = new MemoryCacheStore()
     const agent = new Agent()
     setGlobalDispatcher(
       agent.compose(
@@ -50,6 +50,16 @@ describe('Cache with Vary headers', () => {
     assert.strictEqual(body3, 'Request count: 2')
     assert.strictEqual(requestCount, 2)
 
-    after(() => server.close())
+    await new Promise(resolve => server.close(resolve))
+  }
+
+  test('should cache response with MemoryCacheStore when Vary header exists but request header is missing', async () => {
+    await runCacheTest(new MemoryCacheStore())
+  })
+
+  test('should cache response with SqliteCacheStore when Vary header exists but request header is missing', async () => {
+    const sqliteStore = new SqliteCacheStore()
+    await runCacheTest(sqliteStore)
+    after(() => sqliteStore.close())
   })
 })

test/types/cache-interceptor.test-d.ts

@@ -83,7 +83,7 @@ expectAssignable<CacheInterceptor.CacheValue>({
   statusMessage: 'OK',
   headers: {},
   vary: {
-    'accept-encoding': undefined,
+    'accept-encoding': null,
     authorization: 'example-value'
   },
   cachedAt: 0,
@@ -96,8 +96,8 @@ expectAssignable<CacheInterceptor.CacheValue>({
   statusMessage: 'OK',
   headers: {},
   vary: {
-    'accept-encoding': undefined,
-    authorization: undefined
+    'accept-encoding': null,
+    authorization: null
   },
   cachedAt: 0,
   staleAt: 0,
@@ -109,7 +109,7 @@ expectNotAssignable<CacheInterceptor.CacheValue>({
   statusMessage: 'OK',
   headers: {},
   vary: {
-    'accept-encoding': false,
+    'accept-encoding': undefined,
     authorization: 'example-value'
   },
   cachedAt: 0,

types/cache-interceptor.d.ts

@@ -70,7 +70,7 @@ declare namespace CacheHandler {
     statusCode: number
     statusMessage: string
     headers: Record<string, string | string[]>
-    vary?: Record<string, string | string[] | undefined>
+    vary?: Record<string, string | string[] | null>
     etag?: string
     cacheControlDirectives?: CacheControlDirectives
     cachedAt: number
@@ -88,7 +88,7 @@ declare namespace CacheHandler {
     statusCode: number
     statusMessage: string
     headers: Record<string, string | string[]>
-    vary?: Record<string, string | string[] | undefined>
+    vary?: Record<string, string | string[] | null>
     etag?: string
     body?: Readable | Iterable<Buffer> | AsyncIterable<Buffer> | Buffer | Iterable<string> | AsyncIterable<string> | string
     cacheControlDirectives: CacheControlDirectives,