From 7a727510109c1062ac9009df88db992791ee1ce8 Mon Sep 17 00:00:00 2001 From: Akshay Date: Sat, 9 Nov 2024 09:50:13 +0000 Subject: refactor: Replace db.run with db.query and update database name --- src/index.js | 10 +++++++--- src/routes/index.js | 8 ++++---- 2 files changed, 11 insertions(+), 7 deletions(-) (limited to 'src') 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 { -- cgit v1.2.3