refactor: 抽离 KV 模块

Author: clansty

apps/qqbot/package.json

@@ -12,10 +12,12 @@
     "build"
   ],
   "dependencies": {
+    "@deno/kv": "^0.8.3",
     "level": "^8.0.1",
     "puppeteer": "^23.4.0"
   },
   "devDependencies": {
+    "@clansty/maibot-adapters": "workspace:^",
     "@clansty/maibot-core": "workspace:^",
     "@clansty/maibot-firm": "workspace:^",
     "@clansty/maibot-types": "workspace:^",

apps/qqbot/src/index.ts

@@ -4,7 +4,7 @@ import YAML from 'yaml';
 import { BotAdapter } from './adapter/Bot';
 import { buildBot } from '@clansty/maibot-core';
 import { Env } from './types';
-import { LevelKV } from './adapter/LevelKV';
+import { LevelKV } from '@clansty/maibot-adapters/src/LevelKV';
 import { Renderer } from './adapter/Renderer';
 
 fs.mkdirSync('data/cache', { recursive: true });

apps/qqofbot/package.json

@@ -12,10 +12,12 @@
     "build"
   ],
   "dependencies": {
+    "@deno/kv": "^0.8.3",
     "level": "^8.0.1",
     "puppeteer": "^23.4.0"
   },
   "devDependencies": {
+    "@clansty/maibot-adapters": "workspace:^",
     "@clansty/maibot-core": "workspace:^",
     "@clansty/maibot-firm": "workspace:^",
     "@clansty/maibot-types": "workspace:^",

apps/qqofbot/src/adapter/LevelKV.ts

@@ -4,7 +4,7 @@ import YAML from 'yaml';
 import { BotAdapter } from './adapter/Bot';
 import { buildBot } from '@clansty/maibot-core';
 import { Env } from './types';
-import { LevelKV } from './adapter/LevelKV';
+import { LevelKV } from '@clansty/maibot-adapters';
 import { Renderer } from './adapter/Renderer';
 
 fs.mkdirSync('data/cache', { recursive: true });

apps/qqofbot/src/index.ts

@@ -0,0 +1,65 @@
+version: '3'
+
+volumes:
+  data:
+  data-official:
+  napcat-qq:
+  napcat-config:
+
+services:
+  denokv:
+    image: ghcr.io/denoland/denokv
+    init: true
+    volumes:
+      - denokv-data:/data
+    command: --sqlite-path /data/denokv.sqlite serve --access-token random-token
+    ports:
+      - "4512:4512"
+
+  napcat:
+    environment:
+      - ACCOUNT=3087530651
+      - WS_ENABLE=true
+      - NAPCAT_GID=1000
+      - NAPCAT_UID=1000
+    ports:
+      - "6097:6099"
+    mac_address: 02:42:AC:11:21:83
+    restart: unless-stopped
+    image: mlikiowa/napcat-docker
+    dns: 11.11.1.1
+    volumes:
+      - napcat-qq:/app/.config/QQ
+      - napcat-config:/app/napcat/config
+      - data:/app/data
+    labels:
+      - traefik.enable=false
+    stop_signal: SIGKILL
+
+  bot:
+    restart: unless-stopped
+    depends_on:
+      - napcat
+    image: gitea.c5y.moe/clansty/maibot-qq
+    stop_signal: SIGKILL
+    dns: 11.11.1.1
+    volumes:
+      - data:/app/data
+      - /home/clansty/aquadx-bot.yaml:/app/env.yaml:ro
+    labels:
+      - traefik.enable=false
+    cap_add:
+      - SYS_ADMIN
+
+  bot-official:
+    restart: unless-stopped
+    image: gitea.c5y.moe/clansty/maibot-qq-official
+    stop_signal: SIGKILL
+    dns: 11.11.1.1
+    volumes:
+      - data-official:/app/data
+      - /home/clansty/aquadx-bot.yaml:/app/env.yaml:ro
+    labels:
+      - traefik.enable=false
+    cap_add:
+      - SYS_ADMIN

docker-compose.yaml

@@ -3,11 +3,11 @@
   "scripts": {
     "dev:web": "pnpm run --filter=@clansty/maibot-web dev",
     "dev:bot": "pnpm run --filter=@clansty/maibot-workers dev",
-    "dev": "pnpm run --filter=@clansty/maibot-workers --filter=@clansty/maibot-web --stream --parallel dev",
-    "deploy": "pnpm run --filter=@clansty/maibot-workers --filter=@clansty/maibot-onebot --filter=@clansty/maibot-qofbot --filter=@clansty/maibot-web --stream --parallel \"/^deploy.*/\" && pnpm run deploy:docker",
+    "dev": "pnpm run --filter=@clansty/maibot-workers --filter=@clansty/maibot-web --parallel dev",
+    "deploy": "pnpm run --filter=@clansty/maibot-workers --filter=@clansty/maibot-onebot --filter=@clansty/maibot-qofbot --filter=@clansty/maibot-web --parallel \"/^deploy.*/\" && pnpm run deploy:docker",
     "deploy:docker": "curl -X POST -vL https://portainer.c5y.moe/api/stacks/webhooks/10d9fea3-43d2-46c3-811a-e65293d4d0cb",
     "deploy:tg": "pnpm run --filter=@clansty/maibot-workers deploy",
-    "deploy:qq": "pnpm run --filter=@clansty/maibot-onebot --filter=@clansty/maibot-qofbot deploy",
+    "deploy:qq": "pnpm run --filter=@clansty/maibot-onebot --filter=@clansty/maibot-qofbot deploy && pnpm run deploy:docker",
     "deploy:web": "pnpm run --filter=@clansty/maibot-web deploy",
     "tail": "pnpm run --filter=@clansty/maibot-workers tail"
   },

package.json

@@ -0,0 +1,13 @@
+{
+  "name": "@clansty/maibot-adapters",
+  "version": "0.0.0",
+  "type": "module",
+  "private": true,
+  "main": "src/index.ts",
+  "types": "src/index.ts",
+  "devDependencies": {
+    "@clansty/maibot-types": "workspace:^",
+    "@deno/kv": "^0.8.3",
+    "level": "^8.0.1"
+  }
+}

packages/adapters/package.json

@@ -0,0 +1,31 @@
+import { KVStorage } from '@clansty/maibot-types';
+import { openKv, Kv } from '@deno/kv';
+
+export class DenoKV extends KVStorage {
+	private readonly kv: Promise<Kv>;
+
+	constructor(url: string) {
+		super();
+		this.kv = openKv(url);
+	}
+
+	async get<T>(key: string): Promise<T | undefined> {
+		try {
+			const kv = await this.kv;
+			const res = await kv.get<T>([key]);
+			return res.value;
+		} catch {
+			return undefined;
+		}
+	}
+
+	async set<T>(key: string, value: T, ttl?: number): Promise<void> {
+		const kv = await this.kv;
+		await kv.set([key], value, { expireIn: ttl ? ttl * 1000 : undefined });
+	}
+
+	async delete(key: string): Promise<void> {
+		const kv = await this.kv;
+		await kv.delete([key]);
+	}
+}