feat: db schema index update (#725)

* feat: db schema index update

* feat: upgrade dependencies

worker/package.json

@@ -11,20 +11,20 @@
     "build": "wrangler deploy --dry-run --outdir dist --minify"
   },
   "devDependencies": {
-    "@cloudflare/workers-types": "^4.20250904.0",
+    "@cloudflare/workers-types": "^4.20250913.0",
     "@eslint/js": "9.18.0",
     "@simplewebauthn/types": "10.0.0",
-    "@types/node": "^22.18.1",
+    "@types/node": "^22.18.3",
     "eslint": "9.18.0",
     "globals": "^15.15.0",
-    "typescript-eslint": "^8.42.0",
-    "wrangler": "^4.34.0"
+    "typescript-eslint": "^8.43.0",
+    "wrangler": "^4.37.0"
   },
   "dependencies": {
-    "@aws-sdk/client-s3": "^3.879.0",
-    "@aws-sdk/s3-request-presigner": "^3.879.0",
+    "@aws-sdk/client-s3": "^3.888.0",
+    "@aws-sdk/s3-request-presigner": "^3.888.0",
     "@simplewebauthn/server": "10.0.1",
-    "hono": "^4.9.6",
+    "hono": "^4.9.7",
     "jsonpath-plus": "^10.3.0",
     "mimetext": "^3.0.27",
     "postal-mime": "^2.4.4",

worker/src/admin_api/db_api.ts

@@ -14,6 +14,8 @@ CREATE TABLE IF NOT EXISTS raw_mails (
 
 CREATE INDEX IF NOT EXISTS idx_raw_mails_address ON raw_mails(address);
 
+CREATE INDEX IF NOT EXISTS idx_raw_mails_created_at ON raw_mails(created_at);
+
 CREATE TABLE IF NOT EXISTS address (
     id INTEGER PRIMARY KEY AUTOINCREMENT,
     name TEXT UNIQUE,
@@ -23,6 +25,10 @@ CREATE TABLE IF NOT EXISTS address (
 
 CREATE INDEX IF NOT EXISTS idx_address_name ON address(name);
 
+CREATE INDEX IF NOT EXISTS idx_address_created_at ON address(created_at);
+
+CREATE INDEX IF NOT EXISTS idx_address_updated_at ON address(updated_at);
+
 CREATE TABLE IF NOT EXISTS auto_reply_mails (
     id INTEGER PRIMARY KEY,
     source_prefix TEXT,
@@ -54,6 +60,7 @@ CREATE TABLE IF NOT EXISTS sendbox (
 );
 
 CREATE INDEX IF NOT EXISTS idx_sendbox_address ON sendbox(address);
+CREATE INDEX IF NOT EXISTS idx_sendbox_created_at ON sendbox(created_at);
 
 CREATE TABLE IF NOT EXISTS settings (
     key TEXT PRIMARY KEY,
@@ -131,7 +138,13 @@ export default {
         const version = await utils.getSetting(c, CONSTANTS.DB_VERSION_KEY);
         if (version != CONSTANTS.DB_VERSION) {
             // TODO: Perform migration logic here
-
+            // remove all \r and \n characters from the query string
+            // split by ; and join with a ;\n
+            const query = DB_INIT_QUERIES.replace(/[\r\n]/g, "")
+                .split(";")
+                .map((query) => query.trim())
+                .join(";\n");
+            await c.env.DB.exec(query);
             // Update the version in the settings table
             await utils.saveSetting(c, CONSTANTS.DB_VERSION_KEY, CONSTANTS.DB_VERSION);
             return c.json({

worker/src/constants.ts

@@ -3,7 +3,7 @@ export const CONSTANTS = {
 
     // DB Version
     DB_VERSION_KEY: 'db_version',
-    DB_VERSION: "v0.0.1",
+    DB_VERSION: "v0.0.2",
 
     // DB settings
     ADDRESS_BLOCK_LIST_KEY: 'address_block_list',