Merge pull request #1279 from ai16z/feat/redis_adapter

feat: Redis Cache Implementation

Author: shakkernerd

packages/adapter-redis/.npmignore

@@ -0,0 +1,6 @@
+*
+
+!dist/**
+!package.json
+!readme.md
+!tsup.config.ts

packages/adapter-redis/eslint.config.mjs

@@ -0,0 +1,3 @@
+import eslintGlobalConfig from "../../eslint.config.mjs";
+
+export default [...eslintGlobalConfig];

packages/adapter-redis/package.json

@@ -0,0 +1,23 @@
+{
+    "name": "@ai16z/adapter-redis",
+    "version": "0.1.6-alpha.4",
+    "main": "dist/index.js",
+    "type": "module",
+    "types": "dist/index.d.ts",
+    "dependencies": {
+        "@ai16z/eliza": "workspace:*",
+        "ioredis": "5.4.2"
+    },
+    "devDependencies": {
+        "@types/ioredis": "^5.0.0",
+        "tsup": "8.3.5"
+    },
+    "scripts": {
+        "build": "tsup --format esm --dts",
+        "dev": "tsup --format esm --dts --watch",
+        "lint": "eslint --fix  --cache ."
+    },
+    "peerDependencies": {
+        "whatwg-url": "7.1.0"
+    }
+}

packages/adapter-redis/src/index.ts

@@ -0,0 +1,76 @@
+import Redis from "ioredis";
+import { IDatabaseCacheAdapter, UUID, elizaLogger } from "@ai16z/eliza";
+
+export class RedisClient implements IDatabaseCacheAdapter {
+    private client: Redis;
+
+    constructor(redisUrl: string) {
+        this.client = new Redis(redisUrl);
+
+        this.client.on("connect", () => {
+            elizaLogger.success("Connected to Redis");
+        });
+
+        this.client.on("error", (err) => {
+            elizaLogger.error("Redis error:", err);
+        });
+    }
+
+    async getCache(params: {
+        agentId: UUID;
+        key: string;
+    }): Promise<string | undefined> {
+        try {
+            const redisKey = this.buildKey(params.agentId, params.key);
+            const value = await this.client.get(redisKey);
+            return value || undefined;
+        } catch (err) {
+            elizaLogger.error("Error getting cache:", err);
+            return undefined;
+        }
+    }
+
+    async setCache(params: {
+        agentId: UUID;
+        key: string;
+        value: string;
+    }): Promise<boolean> {
+        try {
+            const redisKey = this.buildKey(params.agentId, params.key);
+            await this.client.set(redisKey, params.value);
+            return true;
+        } catch (err) {
+            elizaLogger.error("Error setting cache:", err);
+            return false;
+        }
+    }
+
+    async deleteCache(params: {
+        agentId: UUID;
+        key: string;
+    }): Promise<boolean> {
+        try {
+            const redisKey = this.buildKey(params.agentId, params.key);
+            const result = await this.client.del(redisKey);
+            return result > 0;
+        } catch (err) {
+            elizaLogger.error("Error deleting cache:", err);
+            return false;
+        }
+    }
+
+    async disconnect(): Promise<void> {
+        try {
+            await this.client.quit();
+            elizaLogger.success("Disconnected from Redis");
+        } catch (err) {
+            elizaLogger.error("Error disconnecting from Redis:", err);
+        }
+    }
+
+    private buildKey(agentId: UUID, key: string): string {
+        return `${agentId}:${key}`; // Constructs a unique key based on agentId and key
+    }
+}
+
+export default RedisClient;

packages/adapter-redis/tsconfig.json

@@ -0,0 +1,10 @@
+{
+    "extends": "../core/tsconfig.json",
+    "compilerOptions": {
+        "outDir": "dist",
+        "rootDir": "src"
+    },
+    "include": [
+        "src/**/*.ts"
+    ]
+}

packages/adapter-redis/tsup.config.ts

@@ -0,0 +1,21 @@
+import { defineConfig } from "tsup";
+
+export default defineConfig({
+    entry: ["src/index.ts"],
+    outDir: "dist",
+    sourcemap: true,
+    clean: true,
+    format: ["esm"], // Ensure you're targeting CommonJS
+    external: [
+        "dotenv", // Externalize dotenv to prevent bundling
+        "fs", // Externalize fs to use Node.js built-in module
+        "path", // Externalize other built-ins if necessary
+        "@reflink/reflink",
+        "@node-llama-cpp",
+        "https",
+        "http",
+        "agentkeepalive",
+        "uuid",
+        // Add other modules you want to externalize
+    ],
+});