SERP Search

Author: redji

API/app.js

@@ -9,10 +9,12 @@ const { fetchJSONData } = require('./io/index.js');
 const { chatCompletion } = require('./openAPI/index.js');
 const JSONStream = require('JSONStream');
 const fs = require('fs');
+const { getJson } = require("serpapi");
 
 const chatFilePath = 'chat.json';
 
 const APIKey = process.env['API_KEY'];
+const SERPAPIKEy = process.env['SERP_API'];
 
 app.use(bodyParser.json());
 app.post('/answer/', async (req, res) => {
@@ -137,6 +139,18 @@ app.post('/answer/', async (req, res) => {
 app.get('/', (req, res) => {
   res.send('Hello, Aiva!');
 });
+app.post('/search', (req, res) => {
+	const jsonData = req.body;
+		getJson({
+		engine: "google",
+		api_key: SERPAPIKEy, // Get your API_KEY from https://serpapi.com/manage-api-key
+		q: jsonData.question,
+		location: "Austin, Texas",
+		}, (json) => {
+			console.log(json["organic_results"]);
+			res.json({ reply: json["organic_results"][0].link });
+		});
+  });
 app.get('/clearJSON', (req, res) => {
 	fs.writeFileSync(chatFilePath, '');
 	res.send('JSon Cleared!');

API/package-lock.json

@@ -17,9 +17,12 @@
     "eslint-plugin-vue": "^9.24.1"
   },
   "dependencies": {
+    "axios": "^1.6.8",
     "body-parser": "^1.20.2",
     "dotenv": "^16.4.5",
     "express": "^4.19.2",
-    "openai": "^4.33.0"
+    "JSONStream": "^1.3.5",
+    "openai": "^4.33.0",
+    "serpapi": "^2.1.0"
   }
 }

API/package.json

@@ -1012,4 +1012,47 @@ fetch('https://tasks.aidevs.pl/token/optimaldb', {
         } catch (error) {
             console.error('An error occurred:', error);
         }})
-        .catch(error => console.error('Error:', error));
+        .catch(error => console.error('Error:', error));
+
+fetch('https://tasks.aidevs.pl/token/google', {    
+    method: 'POST',
+    headers: {
+        'Content-Type': 'application/json'
+    },
+    body: JSON.stringify({ apikey: APIKey })
+})
+    .then(async (response) => {
+        const data = await response.json();
+        const token = data.token;
+        const taskUrl = `https://tasks.aidevs.pl/task/${token}`;
+        const response2 = await makeRequestWithDelay(taskUrl, {
+            method: 'GET',
+            headers: {
+                'Content-Type': 'application/json'
+            }
+        }, 10);
+        console.log(response2)
+        const response4 = await makeRequestWithDelay(`https://tasks.aidevs.pl/answer/${token}`, {
+                method: 'POST',
+                headers: {
+                    'Content-Type': 'application/json'
+                },
+                body: JSON.stringify({answer: 'https://frog01-21730.wykr.es/search'})
+            }, 10);
+            console.log('Answer from API', response4);
+        })
+        .catch(error => console.error('Error:', error));
+
+    // Example URL search
+    // fetch('https://frog01-21730.wykr.es/search', {  
+    //     method: 'POST',
+    //     headers: {
+    //         'Content-Type': 'application/json'
+    //     },
+    //     body: JSON.stringify({ question: "What is the weather today?" })
+    // })
+    //     .then(async (response) => {
+    //         const data = await response.json();
+    //         console.log(data.reply);
+    // })
+    // .catch(error => console.error('Error:', error));