refactor: comprehensive codebase optimization and restructuring

Major changes:
- Migrated API framework from Elysia to Fastify
- Removed duplicate dependencies (tmp-promise, undici)
- Consolidated duplicate utilities (MIME, date, temp, convert, encoding)
- Flattened directory structure (interfaces/api, features/recall, features/media, etc.)
- Removed unnecessary single-file directories
- Merged src/app into src/index.ts
- Created shared utilities (registerDualRoute, ErrorResponses, TTLCache)
- Standardized file naming (camelCase for utilities)
- Fixed RecallFeature dynamic imports for better testability
- Fixed all test failures (40/40 tests passing)

This refactoring significantly improves code maintainability, reduces duplication,
and simplifies the project structure.

Author: magisk317

main/package-lock.json

@@ -31,15 +31,15 @@
     "vitest": "^4.0.15"
   },
   "dependencies": {
-    "@bogeychan/elysia-polyfills": "^0.6.4",
-    "@elysiajs/html": "^1.4.0",
+    "@fastify/cors": "^11.1.0",
+    "@fastify/static": "^8.3.0",
     "@kitajs/html": "^4.2.11",
     "@mtcute/core": "^0.27.2",
     "@mtcute/dispatcher": "^0.27.2",
     "@mtcute/node": "^0.27.2",
     "@prisma/adapter-pg": "7.1.0",
     "@prisma/client": "7.1.0",
-    "elysia": "^1.4.18",
+    "fastify": "^5.6.2",
     "file-type": "^21.1.1",
     "node-napcat-ts": "^0.4.20",
     "pg": "^8.16.3",

main/package.json

@@ -2,8 +2,8 @@ import { getLogger } from '../shared/logger';
 import type { IQQClient } from '../infrastructure/clients/qq';
 import type Telegram from '../infrastructure/clients/telegram/client';
 import type Instance from '../domain/models/Instance';
-import { RecallFeature } from './recall/RecallFeature';
-import { MediaFeature } from './media/MediaFeature';
+import { RecallFeature } from './RecallFeature';
+import { MediaFeature } from './MediaFeature';
 import { CommandsFeature } from './commands/CommandsFeature';
 import { ForwardFeature } from './forward/ForwardFeature';
 

main/src/app/index.ts

@@ -1,11 +1,11 @@
-import { getLogger } from '../../shared/logger';
-import type { IQQClient } from '../../infrastructure/clients/qq';
-import type { UnifiedMessage, ImageContent, VideoContent, AudioContent } from '../../domain/message';
-import type Telegram from '../../infrastructure/clients/telegram/client';
-import type Instance from '../../domain/models/Instance';
+import { getLogger } from '../shared/logger';
+import type { IQQClient } from '../infrastructure/clients/qq';
+import type { UnifiedMessage, ImageContent, VideoContent, AudioContent } from '../domain/message';
+import type Telegram from '../infrastructure/clients/telegram/client';
+import type Instance from '../domain/models/Instance';
 
 import { createReadStream } from 'fs';
-import { file as createTempFile } from '../../shared/utils/temp';
+import { file as createTempFile } from '../shared/utils/temp';
 import fsP from 'fs/promises';
 
 const logger = getLogger('MediaFeature');

main/src/domain/message/services/MessageConverter.ts renamed to main/src/domain/message/MessageConverter.ts

@@ -1,9 +1,10 @@
-import { getLogger } from '../../shared/logger';
-import type { IQQClient } from '../../infrastructure/clients/qq';
-import type { RecallEvent } from '../../domain/message';
-import type Telegram from '../../infrastructure/clients/telegram/client';
-import type Instance from '../../domain/models/Instance';
-import db from '../../domain/models/db';
+import { getLogger } from '../shared/logger';
+import type { IQQClient } from '../infrastructure/clients/qq';
+import type { RecallEvent } from '../domain/message';
+import type Telegram from '../infrastructure/clients/telegram/client';
+import type Instance from '../domain/models/Instance';
+import db from '../domain/models/db';
+import env from '../domain/models/env';
 
 const logger = getLogger('RecallFeature');
 
@@ -40,7 +41,6 @@ export class RecallFeature {
             logger.info(`QQ message recalled: ${event.messageId}`);
 
             // 检查是否启用自动撤回
-            const { default: env } = await import('../../domain/models/env');
             if (!env.ENABLE_AUTO_RECALL) {
                 logger.debug('Auto recall is disabled, skipping TG message deletion');
                 return;
@@ -96,7 +96,6 @@ export class RecallFeature {
             logger.info(`TG messages deleted in ${chatId}: ${messageIds.join(', ')}`);
 
             // 检查是否启用自动撤回
-            const { default: env } = await import('../../domain/models/env');
             if (!env.ENABLE_AUTO_RECALL) {
                 logger.debug('Auto recall disabled, skipping QQ message recall');
                 return;

main/src/features/FeatureManager.ts

@@ -1,5 +1,5 @@
 import { describe, it, expect, beforeEach, vi } from 'vitest';
-import { MediaFeature } from '../media/MediaFeature';
+import { MediaFeature } from '../MediaFeature';
 import type { ImageContent, VideoContent, AudioContent } from '../../domain/message';
 
 // Mock global fetch

main/src/features/media/MediaFeature.ts renamed to main/src/features/MediaFeature.ts

@@ -1,7 +1,4 @@
 import { describe, it, expect, beforeEach, vi } from 'vitest';
-import { RecallFeature } from '../recall/RecallFeature';
-import type { RecallEvent } from '../../domain/message';
-import type { IQQClient } from '../../infrastructure/clients/qq';
 
 // Mock database
 vi.mock('../../domain/models/db', () => ({
@@ -13,6 +10,21 @@ vi.mock('../../domain/models/db', () => ({
     },
 }));
 
+// Mock environment
+vi.mock('../../domain/models/env', () => ({
+    default: {
+        ENABLE_AUTO_RECALL: true,
+        LOG_FILE: '/tmp/test-logs/app.log',
+        LOG_LEVEL: 'off',
+        LOG_FILE_LEVEL: 'off',
+        DATA_DIR: '/tmp/test-data',
+    },
+}));
+
+// Now import after mocks are set up
+import { RecallFeature } from '../RecallFeature';
+import type { RecallEvent } from '../../domain/message';
+import type { IQQClient } from '../../infrastructure/clients/qq';
 import db from '../../domain/models/db';
 
 const createMockQQClient = (): IQQClient => ({
@@ -152,7 +164,13 @@ describe('RecallFeature', () => {
             };
 
             (db.message.findFirst as any).mockResolvedValue(mockDbEntry);
-            mockTgBot.deleteMessages.mockRejectedValue(new Error('TG API Error'));
+            (db.message.update as any).mockResolvedValue({ ...mockDbEntry, ignoreDelete: true });
+
+            // Mock getChat to return a chat with failing deleteMessages
+            const mockChat = {
+                deleteMessages: vi.fn().mockRejectedValue(new Error('TG API Error')),
+            };
+            mockTgBot.getChat.mockResolvedValue(mockChat);
 
             await expect(
                 recallFeature['handleQQRecall'](recallEvent)