fixing wildcard pattern support

index.js

@@ -76,13 +76,18 @@ const middleware = (opts) => async (req, res, next) => {
       if (payload.headers[X_CACHE_EXPIRE]) {
         // support service level expiration
         const keysPattern = payload.headers[X_CACHE_EXPIRE].replace(/\s/g, '')
-        const patterns = keysPattern.split(',').map(pattern =>
-          pattern.endsWith('*') ? pattern : [pattern, pattern + DATA_POSTFIX])
-          .reduce((acc, item) => {
+        const patterns = keysPattern.split(',').map(pattern => pattern.endsWith('*')
+          ? pattern
+          : [pattern, pattern + DATA_POSTFIX]
+        ).reduce((acc, item) => {
+          if (Array.isArray(item)) {
             acc.push(...item)
+          } else {
+            acc.push(item)
+          }
 
-            return acc
-          }, [])
+          return acc
+        }, [])
         // delete keys on all cache tiers
         patterns.forEach(pattern => opts.stores.forEach(store => getKeys(store, pattern).then(keys => mcache.del(keys))))
       } else if (payload.headers[X_CACHE_TIMEOUT] || payload.headers[CACHE_CONTROL]) {

test/smoke.test.js

@@ -61,6 +61,11 @@ describe('cache middleware', () => {
       res.setHeader('x-cache-expire', '*/cache')
       res.end()
     })
+
+    server.delete('/cache2', (req, res) => {
+      res.setHeader('x-cache-expire', '*/cache*')
+      res.end()
+    })
   })
 
   it('start', async () => {
@@ -94,7 +99,17 @@ describe('cache middleware', () => {
     await got.delete('http://localhost:3000/cache')
   })
 
-  it('create cache 2', async () => {
+  it('re-create cache', async () => {
+    const res = await got('http://localhost:3000/cache')
+    expect(res.body).to.equal('hello')
+    expect(res.headers['x-cache-hit']).to.equal(undefined)
+  })
+
+  it('cache expire using wildcard', async () => {
+    await got.delete('http://localhost:3000/cache2')
+  })
+
+  it('re-create cache', async () => {
     const res = await got('http://localhost:3000/cache')
     expect(res.body).to.equal('hello')
     expect(res.headers['x-cache-hit']).to.equal(undefined)