feat: add memory adapter

Author: BearToCode

package.json

@@ -9,7 +9,7 @@
 		"test:push-schema": "prisma db push --schema ./tests/prisma/schema.prisma",
 		"build": "tsc -p tsconfig.build.json",
 		"test": "vitest",
-		"lint": "prettier --check . && eslint .",
+		"lint": "prettier --write . && eslint .",
 		"format": "prettier --write .",
 		"postinstall": "husky install",
 		"commit": "git-cz"

src/index.ts

@@ -161,3 +161,6 @@ export function cache(opts: CacheOptions) {
 		});
 	});
 }
+
+export * from './types';
+export * from './storage';

src/storage/acebase.ts

@@ -1,6 +1,6 @@
 import type { AceBase } from 'acebase';
+import type { Adapter } from '.';
 import hash from 'object-hash';
-import { Adapter } from '.';
 
 export function adapterAceBase(acebase: AceBase): Adapter {
 	return ({ logger }) => ({

src/storage/index.ts

@@ -22,3 +22,6 @@ export interface Database {
 	clear(model: string): Promise<void>;
 	clearAll(): Promise<void>;
 }
+
+export * from './acebase';
+export * from './memory';

src/storage/memory.ts

@@ -0,0 +1,37 @@
+import type { Adapter } from '.';
+import hash from 'object-hash';
+
+export function adapterMemory(): Adapter {
+	const storage = new Map<string, string>();
+	return ({ logger }) => ({
+		async get({ model, operation, args }) {
+			const queryHash = hash({ operation, args });
+			const key = `${model}:${queryHash}`;
+
+			logger.module('memory').log(`Get key ${key}`);
+			const value = storage.get(key);
+			if (value) {
+				logger.module('memory').log(`Found value:`, value);
+				return JSON.parse(value);
+			}
+			return null;
+		},
+		async set({ model, operation, args }, value) {
+			const queryHash = hash({ operation, args });
+			const key = `${model}:${queryHash}`;
+
+			logger.module('memory').log(`Set key ${key}`);
+			storage.set(key, JSON.stringify(value));
+		},
+		async clear(model) {
+			for (const [key] of storage.entries()) {
+				if (key.startsWith(`${model}:`)) {
+					storage.delete(key);
+				}
+			}
+		},
+		async clearAll() {
+			storage.clear();
+		}
+	});
+}

tests/memory.test.ts

@@ -0,0 +1,6 @@
+import { adapterMemory } from '@/storage';
+import { testAdapter } from './adapter-tests';
+
+const adapter = adapterMemory();
+
+await testAdapter(adapter);