refactor: Replace db.run with db.query and update database name

2 files changed, 11 insertions, 7 deletions

diff --git a/src/index.js b/src/index.js
index ae9d87b..cc7e2e6 100644
--- a/src/index.js
+++ b/src/index.js
@@ -13,9 +13,9 @@ app.use(express.json());
 app.use(express.static(path.join(__dirname, "public")));
 app.use("/", routes);
 
-const db = new Database("users.db");
+const db = new Database("readit.db");
 
-db.run(`
+const createUsers = db.query(`
   CREATE TABLE IF NOT EXISTS users (
     id INTEGER PRIMARY KEY AUTOINCREMENT,
     username TEXT UNIQUE,
@@ -23,7 +23,9 @@ db.run(`
   )
 `);
 
-db.run(`
+createUsers.run();
+
+const createSubs = db.query(`
   CREATE TABLE IF NOT EXISTS subscriptions (
     id INTEGER PRIMARY KEY AUTOINCREMENT,
     user_id INTEGER,
@@ -33,6 +35,8 @@ db.run(`
   )
 `);
 
+createSubs.run();
+
 module.exports = { db };
 
 const port = process.env.READIT_PORT;
diff --git a/src/routes/index.js b/src/routes/index.js
index 93ebf46..6153692 100644
--- a/src/routes/index.js
+++ b/src/routes/index.js
@@ -82,10 +82,10 @@ router.post("/register", async (req, res) => {
                 return res.status(400).send("Passwords do not match");
         }
         try {
-                db.run("INSERT INTO users (username, password) VALUES (?, ?)", [
+                db.query("INSERT INTO users (username, password) VALUES (?, ?)", [
                         username,
                         password,
-                ]);
+                ]).run();
                 res.status(201).send("User registered successfully");
         } catch (err) {
                 console.log(err);
@@ -125,10 +125,10 @@ router.post("/subscribe", async (req, res) => {
                 if (existingSubscription) {
                         res.status(400).send("Already subscribed to this subreddit");
                 } else {
-                        db.run("INSERT INTO subscriptions (user_id, subreddit) VALUES (?, ?)", [
+                        db.query("INSERT INTO subscriptions (user_id, subreddit) VALUES (?, ?)", [
                                 user.id,
                                 subreddit,
-                        ]);
+                        ]).run();
                         res.status(201).send("Subscribed successfully");
                 }
         } else {