all back end final

Author: jelonmusk

server/api.js

@@ -1,4 +1,4 @@
-import {Configuration , OpenAIApi} from 'openai';
+import OpenAI from 'openai';
 import dotenv from 'dotenv';
 
 dotenv.config();
@@ -8,15 +8,11 @@ const openaiApiKey = process.env.OPENAI_API_KEY;
 if (!openaiApiKey) {
     console.error('OPENAI_API_KEY is not defined in the environment variables');
     throw new Error('OPENAI_API_KEY is not defined in the environment variables');
-    // This will stop the execution of the script
-    process.exit(1);
-
 }
 
-const configuration = new Configuration({
+const openai = new OpenAI({
     apiKey: openaiApiKey,
 });
-// below is the open ai api instance
-// The OpenAIApi class is used to interact with the OpenAI API
-const openai = new OpenAIApi(configuration);
-// Function to generate SQL query using OpenAI API
+
+export default openai;
+// This code imports the OpenAI library and dotenv for environment variable management.

server/generate.js

@@ -0,0 +1,30 @@
+import openaiClient from './api.js';
+
+const generate = async (queryDescription) => {
+  const turbo = async (queryDescription) => {
+    const messages = [
+      { role: "system", content: "You are a helpful assistant that converts natural language queries into SQL queries." },
+      { role: "user", content: "Convert the following natural language description into a SQL Query:\n\nShow all elements in the table users." },
+      { role: "assistant", content: "SELECT * FROM users;" },
+      { role: "user", content: `Convert the following natural language description into a SQL Query:\n\n${queryDescription}` },
+    ];
+
+    const response = await openaiClient.chat.completions.create({
+      model: "gpt-3.5-turbo-0125",
+      messages: messages,
+      max_tokens: 100,
+      temperature: 0.7,
+    });
+
+    return response.choices[0].message.content.replace(/```sql|```/g, '').trim();
+};
+
+  try {
+    return await turbo(queryDescription);
+  } catch (err) {
+    console.error("OpenAI API error:", err.response?.data || err.message || err);
+    throw err;
+  }
+};
+
+export default generate;

server/index.js

@@ -1,17 +1,42 @@
 import  express from 'express';
 import cors from 'cors';
+import generate from './generate.js';
+
 
 const app = express();
 
+app.use(express.json()); // Middleware to parse JSON request bodies
+// Middleware to enable CORS (Cross-Origin Resource Sharing)
 app.use(cors());
 
 const port = process.env.PORT || 3005;
 
+
 // endpoint to test the server
 app.get("/", (req, res) => {
     res.send("Server is running.Hello World from our API");
 });
 
+//Routes to handle the SQL generation
+app.post("/generate", async (req, res) => {
+    const queryDescription = req.body.queryDescription;
+    console.log("Received Query Description:", queryDescription);
+
+
+    try{
+        const sqlQuery = await generate(queryDescription);
+        res.json({ response: sqlQuery });
+        console.log("Generated SQL Query:", sqlQuery);
+    }
+    catch (error) {
+        console.error("Error generating SQL query:", error.response?.data || error.message || error);
+        res.status(500).json({ error: "An error occurred while generating the SQL query." });
+        return;
+    }
+    // Call the generate function to get the SQL query
+
+})
+
 // app.listen is a method that starts the server and listens for incoming requests on the specified port
 // The port is either taken from the environment variables or defaults to 3005
 // The callback function is executed when the server starts successfully