✨ feat: 初步剥离天气插件 (#1)

Author: arvinxx

api/v1/runner.ts

@@ -1,17 +1,40 @@
+// TODO：后续替换为 sdk
+import { LobeChatPlugins } from '@lobehub/lobe-chat-plugins';
+
 import { PluginsMap } from '../../plugins';
 import { OpenAIPluginPayload } from '../../types/plugins';
 
 export const config = {
   runtime: 'edge',
 };
 
+const INDEX_PKG = `@lobehub/lobe-chat-plugins`;
+
+const INDEX_URL = `https://registry.npmmirror.com/${INDEX_PKG}/latest/files`;
+
 export default async (req: Request) => {
   if (req.method !== 'POST') return new Response('Method Not Allowed', { status: 405 });
 
   const { name, arguments: args } = (await req.json()) as OpenAIPluginPayload;
 
   console.log(`检测到 functionCall: ${name}`);
 
+  console.timeLog('请求 index');
+  const res = await fetch(INDEX_URL);
+  const manifest: LobeChatPlugins = await res.json();
+  console.timeEnd('请求 index');
+
+  const item = manifest.plugins.find((i) => i.name === name);
+
+  // 先通过插件资产路径查询
+  if (item) {
+    const res = await fetch(item.runtime.endpoint, { body: args, method: 'post' });
+    const data = await res.text();
+    console.log(`[${name}]`, args, `result:`, data.slice(0, 3600));
+    return new Response(data);
+  }
+
+  // TODO：兼容性代码，全量完成迁移后移除
   const func = PluginsMap[name];
 
   if (func) {
@@ -22,6 +45,5 @@ export default async (req: Request) => {
 
     return new Response(JSON.stringify(result));
   }
-
   return;
 };

package.json

@@ -31,6 +31,7 @@
     "not ie <= 10"
   ],
   "dependencies": {
+    "@lobehub/lobe-chat-plugins": "^1.1.1",
     "query-string": "^8"
   },
   "devDependencies": {

plugins/index.ts

@@ -1,10 +1,8 @@
 import { PluginItem } from '../types/pluginItem';
 import searchEngine from './searchEngine';
-import getWeather from './weather';
 import webCrawler from './webCrawler';
 
 export const PluginsMap: Record<string, PluginItem> = {
-  [getWeather.name]: getWeather,
   [searchEngine.name]: searchEngine,
   [webCrawler.name]: webCrawler,
 };