Update api/index.js

api/index.js

@@ -23,7 +23,6 @@ class Config {
                 this.GPT_GRPC = 'runtime-native-io-gpt-inference-grpc-service-lmuw6mcn3q-ul.a.run.app';
                 this.GPT_PROTO = path.join(__dirname,'..', 'protos', 'GPTInferenceService.proto')
                 this.PORT = process.env.PORT || 8787;
-                this.USE_SSL = process.env.USE_SSL === 'true';
         }
 }
 class GRPCHandler {
@@ -95,14 +94,10 @@ router.get(config.API_PREFIX + '/v1/models', () =>
 router.post(config.API_PREFIX + '/v1/chat/completions', (req) => handleCompletion(req));
 
 async function GrpcToPieces(models, message, rules, stream, temperature, top_p) {
-        let credentials;
-        if (config.USE_SSL) {
-                credentials = grpc.credentials.createSsl();
-        } else {
-                credentials = grpc.credentials.createInsecure();
-        }
-
-        let client, request;
+        // 在非GPT类型的模型中，temperature和top_p是无效的
+        // 使用系统的根证书
+        const credentials = grpc.credentials.createSsl();
+        let client,request;
         if (models.includes('gpt')){
                 // 加载proto文件
                 const packageDefinition = new GRPCHandler(config.GPT_PROTO).packageDefinition;
@@ -287,18 +282,11 @@ async function handleCompletion(request) {
 }
 
 (async () => {
-        if (typeof addEventListener === 'function') return;
-        
-        const ittyServer = createServerAdapter(router.fetch);
-        const httpServer = createServer(ittyServer);
-
-        // 添加错误处理
-        httpServer.on('error', (error) => {
-                console.error('Server error:', error);
-        });
-
-        // 确保监听所有接口
-        httpServer.listen(config.PORT, '0.0.0.0', () => {
-                console.log(`Server is running on http://0.0.0.0:${config.PORT}`);
-        });
+	//For Cloudflare Workers
+	if (typeof addEventListener === 'function') return;
+	// For Nodejs
+	const ittyServer = createServerAdapter(router.fetch);
+	console.log(`Listening on http://localhost:${config.PORT}`);
+	const httpServer = createServer(ittyServer);
+	httpServer.listen(config.PORT);
 })();