feat: support memcached

package.json

@@ -43,13 +43,15 @@
     "unstorage": "pnpm jiti src/cli"
   },
   "dependencies": {
+    "@types/memcached": "^2.2.7",
     "anymatch": "^3.1.3",
     "chokidar": "^3.5.3",
     "destr": "^2.0.0",
     "h3": "^1.7.0",
     "ioredis": "^5.3.2",
     "listhen": "^1.0.4",
     "lru-cache": "^10.0.0",
+    "memcached": "^2.2.2",
     "mri": "^1.2.0",
     "node-fetch-native": "^1.2.0",
     "ofetch": "^1.1.1",

src/drivers/memcached.ts

@@ -0,0 +1,55 @@
+import { defineDriver } from "./utils";
+import Memcached from 'memcached';
+
+export interface MemcachedOpts {
+    serverLocation: Memcached.Location;
+    connectionOptions: Memcached.options;
+}
+
+
+export default defineDriver<MemcachedOpts>((_opts : MemcachedOpts) => {
+    //@ts-ignore-next-line
+    const memcached = new Memcached(_opts.serverLocation || 'localhost:11211', _opts.connectionOptions || {});
+    return {
+        async getItem(key) {
+            return await new Promise((resolve, reject) => {
+                memcached.get(key, (err, data) => {
+                    if (err) reject(err);
+                    resolve(data);
+                })
+            });
+        },
+
+
+        async hasItem(key: string) {
+            return await new Promise((resolve, reject) => {
+                memcached.get(key, (err, data) => {
+                    if (err) reject(err);
+                    resolve(data || false);
+                })
+            });
+        },
+
+
+        async setItem(key: string, value: string, lifetime: number | undefined) {
+            if (lifetime === undefined) throw new Error('Lifetime must be a number when using memcached!');
+            return await new Promise((resolve, reject) => {
+                memcached.set(key, value, lifetime, (err, result) => {
+                    if (err) reject(err);
+                    if (!result) reject('Failed');
+                    resolve();
+                });
+            });
+        },
+
+        async removeItem(key) {
+            return await new Promise((resolve, reject) => {
+                memcached.del(key, (err, result) => {
+                    if (err) reject(err);
+                    if (!result) reject('Failed');
+                    resolve();
+                })
+            })
+        },
+    }
+});

test/drivers/memcached.test.ts

@@ -0,0 +1,23 @@
+import { describe, it, expect, vi, vitest, beforeEach, afterEach } from 'vitest'
+import driver from '../../src/drivers/memcached'
+import { createStorage } from '../../src'
+import { testDriver } from './utils'
+
+describe('Memcached storage', () => {
+    const storage = driver({
+        serverLocation: 'localhost:11211',
+        connectionOptions: {}
+    });
+
+    it('driver: basic',async () => {
+        // @ts-ignore
+        await storage.setItem('basic', 'foo', 0);
+        let got = await storage.getItem('basic');
+        const has = await storage.hasItem('basic');
+        expect(got).toBe('foo');
+        expect(has).toBeTruthy();
+        await storage.removeItem('basic');
+        got = await storage.getItem('basic');
+        expect(got).toBeUndefined();
+    });
+});