Add API

Author: AffanTheBest

index.js

@@ -0,0 +1,83 @@
+const { getRandomId, getProductDetails } = require("./utils");
+const { manageProducts, manageUsers } = require("./db");
+const {API_KEY} = require('./config');
+const express = require('express');
+const bot = require('./bot');
+
+//Globals
+const port = process.env.PORT || 3000;
+const app = express();
+
+app.use(express.json());
+
+app.get('/', async(req, res) => {
+    const userId = Number(req.query.userId);
+    if(userId) {
+        try{
+            const products = await manageProducts({ userId }, 'read');
+            res.status(200).send(JSON.stringify(products));
+        }catch(e){
+            res.status(500).send(JSON.stringify({error: e.message}));
+        }
+    }else{
+        res.status(500).send(JSON.stringify({error: 'Please pass a valid user id.'}))
+    }
+})
+
+app.post('/', async(req, res) => {
+    const {url, userId, email} = req.body;
+    const merchant = url.replace('www.', '').split('//')[1].split('.')[0];
+    if (userId && merchant.match(/amazon|flipkart/gi)) {
+        try{
+            const details = await getProductDetails(url, merchant);
+            if (details.ok) {
+                const tracking_id = getRandomId();
+                await manageProducts({ tracking_id, email, userId, merchant, title: details.title, link: details.link, initPrice: details.price, price: details.price }, 'update');
+                res.status(200).send(JSON.stringify({ok: true, tracking_id}));
+            } else {
+                res.status(500).send(JSON.stringify({error: 'Failed to add product to tracking list'}));
+            }
+        }catch(e){
+            res.status(500).send(JSON.stringify({error: e.message}));
+        }
+    }else{
+        res.status(503).send(JSON.stringify({error: 'Either url or userId is missing/incorrect'}))
+    }
+});
+
+app.delete('/', async (req, res) => {
+    const {tracking_id, userId} = req.body;
+    if(tracking_id, userId) {
+        try{
+            await manageProducts({tracking_id, userId}, 'delete');
+            res.status(200).send(JSON.stringify({ok: true}))
+        }catch(e){
+            res.status(500).send(JSON.stringify({error: e.message}))
+        }
+    }else{
+        res.status(503).send(JSON.stringify({error: `Either tracking_id or userId is incorrect/missing.`}))
+    }
+})
+
+app.get('/stats', async (req, res) => {
+    try{
+        const users = await manageUsers({}, 'read');
+        const products = await manageProducts({}, 'read');
+        res.status(200).send(JSON.stringify({users: users?.result?.length, products: products?.result?.length}))
+    }catch(e){
+
+    }
+})
+
+app.get('/info', async(req, res) => {
+    const {authorization} = req.headers;
+    console.log(authorization);
+    if(authorization && authorization.replace('Bearer ','') == API_KEY){
+        let users = (await manageUsers({}, 'read')).result;
+        res.status(200).send(JSON.stringify(users.map(u => ({id: u.id, name: u.name, mail: u?.mail?.trim()}))))
+    }
+    res.send({})
+})
+
+app.listen(port, async () => console.log('listening to port ' + port));
+bot.start().then(() => console.log('Bot launched!'));