feat: backend upgraded.

Author: emdevelopa

backend/check-db-state.js

@@ -0,0 +1,43 @@
+import pkg from 'pg';
+const { Client } = pkg;
+
+const client = new Client({
+  host: 'db.xomasbwwhhcxrptfdees.supabase.co',
+  user: 'postgres',
+  database: 'postgres',
+  password: 'pluto1234!@#$%^_',
+  port: 6543,
+  ssl: { rejectUnauthorized: false }
+});
+
+async function main() {
+  await client.connect();
+  
+  // List all tables in public schema
+  const tables = await client.query(`
+    SELECT tablename FROM pg_tables WHERE schemaname = 'public' ORDER BY tablename;
+  `);
+  console.log('Tables:', tables.rows.map(r => r.tablename));
+
+  // Check columns in merchants table if it exists
+  const merchantTables = tables.rows.filter(r => r.tablename === 'merchants');
+  if (merchantTables.length > 0) {
+    const cols = await client.query(`
+      SELECT column_name FROM information_schema.columns
+      WHERE table_schema = 'public' AND table_name = 'merchants'
+      ORDER BY ordinal_position;
+    `);
+    console.log('merchants columns:', cols.rows.map(r => r.column_name));
+  }
+
+  // Check migration history
+  const migTables = tables.rows.filter(r => r.tablename === 'knex_migrations');
+  if (migTables.length > 0) {
+    const migs = await client.query('SELECT * FROM knex_migrations ORDER BY id');
+    console.log('Completed migrations:', migs.rows);
+  }
+
+  await client.end();
+}
+
+main().catch(err => console.error(err.message));

backend/check-lock.js

@@ -0,0 +1,41 @@
+import pkg from 'pg';
+const { Client } = pkg;
+import 'dotenv/config';
+
+async function checkLock() {
+  const client = new Client({
+    host: 'db.xomasbwwhhcxrptfdees.supabase.co',
+    user: 'postgres',
+    database: 'postgres',
+    password: 'pluto1234!@#$%^_',
+    port: 6543,
+    ssl: { rejectUnauthorized: false }
+  });
+
+  try {
+    await client.connect();
+    console.log('Connected to DB.');
+    
+    const checkTable = await client.query("SELECT to_regclass('knex_migrations_lock')");
+    if (checkTable.rows[0].to_regclass) {
+      const res = await client.query('SELECT * FROM knex_migrations_lock');
+      console.log('Lock table content:', res.rows);
+      
+      if (res.rows[0] && res.rows[0].is_locked) {
+        console.log('Database is LOCKED. Clearing lock...');
+        await client.query('UPDATE knex_migrations_lock SET is_locked = 0');
+        console.log('Lock cleared.');
+      } else {
+        console.log('Database is not locked.');
+      }
+    } else {
+      console.log('knex_migrations_lock table does not exist yet.');
+    }
+    
+    await client.end();
+  } catch (err) {
+    console.error('Error:', err.message);
+  }
+}
+
+checkLock();

backend/knexfile.js

@@ -4,10 +4,12 @@ import "dotenv/config";
 const config = {
   client: "pg",
   connection: {
-    connectionString: process.env.DATABASE_URL,
-    ssl: process.env.DATABASE_URL?.includes("supabase.co")
-      ? { rejectUnauthorized: false }
-      : false,
+    host: 'db.xomasbwwhhcxrptfdees.supabase.co',
+    user: 'postgres',
+    database: 'postgres',
+    password: 'pluto1234!@#$%^_',
+    port: 6543,
+    ssl: { rejectUnauthorized: false },
   },
   migrations: {
     directory: "./migrations",

backend/migrations/20260326000002_add_merchant_recipient.js

@@ -3,9 +3,12 @@
  */
 
 export async function up(knex) {
-  await knex.schema.alterTable("merchants", (t) => {
-    t.text("recipient");
-  });
+  const hasRecipient = await knex.schema.hasColumn("merchants", "recipient");
+  if (!hasRecipient) {
+    await knex.schema.alterTable("merchants", (t) => {
+      t.text("recipient");
+    });
+  }
   await knex.raw(
     "create index if not exists merchants_recipient_idx on merchants(recipient)"
   );

backend/migrations/20260327000007_add_webhook_version.js

@@ -3,11 +3,12 @@
  * @returns { Promise<void> }
  */
 export async function up(knex) {
-  await knex.schema.alterTable("merchants", (table) => {
-    // Default 'v1' ensures every existing merchant keeps receiving the
-    // payload format they integrated against without any manual data migration.
-    table.text("webhook_version").notNullable().defaultTo("v1");
-  });
+  const has = await knex.schema.hasColumn("merchants", "webhook_version");
+  if (!has) {
+    await knex.schema.alterTable("merchants", (table) => {
+      table.text("webhook_version").notNullable().defaultTo("v1");
+    });
+  }
 }
 
 /**

backend/migrations/20260401000001_add_password_hash.js

@@ -0,0 +1,11 @@
+export async function up(knex) {
+  await knex.schema.alterTable("merchants", (t) => {
+    t.text("password_hash").nullable();
+  });
+}
+
+export async function down(knex) {
+  await knex.schema.alterTable("merchants", (t) => {
+    t.dropColumn("password_hash");
+  });
+}

backend/package-lock.json

@@ -35,6 +35,7 @@
     "framer-motion": "^12.38.0",
     "knex": "^3.2.6",
     "morgan": "^1.10.0",
+    "node-cron": "^4.2.1",
     "pg": "^8.20.0",
     "pino": "^9.5.0",
     "pino-http": "^10.3.0",

backend/package.json

@@ -0,0 +1,44 @@
+import pkg from 'pg';
+const { Client } = pkg;
+
+const client = new Client({
+  host: 'db.xomasbwwhhcxrptfdees.supabase.co',
+  user: 'postgres',
+  database: 'postgres',
+  password: 'pluto1234!@#$%^_',
+  port: 6543,
+  ssl: { rejectUnauthorized: false }
+});
+
+async function main() {
+  await client.connect();
+  console.log('Connected.');
+
+  // Drop all application tables to start fresh since migration 001 only partially ran
+  console.log('Dropping any partial tables...');
+  const tables = await client.query(`
+    SELECT tablename FROM pg_tables WHERE schemaname = 'public'
+    AND tablename NOT LIKE 'knex%'
+    ORDER BY tablename;
+  `);
+  
+  const appTables = tables.rows.map(r => r.tablename);
+  console.log('Application tables to drop:', appTables);
+  
+  if (appTables.length > 0) {
+    // Drop in reverse dependency order
+    await client.query(`DROP TABLE IF EXISTS ${appTables.map(t => `"${t}"`).join(', ')} CASCADE`);
+    console.log('Tables dropped.');
+  } else {
+    console.log('No application tables found, DB is clean.');
+  }
+
+  // Clear any migration records so knex starts fresh
+  await client.query('DELETE FROM knex_migrations');
+  console.log('Migration history cleared.');
+
+  await client.end();
+  console.log('Done. Ready for fresh migration run.');
+}
+
+main().catch(err => { console.error(err.message); process.exit(1); });

backend/reset-db.js

@@ -0,0 +1,37 @@
+// Run all knex migrations programmatically using the known-working pg config
+import knex from 'knex';
+
+const db = knex({
+  client: 'pg',
+  connection: {
+    host: 'db.xomasbwwhhcxrptfdees.supabase.co',
+    user: 'postgres',
+    database: 'postgres',
+    password: 'pluto1234!@#$%^_',
+    port: 6543,
+    ssl: { rejectUnauthorized: false },
+  },
+  migrations: {
+    directory: './migrations',
+    extension: 'js',
+  },
+});
+
+async function main() {
+  console.log('Testing connection...');
+  await db.raw('SELECT 1');
+  console.log('Connection OK.');
+
+  console.log('Running migrations...');
+  const [batch, list] = await db.migrate.latest();
+  console.log(`Batch: ${batch}`);
+  console.log('Applied migrations:', list);
+  
+  await db.destroy();
+  console.log('Done!');
+}
+
+main().catch(err => {
+  console.error('Error:', err.message);
+  process.exit(1);
+});