Update server.js

server.js

@@ -1,23 +1,27 @@
 const express = require('express');
 const proxy = require('express-http-proxy');
-const app = express();
 const FormData = require('form-data');
-const fetch = require('node-fetch').default; 
+const https = require('https'); // Use the built-in 'https' module
 const fs = require('fs');
 
+const app = express();
 const targetUrl = 'https://api.openai.com';
 const openaiKey = process.env.OPENAI_KEY;
 const proxyKey = process.env.PROXY_KEY; // Your secret proxy key
 const port = 7860;
 const baseUrl = getExternalUrl(process.env.SPACE_ID);
 
+app.use(express.json({ limit: '50mb' })); // Adjust the limit as needed
+
 // Middleware to authenticate requests with the proxy key
 function authenticateProxyKey(req, res, next) {
-  const providedKey = req.headers['auro'];
+  const providedKey = req.headers['auro']; // Assuming the key is sent in the 'x-proxy-key' header
 
   if (providedKey && providedKey === proxyKey) {
+    // If the provided key matches the expected key, allow the request to proceed
     next();
   } else {
+    // If the key is missing or incorrect, reject the request with an error response
     res.status(401).json({ error: 'Unauthorized' });
   }
 }
@@ -55,40 +59,49 @@ app.post('/api/proxy', async (req, res) => {
   form.append('model', 'whisper-1');
   form.append('response_format', 'text');
 
+  // Configure the request options
+  const requestOptions = {
+    method: 'POST',
+    headers,
+    path: '/audio/transcriptions',
+    host: targetUrl.replace('https://', ''), // Extract the host without 'https://'
+    port: 443, // HTTPS port
+  };
+
   try {
-    const response = await fetch(url, {
-      method: 'POST',
-      headers: {
-        ...headers,
-        ...form.getHeaders(),
-      },
-      body: form,
+    const request = https.request(requestOptions, (response) => {
+      let data = '';
+
+      response.on('data', (chunk) => {
+        data += chunk;
+      });
+
+      response.on('end', () => {
+        if (response.statusCode === 200) {
+          res.status(200).json({ transcription: data });
+        } else {
+          res.status(response.statusCode).json({ error: data });
+        }
+      });
+    });
+
+    // Pipe the form data into the request
+    form.pipe(request);
+
+    // Handle errors
+    request.on('error', (error) => {
+      console.error(error);
+      res.status(500).json({ error: 'Internal Server Error' });
     });
 
-    if (response.ok) {
-      const text = await response.text();
-      res.status(200).json({ transcription: text });
-    } else {
-      const errorText = await response.text();
-      res.status(response.status).json({ error: errorText });
-    }
+    // End the request
+    request.end();
   } catch (error) {
+    console.error(error);
     res.status(500).json({ error: 'Internal Server Error' });
   }
 });
 
-app.use('/api', authenticateProxyKey, proxy(targetUrl, {
-  proxyReqOptDecorator: (proxyReqOpts, srcReq) => {
-    // Modify the request headers if necessary
-    proxyReqOpts.headers['Authorization'] = 'Bearer ' + openaiKey;
-    return proxyReqOpts;
-  },
-}));
-
-app.get("/", (req, res) => {
-  res.send(`This is your OpenAI Reverse Proxy URL: ${baseUrl}`);
-});
-
 function getExternalUrl(spaceId) {
   try {
     const [username, spacename] = spaceId.split("/");
@@ -98,6 +111,10 @@ function getExternalUrl(spaceId) {
   }
 }
 
+app.get("/", (req, res) => {
+  res.send(`This is your OpenAI Reverse Proxy URL: ${baseUrl}`);
+});
+
 app.listen(port, () => {
   console.log(`Reverse proxy server running on ${baseUrl}`);
 });