Merge pull request #4 from JawherKl/feature/4-update-project-structure

update all the structure of project with adding different layers module

Author: JawherKl

package.json

@@ -4,7 +4,7 @@
   "main": "index.js",
   "scripts": {
     "test": "echo \"Error: no test specified\" && exit 1",
-    "start": "node server.mjs"
+    "start": "node src/server.mjs"
   },
   "keywords": [],
   "author": "",

analyze.mjs simple_code/analyze.mjs

@@ -0,0 +1,14 @@
+import express from "express";
+import analyzeRoutes from "./routes/analyzeRoutes.mjs";
+import searchRoutes from "./routes/searchRoutes.mjs";
+import { errorHandler } from "./middlewares/errorHandler.mjs";
+
+const app = express();
+app.use(express.json());
+
+app.use("/search", searchRoutes);
+app.use("/analyze", analyzeRoutes);
+
+app.use(errorHandler);
+
+export default app;

connect.mjs simple_code/connect.mjs

@@ -0,0 +1,11 @@
+import OpenAI from "openai";
+import { config } from "dotenv";
+
+config();
+
+const openai = new OpenAI({
+  baseURL: process.env.BASE_URL,
+  apiKey: process.env.API_KEY,
+});
+
+export default openai;

search.mjs simple_code/search.mjs

@@ -0,0 +1,11 @@
+import { analyzeData } from "../services/analyzeService.mjs";
+
+export async function analyzeText(req, res) {
+  try {
+    const { text } = req.body;
+    const analysis = await analyzeData(text);
+    res.json({ analysis });
+  } catch (error) {
+    res.status(500).json({ error: error.message });
+  }
+}

server.mjs simple_code/server.mjs

@@ -0,0 +1,11 @@
+import { semanticSearch } from "../services/searchService.mjs";
+
+export async function searchQuery(req, res) {
+  try {
+    const { query, model } = req.body;
+    const result = await semanticSearch(query, model);
+    res.json({ result });
+  } catch (error) {
+    res.status(500).json({ error: error.message });
+  }
+}

src/app.mjs

@@ -0,0 +1,5 @@
+export function errorHandler(err, req, res, next) {
+    console.error(err.stack);
+    res.status(500).json({ error: "Internal Server Error" });
+  }
+  

src/config/openAIConfig.mjs

@@ -0,0 +1,8 @@
+import express from "express";
+import { analyzeText } from "../controllers/analyzeController.mjs";
+
+const router = express.Router();
+
+router.post("/", analyzeText);
+
+export default router;

src/controllers/analyzeController.mjs

@@ -0,0 +1,8 @@
+import express from "express";
+import { searchQuery } from "../controllers/searchController.mjs";
+
+const router = express.Router();
+
+router.post("/", searchQuery);
+
+export default router;

src/controllers/searchController.mjs

@@ -0,0 +1,7 @@
+import app from "./app.mjs";
+
+const PORT = process.env.PORT || 3000;
+
+app.listen(PORT, () => {
+  console.log(`Server running on http://localhost:${PORT}`);
+});

src/middlewares/errorHandler.mjs

@@ -0,0 +1,22 @@
+import openai from "../config/openAIConfig.mjs";
+
+export async function analyzeData(text) {
+  try {
+    const completion = await openai.chat.completions.create({
+      model: "gpt-4-turbo",
+      messages: [
+        {
+          role: "system",
+          content: "Analyze this text for sentiment, key topics, and named entities."
+        },
+        { role: "user", content: text }
+      ],
+      temperature: 0.1,
+      max_tokens: 256
+    });
+    return completion.choices[0].message.content;
+  } catch (error) {
+    console.error("Analysis error:", error.message);
+    throw error;
+  }
+}

src/routes/analyzeRoutes.mjs

@@ -0,0 +1,22 @@
+import openai from "../config/openAIConfig.mjs";
+
+export async function semanticSearch(query, model) {
+  try {
+    const completion = await openai.chat.completions.create({
+      model: model || "gpt-4-turbo",
+      messages: [
+        {
+          role: "system",
+          content: "You are a powerful search engine. Return concise, factual answers."
+        },
+        { role: "user", content: query }
+      ],
+      temperature: 0.3,
+      max_tokens: 150
+    });
+    return completion.choices[0].message.content;
+  } catch (error) {
+    console.error("Search error:", error.message);
+    throw error;
+  }
+}