build(dep): replace sqlite3 with better-sqlite3 (#116)

Author: adambcomer

package.json

@@ -17,6 +17,7 @@
     "@heroui/tooltip": "2.2.24",
     "@tailwindcss/vite": "4.1.15",
     "@vitejs/plugin-react": "5.0.4",
+    "better-sqlite3": "12.4.1",
     "buffer": "6.0.3",
     "compression": "1.8.1",
     "express": "5.1.0",
@@ -26,7 +27,6 @@
     "protobufjs": "7.5.3",
     "react": "19.2.0",
     "react-dom": "19.2.0",
-    "sqlite3": "5.1.7",
     "tailwindcss": "4.1.15",
     "vike": "0.4.244",
     "vike-react": "0.6.10",
@@ -36,6 +36,7 @@
   "devDependencies": {
     "@eslint/compat": "1.4.0",
     "@eslint/js": "9.38.0",
+    "@types/better-sqlite3": "^7.6.13",
     "@types/compression": "1.8.1",
     "@types/express": "5.0.3",
     "@types/fontfaceobserver": "2.1.3",

pages/@workspace/builder/+data.ts

@@ -19,8 +19,8 @@ import { render } from 'vike/abort'
 import { db } from '../../../repo/database'
 import { getWorkspace } from '../../../repo/workspace'
 
-export const data = async (pageContext: PageContextServer) => {
-  const workspace = await getWorkspace(db, pageContext.routeParams.workspace)
+export const data = (pageContext: PageContextServer) => {
+  const workspace = getWorkspace(db, pageContext.routeParams.workspace)
   if (!workspace) {
     throw render(
       404,

pnpm-lock.yaml

@@ -15,21 +15,12 @@
  */
 
 import fs from 'node:fs'
-import sqlite3 from 'sqlite3'
+import Database from 'better-sqlite3'
 
-export const db = new sqlite3.Database(process.env.DATABASE_PATH ?? '')
+export const db = new Database(process.env.DATABASE_PATH ?? '')
 
 export const initDB = () => {
-  return new Promise<void>((resolve, reject) => {
-    const initDBData = fs.readFileSync('./repo/db.sql', 'utf8')
+  const initDBData = fs.readFileSync('./repo/db.sql', 'utf8')
 
-    db.exec(initDBData, function (this, err) {
-      if (err) {
-        reject(err)
-        return
-      }
-
-      resolve()
-    })
-  })
+  db.exec(initDBData)
 }

repo/database.ts

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-import sqlite3 from 'sqlite3'
+import { Database } from 'better-sqlite3'
 import { Sentence, RuleSet } from './proto/bundle.js'
 import { DEFAULT_SENTENCE } from './data/sentence.js'
 import { DEFAULT_RULESET } from './data/ruleset.js'
@@ -35,86 +35,49 @@ interface WorkspaceRow {
   updated_at: string
 }
 
-interface Workspace {
-  id: string
-  ruleset: RuleSet
-  sentence: Sentence
-  createdAt: Date
-  updatedAt: Date
-}
-
-export const createWorkspace = async (db: sqlite3.Database, id: string) => {
+export const createWorkspace = (db: Database, id: string) => {
   const timestamp = new Date()
 
   const sentence = Sentence.encode(DEFAULT_SENTENCE).finish()
   const ruleSet = RuleSet.encode(DEFAULT_RULESET).finish()
 
-  return new Promise<sqlite3.RunResult>((resolve, reject) =>
-    db.run(
-      'INSERT INTO workspaces (id, sentence, ruleset, created_at, updated_at) VALUES (?, ?, ?, ?, ?);',
-      [id, sentence, ruleSet, timestamp.toISOString(), timestamp.toISOString()],
-      function (this, err) {
-        if (err) {
-          reject(err)
-          return
-        }
-
-        resolve(this)
-      }
-    )
-  )
+  db.prepare(
+    'INSERT INTO workspaces (id, sentence, ruleset, created_at, updated_at) VALUES (?, ?, ?, ?, ?);'
+  ).run(id, sentence, ruleSet, timestamp.toISOString(), timestamp.toISOString())
 }
 
-export const getWorkspace = async (db: sqlite3.Database, id: string) => {
-  return new Promise<Workspace | void>((resolve, reject) => {
-    db.get(
-      'SELECT id, sentence, ruleset, created_at, updated_at FROM workspaces WHERE id = ?;',
-      id,
-      function (this, err, row: WorkspaceRow) {
-        if (err) {
-          reject(err)
-          return
-        }
-        if (!row) {
-          resolve()
-          return
-        }
+export const getWorkspace = (db: Database, id: string) => {
+  const row = db
+    .prepare<
+      string,
+      WorkspaceRow
+    >('SELECT id, sentence, ruleset, created_at, updated_at FROM workspaces WHERE id = ?;')
+    .get(id)
+  if (!row) {
+    return undefined
+  }
 
-        resolve({
-          id: row.id,
-          ruleset: RuleSet.decode(row.ruleset),
-          sentence: Sentence.decode(row.sentence),
-          createdAt: new Date(row.created_at),
-          updatedAt: new Date(row.updated_at)
-        })
-      }
-    )
-  })
+  return {
+    id: row.id,
+    ruleset: RuleSet.decode(row.ruleset),
+    sentence: Sentence.decode(row.sentence),
+    createdAt: new Date(row.created_at),
+    updatedAt: new Date(row.updated_at)
+  }
 }
 
-export const updateWorkspace = async (
-  db: sqlite3.Database,
+export const updateWorkspace = (
+  db: Database,
   id: string,
   ruleset: RuleSet,
   sentence: Sentence
 ) => {
-  return new Promise((resolve, reject) => {
-    db.run(
-      'UPDATE workspaces SET sentence = ?, ruleset = ?, updated_at = ? WHERE id = ?;',
-      [
-        Sentence.encode(sentence).finish(),
-        RuleSet.encode(ruleset).finish(),
-        new Date().toISOString(),
-        id
-      ],
-      function (this, err) {
-        if (err) {
-          reject(err)
-          return
-        }
-
-        resolve(this)
-      }
-    )
-  })
+  db.prepare(
+    'UPDATE workspaces SET sentence = ?, ruleset = ?, updated_at = ? WHERE id = ?;'
+  ).run(
+    Sentence.encode(sentence).finish(),
+    RuleSet.encode(ruleset).finish(),
+    new Date().toISOString(),
+    id
+  )
 }

repo/workspace.ts

@@ -27,16 +27,16 @@ import { randomUUID } from 'node:crypto'
 
 export const router = Router()
 
-router.post('/', async (_, res) => {
+router.post('/', (_, res) => {
   const id = randomUUID()
 
-  await createWorkspace(db, id)
+  createWorkspace(db, id)
 
   res.send({ id })
 })
 
-router.get('/:id', async (req, res) => {
-  const workspace = await getWorkspace(db, req.params.id)
+router.get('/:id', (req, res) => {
+  const workspace = getWorkspace(db, req.params.id)
   if (!workspace) {
     res.sendStatus(404)
     return
@@ -51,7 +51,7 @@ type WorkspacePutReqest = Request<
   { ruleset: unknown; sentence: unknown }
 >
 
-router.put('/:id', async (req: WorkspacePutReqest, res) => {
+router.put('/:id', (req: WorkspacePutReqest, res) => {
   const ruleset: unknown = req.body.ruleset
   if (!isRuleSet(ruleset)) {
     res.sendStatus(422)
@@ -64,7 +64,7 @@ router.put('/:id', async (req: WorkspacePutReqest, res) => {
     return
   }
 
-  await updateWorkspace(db, req.params.id, ruleset, sentence)
+  updateWorkspace(db, req.params.id, ruleset, sentence)
 
   res.sendStatus(200)
 })

server/handlers/workspace.ts

@@ -21,7 +21,7 @@ import { serve } from 'vike-server/express/serve'
 import { router as api } from './handlers/api.js'
 import { initDB } from '../repo/database.js'
 
-initDB().catch(console.error)
+initDB()
 
 const app = express()