Add files via upload

dynamic_server.mjs

@@ -1,19 +1,259 @@
-import * as fs from 'node:fs';
-import * as path from 'node:path';
-import * as url from 'node:url';
+import * as fs from "node:fs";
+import * as path from "node:path";
+import * as url from "node:url";
 
-import { default as express } from 'express';
-import { default as sqlite3 } from 'sqlite3';
+import { default as express } from "express";
+import { default as sqlite3 } from "sqlite3";
+import { Console } from "node:console";
 
 const __dirname = path.dirname(url.fileURLToPath(import.meta.url));
 
 const port = 8000;
-const root = path.join(__dirname, 'public');
-const template = path.join(__dirname, 'templates');
+const root = path.join(__dirname, "public");
+const template = path.join(__dirname, "templates");
 
 let app = express();
 app.use(express.static(root));
 
+const db = new sqlite3.Database(
+  path.join(__dirname, "equality.sqlite3"),
+  sqlite3.OPEN_READONLY,
+  (err) => {
+    if (err) {
+      console.log(err);
+    } else {
+      console.log("Successfully connected to database");
+    }
+  }
+);
+
+const dbVis = new sqlite3.Database(
+  path.join(__dirname, "regions.sqlite3"),
+  sqlite3.OPEN_READONLY,
+  (err) => {
+    if (err) {
+      console.log(err);
+    } else {
+      console.log("Successfully connected to database");
+    }
+  }
+);
+
+function dbSelect(query, params) {
+  let p = new Promise((resolve, reject) => {
+    db.all(query, params, (err, rows) => {
+      if (err) {
+        reject(err);
+      } else {
+        //console.log(rows);
+        resolve(rows);
+      }
+    });
+  });
+  return p;
+}
+
+function dbVisSelect(query, params) {
+  let p = new Promise((resolve, reject) => {
+    dbVis.all(query, params, (err, rows) => {
+      if (err) {
+        reject(err);
+      } else {
+        console.log(rows);
+        resolve(rows);
+      }
+    });
+  });
+  return p;
+}
+
+app.get("/all", (req, res) => {
+  let p1 = dbSelect("SELECT * FROM Equality");
+  let p2 = fs.promises.readFile(path.join(template, "search.html"), "utf-8");
+  Promise.all([p1, p2])
+    .then((results) => {
+      let equality_list = results[0];
+      let response = results[1];
+      let table_body = "";
+      let data_string = "";
+      equality_list.forEach((equality) => {
+        let table_row = "<tr>";
+        table_row += `<td class="center-text">${equality.country}</td>`;
+        table_row += `<td class="center-text">${equality.wei}</td>`;
+        table_row += `<td class="center-text">${equality.weg}</td>`;
+        table_row += `<td class="center-text">${equality.ggpi}</td>`;
+        table_row += `<td class="center-text">${equality.ggpg}</td>`;
+        table_row += `<td class="center-text">${equality.hdg}</td>`;
+        table_row += `<td class="center-text">${equality.region}</td>`;
+        table_row += `<td class="center-text">${equality.population}</td>`;
+        table_row += "</tr>";
+        table_body += table_row;
+        let data_row = "{";
+        data_row += `x:${equality.wei},`;
+        data_row += `y:${equality.ggpi},`;
+        data_row += `r:${Math.pow(equality.population, 1 / 6)}`;
+        data_row += "},";
+        data_string += data_row;
+      });
+      response = response.replace("$TABLE_DATA$", table_body);
+      response = response.replace("$PLOT_DATA$", data_string);
+      res.status(200).type("html").send(response);
+    })
+    .catch((error) => {
+      res.status(404).type("txt").send(error);
+    });
+});
+
+app.get("/weg/:group", (req, res) => {
+  let empowerment = req.params.group;
+  let p1 = dbSelect("SELECT * FROM Equality WHERE weg = ?", [empowerment]);
+  let p2 = fs.promises.readFile(
+    path.join(template, "empowerment.html"),
+    "utf-8"
+  );
+  Promise.all([p1, p2])
+    .then((results) => {
+      let equality_list = results[0];
+      if (equality_list.length === 0) {
+        res
+          .status(404)
+          .type("txt")
+          .send(
+            `${empowerment} is not a Women's Empowerment Group in the database!`
+          );
+      }
+      let response = results[1];
+      let table_body = "";
+      let data_string = "";
+      equality_list.forEach((equality) => {
+        let table_row = "<tr>";
+        table_row += `<td class="center-text">${equality.country}</td>`;
+        table_row += `<td class="center-text">${equality.wei}</td>`;
+        table_row += `<td class="center-text">${equality.weg}</td>`;
+        table_row += `<td class="center-text">${equality.ggpi}</td>`;
+        table_row += `<td class="center-text">${equality.ggpg}</td>`;
+        table_row += `<td class="center-text">${equality.hdg}</td>`;
+        table_row += `<td class="center-text">${equality.region}</td>`;
+        table_row += `<td class="center-text">${equality.population}</td>`;
+        table_row += "</tr>";
+        table_body += table_row;
+        let data_row = "{";
+        data_row += `x:${equality.wei},`;
+        data_row += `y:${equality.ggpi},`;
+        data_row += `r:${Math.pow(equality.population, 1 / 6)}`;
+        data_row += "},";
+        data_string += data_row;
+      });
+      response = response.replace("$TABLE_DATA$", table_body);
+      response = response.replace("$PLOT_DATA$", data_string);
+      response = response.replace("$EMPOWERMENT$", empowerment);
+      res.status(200).type("html").send(response);
+    })
+    .catch((error) => {
+      res.status(404).type("txt").send(error);
+    });
+});
+
+app.get("/ggpg/:group", (req, res) => {
+  let parity = req.params.group;
+  let p1 = dbSelect("SELECT * FROM Equality WHERE ggpg = ?", [parity]);
+  let p2 = fs.promises.readFile(path.join(template, "parity.html"), "utf-8");
+  Promise.all([p1, p2])
+    .then((results) => {
+      let equality_list = results[0];
+      if (equality_list.length === 0) {
+        res
+          .status(404)
+          .type("txt")
+          .send(
+            `${parity} is not a Global Gender Parity Group in the database!`
+          );
+      }
+      let response = results[1];
+      let table_body = "";
+      let data_string = "";
+      equality_list.forEach((equality) => {
+        let table_row = "<tr>";
+        table_row += `<td class="center-text">${equality.country}</td>`;
+        table_row += `<td class="center-text">${equality.wei}</td>`;
+        table_row += `<td class="center-text">${equality.weg}</td>`;
+        table_row += `<td class="center-text">${equality.ggpi}</td>`;
+        table_row += `<td class="center-text">${equality.ggpg}</td>`;
+        table_row += `<td class="center-text">${equality.hdg}</td>`;
+        table_row += `<td class="center-text">${equality.region}</td>`;
+        table_row += `<td class="center-text">${equality.population}</td>`;
+        table_row += "</tr>";
+        table_body += table_row;
+        let data_row = "{";
+        data_row += `x:${equality.wei},`;
+        data_row += `y:${equality.ggpi},`;
+        data_row += `r:${Math.pow(equality.population, 1 / 6)}`;
+        data_row += "},";
+        data_string += data_row;
+      });
+      response = response.replace("$TABLE_DATA$", table_body);
+      response = response.replace("$PLOT_DATA$", data_string);
+      response = response.replace("$PARITY$", parity);
+      res.status(200).type("html").send(response);
+    })
+    .catch((error) => {
+      res.status(404).type("txt").send(error);
+    });
+});
+
+app.get("/region/:region", (req, res) => {
+  let region = req.params.region;
+  let p1 = dbSelect("SELECT * FROM Equality WHERE region = ?", [region]);
+  let p2 = fs.promises.readFile(path.join(template, "region.html"), "utf-8");
+  let p3 = dbVisSelect("SELECT * FROM Region WHERE name = ?", [region]);
+  Promise.all([p1, p2, p3])
+    .then((results) => {
+      let equality_list = results[0];
+      if (equality_list.length === 0) {
+        res
+          .status(404)
+          .type("txt")
+          .send(`${region} is not a region in the database!`);
+      }
+      let response = results[1];
+      let regionPaths = results[2];
+      let path = "";
+      let regionName = region;
+      let table_body = "";
+      let data_string = "";
+      regionPaths.forEach((region) => {
+        path += region.path;
+      });
+      equality_list.forEach((equality) => {
+        let table_row = "<tr>";
+        table_row += `<td class="center-text">${equality.country}</td>`;
+        table_row += `<td class="center-text">${equality.wei}</td>`;
+        table_row += `<td class="center-text">${equality.weg}</td>`;
+        table_row += `<td class="center-text">${equality.ggpi}</td>`;
+        table_row += `<td class="center-text">${equality.ggpg}</td>`;
+        table_row += `<td class="center-text">${equality.hdg}</td>`;
+        table_row += `<td class="center-text">${equality.region}</td>`;
+        table_row += `<td class="center-text">${equality.population}</td>`;
+        table_row += "</tr>";
+        table_body += table_row;
+        let data_row = "{";
+        data_row += `x:${equality.wei},`;
+        data_row += `y:${equality.ggpi},`;
+        data_row += `r:${Math.pow(equality.population, 1 / 6)}`;
+        data_row += "},";
+        data_string += data_row;
+      });
+      response = response.replace("$TABLE_DATA$", table_body);
+      response = response.replace("$PLOT_DATA$", data_string);
+      response = response.replace("$PATH$", path);
+      response = response.replace("$SRC$", regionName);
+      res.status(200).type("html").send(response);
+    })
+    .catch((error) => {
+      res.status(404).type("txt").send(error);
+    });
+});
+
 app.listen(port, () => {
-    console.log('Now listening on port ' + port);
+  console.log("Now listening on port " + port);
 });

package.json

@@ -3,14 +3,32 @@
     "description": "Dynamic Server",
     "version": "1.0.0",
     "author": {
-        "name": "",
-        "email": ""
+        "name": "Josh Kahlbaugh",
+        "email": "kahl7683@stthomas.edu"
     },
     "contributors": [
+        {
+          "name": "Josh Kahlbaugh",
+          "email": "kahl7683@stthomas.edu"
+        },
+        {
+          "name": "Omar Alshaali",
+          "email": "alsh4255@stthomas.edu"
+        },
+        {
+          "name": "Jasper Olson",
+          "email": "olso3797@sthomas.edu"
+        }
     ],
-    "repository": {},
+    "repository": {
+      "type": "git",
+      "url": "https://github.com/JoshK710/dynamic-webserver"
+    },
     "dependencies": {
+        "bootstrap": "^5.3.2",
+        "chart.js": "^4.4.0",
+        "cubejs": "^1.3.2",
         "express": "^4.18.2",
         "sqlite3": "^5.1.6"
     }
-}
+}