perf: init tool (#319)

* add gpt5.2

* perf: init tool

* perf: init tool

* perf: init tool

* rename gpt 5.2

* rename gpt 5.2

* rename gpt 5.2

Author: c121914yu

modules/model/provider/OpenAI/index.ts

@@ -3,6 +3,18 @@ import { ModelTypeEnum, type ProviderConfigType } from '../../type';
 const models: ProviderConfigType = {
   provider: 'OpenAI',
   list: [
+    {
+      type: ModelTypeEnum.llm,
+      model: 'gpt-5.2',
+      maxContext: 400000,
+      maxTokens: 128000,
+      quoteMaxToken: 400000,
+      maxTemperature: null,
+      responseFormatList: ['text', 'json_schema'],
+      vision: true,
+      reasoning: false,
+      toolChoice: true
+    },
     {
       type: ModelTypeEnum.llm,
       model: 'gpt-5.1',

modules/tool/api/upload/delete.ts

@@ -9,7 +9,6 @@ import { UploadToolsS3Path } from '@tool/constants';
 import { addLog } from '@/utils/log';
 
 export default s.route(contract.tool.upload.delete, async ({ query: { toolId } }) => {
-  addLog.debug(`Deleting tool: ${toolId}`);
   const res = await mongoSessionRun(async (session) => {
     const result = await MongoSystemPlugin.findOneAndDelete({ toolId }).session(session);
     if (!result || !result.toolId) {

modules/tool/init.ts

@@ -30,6 +30,9 @@ export async function initTools() {
   }
   global.isIniting = true;
   try {
+    const start = Date.now();
+    addLog.info(`Load tools start`);
+
     await refreshDir(toolsDir);
     // 1. download pkgs into pkg dir
     // 1.1 get tools from mongo
@@ -38,29 +41,23 @@ export async function initTools() {
     }).lean();
 
     addLog.debug(`Tools in mongo: ${toolsInMongo.length}`);
-    // 1.2 download it to temp dir
+    const toolMap: ToolMapType = new Map();
+
+    // 2 download it to temp dir, and parse it
     await batch(
       10,
-      toolsInMongo.map(
-        (tool) => () =>
-          privateS3Server.downloadFile({
-            downloadPath: toolsDir,
-            objectName: `${UploadToolsS3Path}/${tool.toolId}.js`
-          })
-      )
+      toolsInMongo.map((tool) => async () => {
+        const filepath = await privateS3Server.downloadFile({
+          downloadPath: toolsDir,
+          objectName: `${UploadToolsS3Path}/${tool.toolId}.js`
+        });
+        if (!filepath) return;
+        const filename = filepath.replace(`${toolsDir}/`, '');
+        const loadedTools = await LoadToolsByFilename(filename);
+        loadedTools.forEach((tool) => toolMap.set(tool.toolId, tool));
+      })
     );
 
-    // 2. get all tool dirs
-    addLog.debug(`Load tool in local: ${toolsInMongo.length}`);
-    const toolFiles = await readdir(toolsDir);
-    const toolMap: ToolMapType = new Map();
-
-    const promises = toolFiles.map(async (filename) => {
-      const loadedTools = await LoadToolsByFilename(filename);
-      loadedTools.forEach((tool) => toolMap.set(tool.toolId, tool));
-    });
-    await Promise.all(promises);
-
     // 3. read dev tools, if in dev mode
     if (!isProd && process.env.DISABLE_DEV_TOOLS !== 'true') {
       const dir = join(basePath, 'modules', 'tool', 'packages');
@@ -81,11 +78,11 @@ export async function initTools() {
       }
     }
 
-    addLog.info(`Load Tools: ${toolMap.size}`);
+    addLog.info(`Load tools finish: ${toolMap.size}, time: ${Date.now() - start}ms`);
     global.isIniting = false;
     return toolMap;
   } catch (e) {
-    addLog.error(`Init Tools Error:`, e);
+    addLog.error(`Load tools Error:`, e);
     global.isIniting = false;
     return getCachedData(SystemCacheKeyEnum.systemTool);
   }

modules/tool/loadToolProd.ts

@@ -3,29 +3,18 @@ import type { ToolSetType, ToolType } from './type';
 import { addLog } from '@/utils/log';
 import { join } from 'path';
 import { parseMod } from './parseMod';
-import { createHash } from 'crypto';
-import { readFile } from 'fs/promises';
+import { stat } from 'fs/promises';
 
 // Load tool or toolset and its children
 export const LoadToolsByFilename = async (filename: string): Promise<ToolType[]> => {
+  const start = Date.now();
+
   const filePath = join(toolsDir, filename);
 
   // Calculate file content hash for cache key
-  // Same content = same hash = reuse cache, reducing memory usage
-  const fileContent = await readFile(filePath);
-  const contentHash = createHash('md5').update(fileContent).digest('hex').slice(0, 8);
-
-  // Clear module cache in Node.js to prevent memory leaks
-  // @ts-ignore - require.cache only exists in Node.js, not in Bun
-  if (typeof require !== 'undefined' && require.cache) {
-    // Try to delete cache entries (works for CJS modules)
-    delete require.cache[filePath];
-    delete require.cache[require.resolve?.(filePath) || filePath];
-  }
-
-  // Use content hash as cache buster (works for ESM in both Node.js and Bun)
+  const fileSize = await stat(filePath).then((res) => res.size);
   // This ensures same content reuses the same cached module
-  const modulePath = `${filePath}?v=${contentHash}`;
+  const modulePath = `${filePath}?v=${fileSize}`;
 
   const rootMod = (await import(modulePath)).default as ToolType | ToolSetType;
 
@@ -34,5 +23,7 @@ export const LoadToolsByFilename = async (filename: string): Promise<ToolType[]>
     return [];
   }
 
+  addLog.debug(`Load tool ${filename} finish, time: ${Date.now() - start}ms`);
+
   return parseMod({ rootMod, filename });
 };

runtime/index.ts

@@ -1,4 +1,4 @@
-import { refreshVersionKey } from '@/cache';
+import { getCachedData, refreshVersionKey } from '@/cache';
 import { SystemCacheKeyEnum } from '@/cache/type';
 import { isProd } from '@/constants';
 import { initOpenAPI } from '@/contract/openapi';
@@ -50,8 +50,9 @@ async function main(reboot: boolean = false) {
   await refreshDir(tempDir); // upload pkg files, unpkg, temp dir
   await ensureDir(tempToolsDir); // ensure the unpkged tools temp dir
 
+  await refreshVersionKey(SystemCacheKeyEnum.systemTool); // init system tool
   await Promise.all([
-    refreshVersionKey(SystemCacheKeyEnum.systemTool), // init system tool
+    getCachedData(SystemCacheKeyEnum.systemTool), // init system tool
     initModels(reboot),
     initWorkflowTemplates()
   ]);