New tool (#268)

* Install packages

* fix: tag union field

* qwen vl model

* qwen model

* update bun version

* update bun version

* update zod version

* npm

* zod v4

* zod version

Author: c121914yu

bun.lock

@@ -13,7 +13,7 @@ export type MongoPluginSchemaType = z.infer<typeof PluginZodSchema>;
 
 const pluginMongooseSchema = new Schema({
   toolId: { type: String },
-  type: { type: String, required: true, enum: Object.values(pluginTypeEnum.Enum) }
+  type: { type: String, required: true, enum: Object.values(pluginTypeEnum.enum) }
 });
 
 pluginMongooseSchema.index({ toolId: 1 }, { unique: true, sparse: true });

lib/mongo/models/plugins.ts

@@ -14,9 +14,9 @@
     "@opentelemetry/sdk-logs": "^0.203.0",
     "@opentelemetry/sdk-metrics": "^2.0.1",
     "@scalar/express-api-reference": "^0.8.7",
-    "@ts-rest/core": "^3.52.1",
+    "@ts-rest/core": "3.52.1",
     "@ts-rest/express": "^3.52.1",
-    "@ts-rest/open-api": "^3.52.1",
+    "@ts-rest/open-api": "3.52.1",
     "@vercel/otel": "^1.9.2",
     "fs-extra": "^11.3.2",
     "jszip": "^3.10.1",

lib/package.json

@@ -1,4 +1,4 @@
-import z from 'zod';
+import { z } from 'zod';
 import { FASTGPT_REDIS_PREFIX, getGlobalRedisConnection } from '.';
 export const lockEnum = z.enum(['parsePkg']);
 const lockPrefix = `${FASTGPT_REDIS_PREFIX}LOCK:`;

lib/redis/lock.ts

@@ -4,7 +4,7 @@ export const PresignedUrlInputSchema = z.object({
   filepath: z.string(),
   filename: z.string(),
   contentType: z.string().optional(),
-  metadata: z.record(z.string()).optional(),
+  metadata: z.record(z.string(), z.string()).optional(),
   maxSize: z.number().optional().describe('B'),
   fileExpireMins: z.number().optional()
 });

lib/s3/type.ts

@@ -1,4 +1,4 @@
-import z from 'zod';
+import { z } from 'zod';
 import { FileMetadataSchema, type FileMetadata } from '@/s3/config';
 import { FileInputSchema } from '@/s3/type';
 import { StreamDataSchema, ToolCallbackReturnSchema } from '@tool/type/req';

lib/worker/type.ts

@@ -4,6 +4,7 @@ import { setupProxy } from '../utils/setupProxy';
 import { LoadToolsByFilename } from '@tool/utils';
 import { getErrText } from '@tool/utils/err';
 import { LoadToolsDev } from '@tool/loadToolDev';
+import type { ToolCallbackReturnSchemaType } from '@tool/type/req';
 
 setupProxy();
 
@@ -45,7 +46,7 @@ parentPort?.on('message', async (params: Main2WorkerMessageType) => {
         };
 
         // sendMessage is optinal
-        const result = await tool.cb(data.inputs, {
+        const result: ToolCallbackReturnSchemaType = await tool.cb(data.inputs, {
           systemVar: data.systemVar,
           streamResponse: sendMessage
         });

lib/worker/worker.ts

@@ -1,4 +1,4 @@
-import z from 'zod';
+import { z } from 'zod';
 import { c } from '@/contract/init';
 import { type ListModelsType } from './api/type';
 import { type I18nStringStrictType } from '@/type/i18n';

modules/model/contract.ts

@@ -88,6 +88,30 @@ const models: ProviderConfigType = {
         stream: true
       }
     },
+    {
+      type: ModelTypeEnum.llm,
+      model: 'qwen3-vl-flash',
+      maxContext: 25000,
+      maxTokens: 8000,
+      quoteMaxToken: 20000,
+      maxTemperature: 1,
+      responseFormatList: ['text'],
+      vision: true,
+      reasoning: false,
+      toolChoice: true
+    },
+    {
+      type: ModelTypeEnum.llm,
+      model: 'qwen3-vl-plus',
+      maxContext: 25000,
+      maxTokens: 8000,
+      quoteMaxToken: 20000,
+      maxTemperature: 1,
+      responseFormatList: ['text'],
+      vision: true,
+      reasoning: false,
+      toolChoice: true
+    },
     {
       type: ModelTypeEnum.llm,
       model: 'qwen3-32b',

modules/model/provider/Qwen/index.ts

@@ -50,8 +50,8 @@ export const LLMModelItemSchema = PriceSchema.merge(BaseModelItemSchema).extend(
   useInEvaluation: z.boolean().optional(), // evaluation
 
   defaultSystemChatPrompt: z.string().optional(),
-  defaultConfig: z.record(z.any()).optional(),
-  fieldMap: z.record(z.string()).optional()
+  defaultConfig: z.record(z.string(), z.any()).optional(),
+  fieldMap: z.record(z.string(), z.string()).optional()
 });
 
 // Embedding 模型类型 schema
@@ -62,9 +62,9 @@ export const EmbeddingModelItemSchema = PriceSchema.merge(BaseModelItemSchema).e
   weight: z.number().optional(), // training weight
   hidden: z.boolean().optional(), // Disallow creation
   normalization: z.boolean().optional(), // normalization processing
-  defaultConfig: z.record(z.any()).optional(), // post request config
-  dbConfig: z.record(z.any()).optional(), // Custom parameters for storage
-  queryConfig: z.record(z.any()).optional() // Custom parameters for query
+  defaultConfig: z.record(z.string(), z.any()).optional(), // post request config
+  dbConfig: z.record(z.string(), z.any()).optional(), // Custom parameters for storage
+  queryConfig: z.record(z.string(), z.any()).optional() // Custom parameters for query
 });
 
 // Rerank 模型类型 schema