Add dashboard summary, and improve test coverage and linting

.env.sample

@@ -1,5 +1,4 @@
 PORT=3000
-DB_FILE='investec.db'
 AUTH=false
 CLIENT_ID=
 CLIENT_SECRET=

.gitignore

@@ -2,4 +2,7 @@
 **/dist
 .env
 **.db-shm
-**.db-wal
+**.db-wal
+**.db-journal
+CLAUDE.md
+.idea

eslint.config.js

@@ -9,7 +9,7 @@ export default [
       '@stylistic/js': stylisticJs,
     },
     rules: {
-      '@stylistic/js/max-len': 120,
+      '@stylistic/js/max-len': ['error', { code: 120 }],
     },
   },
   { files: ['**/*.{js,mjs,cjs,ts}'] },

prisma/account.ts

@@ -9,34 +9,49 @@ const accountData: Prisma.AccountCreateInput[] = [
     accountName: 'Mr J Soap',
     referenceName: 'Mr J Soap',
     productName: 'Private Bank Account',
+    kycCompliant: true,
+    profileId: '10001234567890',
+    profileName: 'Joe Soap',
   },
   {
     accountId: '4675778129910189600000004',
     accountNumber: '10012420004',
     accountName: 'Mr J Soap',
     referenceName: 'Mr J Soap',
     productName: 'PrimeSaver',
+    kycCompliant: true,
+    profileId: '10001234567890',
+    profileName: 'Joe Soap',
   },
   {
     accountId: '4675778129910189600000005',
     accountNumber: '10012420005',
     accountName: 'Mr J Soap',
     referenceName: 'Mr J Soap',
     productName: 'Cash Management Account',
+    kycCompliant: true,
+    profileId: '10001234567890',
+    profileName: 'Joe Soap',
   },
   {
     accountId: '4675778129910189600000006',
     accountNumber: '10012420006',
     accountName: 'Mr J Soap',
     referenceName: 'Mr J Soap',
     productName: 'Mortgage Loan Account',
+    kycCompliant: true,
+    profileId: '10001234567890',
+    profileName: 'Joe Soap',
   },
   {
     accountId: '4675778129910189600000007',
     accountNumber: '10012420007',
     accountName: 'Mr J Soap',
     referenceName: 'Mr J Soap',
     productName: 'Instalment Sale Loan Account',
+    kycCompliant: true,
+    profileId: '10001234567890',
+    profileName: 'Joe Soap',
   },
 ]
 

prisma/migrations/20250708211014_add_profile_and_kyc/migration.sql

@@ -0,0 +1,28 @@
+-- CreateTable
+CREATE TABLE "Profile" (
+    "profileId" TEXT NOT NULL PRIMARY KEY,
+    "profileName" TEXT NOT NULL
+);
+
+-- Insert default profile
+INSERT INTO "Profile" ("profileId", "profileName") VALUES ('10001234567890', 'Joe Soap');
+
+-- RedefineTables
+PRAGMA defer_foreign_keys=ON;
+PRAGMA foreign_keys=OFF;
+CREATE TABLE "new_Account" (
+    "accountId" TEXT NOT NULL PRIMARY KEY,
+    "accountNumber" TEXT NOT NULL,
+    "accountName" TEXT NOT NULL,
+    "referenceName" TEXT NOT NULL,
+    "productName" TEXT NOT NULL,
+    "kycCompliant" BOOLEAN NOT NULL DEFAULT true,
+    "profileId" TEXT NOT NULL,
+    "profileName" TEXT NOT NULL
+);
+INSERT INTO "new_Account" ("accountId", "accountName", "accountNumber", "productName", "referenceName", "kycCompliant", "profileId", "profileName") 
+SELECT "accountId", "accountName", "accountNumber", "productName", "referenceName", true, '10001234567890', 'Joe Soap' FROM "Account";
+DROP TABLE "Account";
+ALTER TABLE "new_Account" RENAME TO "Account";
+PRAGMA foreign_keys=ON;
+PRAGMA defer_foreign_keys=OFF;

prisma/profile.ts

@@ -0,0 +1,19 @@
+import { PrismaClient, Prisma } from '@prisma/client'
+
+const prisma = new PrismaClient()
+
+const profileData: Prisma.ProfileCreateInput[] = [
+  {
+    profileId: '10001234567890',
+    profileName: 'Joe Soap',
+  },
+]
+
+export async function seedProfiles() {
+  for (const p of profileData) {
+    const profile = await prisma.profile.create({
+      data: p,
+    })
+    console.log(`Created profile with id: ${profile.profileId}`)
+  }
+}

prisma/schema.prisma

@@ -7,12 +7,20 @@ datasource db {
   url      = "file:./dev.db"
 }
 
+model Profile {
+    profileId String @id
+    profileName String
+}
+
 model Account {
     accountId String @id
     accountNumber String
     accountName String
     referenceName String
     productName String
+    kycCompliant Boolean @default(true)
+    profileId String
+    profileName String
 }
 
 model Transaction {

prisma/seed.ts

@@ -2,6 +2,7 @@ import { PrismaClient } from '@prisma/client'
 import { seedCurrencies } from './currency'
 import { seedCountries } from './country'
 import { seedMerchants } from './merchant'
+import { seedProfiles } from './profile'
 import { seedAccounts } from './account'
 import { seedTransactions } from './transaction'
 import { seedSettings } from './settings'
@@ -16,6 +17,7 @@ async function main() {
   await seedCurrencies()
   await seedCountries()
   await seedMerchants()
+  await seedProfiles()
   await seedAccounts()
   await seedTransactions()
   await seedCards()

src/app.ts

@@ -22,11 +22,11 @@ import { seedTransactions } from '../prisma/transaction.js'
 import { seedBeneficiaries } from '../prisma/beneficiary.js'
 import { seedCards } from '../prisma/card.js'
 import { seedCardCodes } from '../prisma/card-code.js'
+import { seedProfiles } from '../prisma/profile.js'
 
 dotenv.config()
 
 export const port = process.env.PORT || 3000
-// const dbFile = process.env.DB_FILE || 'investec.db'
 // const overdraft = process.env.OVERDRAFT || 5000
 const prisma = new PrismaClient()
 export const app = express()
@@ -67,18 +67,23 @@ io.on('connection', socket => {
         await prisma.beneficiary.deleteMany()
         await prisma.card.deleteMany()
         await prisma.cardCode.deleteMany()
+        await prisma.profile.deleteMany()
+        await emitDatabaseSummary()
         break
       case 'restore':
         await prisma.account.deleteMany()
         await prisma.transaction.deleteMany()
         await prisma.beneficiary.deleteMany()
         await prisma.card.deleteMany()
         await prisma.cardCode.deleteMany()
+        await prisma.profile.deleteMany()
+        seedProfiles()
         seedAccounts()
         seedTransactions()
         seedBeneficiaries()
         seedCards()
         seedCardCodes()
+        await emitDatabaseSummary()
         break
     }
     //io.emit('control', settings);
@@ -202,6 +207,29 @@ app.get('/envs', async (req: Request, res: Response) => {
   }
 })
 
+app.get('/database-summary', async (req: Request, res: Response) => {
+  try {
+    const [profileCount, accountCount, cardCount, transactionCount] = await Promise.all([
+      prisma.profile.count(),
+      prisma.account.count(),
+      prisma.card.count(),
+      prisma.transaction.count()
+    ])
+
+    const summary = {
+      profiles: profileCount,
+      accounts: accountCount,
+      cards: cardCount,
+      transactions: transactionCount
+    }
+
+    return formatResponse(summary, req, res)
+  } catch (error) {
+    console.log(error)
+    return formatErrorResponse(req, res, 500)
+  }
+})
+
 function isValidToken(req: Request) {
   if (settings.auth !== true) {
     return true
@@ -223,20 +251,45 @@ function isValidToken(req: Request) {
   return false
 }
 
+export async function emitDatabaseSummary() {
+  try {
+    const [profileCount, accountCount, cardCount, transactionCount] = await Promise.all([
+      prisma.profile.count(),
+      prisma.account.count(),
+      prisma.card.count(),
+      prisma.transaction.count()
+    ])
+
+    const summary = {
+      profiles: profileCount,
+      accounts: accountCount,
+      cards: cardCount,
+      transactions: transactionCount
+    }
+
+    io.sockets.emit('database-summary', summary)
+  } catch (error) {
+    console.log('Error emitting database summary:', error)
+  }
+}
+
 export function formatResponse (data: unknown, req: Request, res: Response) {
   const date = new Date()
-  io.sockets.emit(
-    messageQueue,
-    date.toUTCString() +
-      ' ' +
-      req.method +
-      ' ' +
-      req.url +
-      ' HTTP/' +
-      req.httpVersion +
-      ' ' +
-      res.statusCode,
-  )
+  // Don't log database-summary calls as they're internal dashboard calls
+  if (req.originalUrl !== '/database-summary') {
+    io.sockets.emit(
+      messageQueue,
+      date.toUTCString() +
+        ' ' +
+        req.method +
+        ' ' +
+        req.originalUrl +
+        ' HTTP/' +
+        req.httpVersion +
+        ' ' +
+        res.statusCode,
+    )
+  }
   return res.json({
     data,
     links: {
@@ -255,7 +308,7 @@ export function formatErrorResponse(req: Request, res: Response, code: number) {
       ' ' +
       req.method +
       ' ' +
-      req.url +
+      req.originalUrl +
       ' HTTP/' +
       req.httpVersion +
       ' ' +

src/index.html

@@ -66,6 +66,23 @@
                     <button type="button" @click="restoreMethod" class="block rounded-md bg-gray-900 px-3 py-2 text-center text-sm font-semibold text-white shadow-sm hover:bg-gray-600 focus-visible:outline focus-visible:outline-2 focus-visible:outline-offset-2 focus-visible:outline-gray-600">Reset DB</button>
                   </div>
               </div>
+            <!-- Database Summary -->
+            <div class="mt-4 divide-y divide-gray-200 overflow-hidden rounded-lg bg-white shadow">
+                <div class="px-4 py-5 sm:p-6">
+                    <h2 class="text-lg font-semibold leading-6 text-gray-900">Database Summary</h2>
+                </div>
+                <div class="px-4 py-4 sm:px-6">
+                    <div class="text-sm text-gray-600">
+                        <span class="font-medium">Profiles:</span> <span class="font-semibold text-gray-900">{{ summary.profiles || 0 }}</span>
+                        <span style="margin: 0 2rem;"></span>
+                        <span class="font-medium">Accounts:</span> <span class="font-semibold text-gray-900">{{ summary.accounts || 0 }}</span>
+                        <span style="margin: 0 2rem;"></span>
+                        <span class="font-medium">Cards:</span> <span class="font-semibold text-gray-900">{{ summary.cards || 0 }}</span>
+                        <span style="margin: 0 2rem;"></span>
+                        <span class="font-medium">Transactions:</span> <span class="font-semibold text-gray-900">{{ summary.transactions || 0 }}</span>
+                    </div>
+                </div>
+            </div>
             <!-- Server Logs -->
             <div class="mt-4 divide-y divide-gray-200 overflow-hidden rounded-lg bg-white shadow">
                 <div class="px-4 py-5 sm:p-6">
@@ -146,6 +163,12 @@ <h2 class="text-base font-semibold leading-7 text-gray-900">Environmental Variab
                 token_expiry: 1799,
                 auth: false,
                 alertMessage: null,
+                summary: {
+                    profiles: 0,
+                    accounts: 0,
+                    cards: 0,
+                    transactions: 0
+                }
             }
           },
             mounted() {
@@ -168,7 +191,11 @@ <h2 class="text-base font-semibold leading-7 text-gray-900">Environmental Variab
                         this.auth = false;
                     }
                 });
+                this.socket.on('database-summary', (msg) => {
+                    this.summary = msg;
+                });
                 this.fetchEnv();
+                this.fetchSummary();
             },
           methods: {
             fetchEnv() {
@@ -186,6 +213,13 @@ <h2 class="text-base font-semibold leading-7 text-gray-900">Environmental Variab
                   }
                 });
             },
+            fetchSummary() {
+              fetch('/database-summary')
+                .then(response => response.json())
+                .then(data => {
+                  this.summary = data.data;
+                });
+            },
             mySubmitMethod() {
               if (this.client_id && this.client_secret && this.api_key) {
                 this.socket.emit('envs', {
@@ -203,14 +237,16 @@ <h2 class="text-base font-semibold leading-7 text-gray-900">Environmental Variab
                     action: 'clear',
                     message: '',
                 });
-                this.toast('Database cleared')
+                this.toast('Database cleared');
+                setTimeout(() => this.fetchSummary(), 500);
             },
             restoreMethod() {
                 this.socket.emit('control', {
                     action: 'restore',
                     message: '',
                 });
-                this.toast('Database Reseeded')
+                this.toast('Database Reseeded');
+                setTimeout(() => this.fetchSummary(), 500);
             },
             toast(msg) {
                 this.alertMessage = msg;