feat: Push Notification API for Learning Events

package.json

@@ -41,6 +41,7 @@
     "cors": "^2.8.6",
     "dotenv": "^16.6.1",
     "express": "^5.2.1",
+    "firebase-admin": "^13.8.0",
     "helmet": "^8.1.0",
     "jsonwebtoken": "^9.0.2",
     "morgan": "^1.10.1",

prisma/schema.prisma

@@ -19,6 +19,9 @@ model User {
   completions     Completion[]
   credentials     Credential[]
   transactions    Transaction[]
+  deviceTokens    DeviceToken[]
+  notificationPref NotificationPreference?
+  notifications   NotificationLog[]
   syncEvents      SyncEvent[]
   referralCode    ReferralCode?
   referrals       Referral[]     @relation("Referrer")
@@ -161,3 +164,40 @@ model WebhookDelivery {
   lastAttemptAt  DateTime?
   createdAt      DateTime        @default(now())
 }
+
+model DeviceToken {
+  id        String   @id @default(uuid())
+  userId    String
+  user      User     @relation(fields: [userId], references: [id], onDelete: Cascade)
+  token     String   @unique
+  platform  String   // "ios", "android", "web"
+  createdAt DateTime @default(now())
+  updatedAt DateTime @updatedAt
+}
+
+model NotificationPreference {
+  id              String   @id @default(uuid())
+  userId          String   @unique
+  user            User     @relation(fields: [userId], references: [id], onDelete: Cascade)
+  rewardReceipt   Boolean  @default(true)
+  quizPassFail    Boolean  @default(true)
+  streakReminders Boolean  @default(true)
+  createdAt       DateTime @default(now())
+  updatedAt       DateTime @updatedAt
+}
+
+model NotificationLog {
+  id           String   @id @default(uuid())
+  userId       String
+  user         User     @relation(fields: [userId], references: [id], onDelete: Cascade)
+  type         String   // "reward", "quiz", "streak"
+  title        String
+  body         String
+  status       String   @default("pending") // pending, sent, failed, dead-letter
+  error        String?
+  attemptCount Int      @default(0)
+  maxAttempts  Int      @default(5)
+  nextAttemptAt DateTime? @default(now())
+  createdAt    DateTime @default(now())
+  updatedAt    DateTime @updatedAt
+}

src/config/database.ts

@@ -1,19 +1,37 @@
 import { PrismaClient } from '@prisma/client'
+import { PrismaPg } from '@prisma/adapter-pg'
+import { Pool } from 'pg'
+
+const connectionString =
+  process.env.DATABASE_URL ??
+  'postgresql://user:password@localhost:5432/learnault'
 
 const globalForPrisma = globalThis as unknown as {
-    prisma: PrismaClient | undefined
+  prisma: PrismaClient | undefined
+  pool: Pool | undefined
+}
+
+function createPrismaClient(): PrismaClient {
+  const pool =
+    globalForPrisma.pool ??
+    new Pool({
+      connectionString,
+      max: 10,
+    })
+
+  if (process.env.NODE_ENV !== 'production') {
+    globalForPrisma.pool = pool
+  }
+
+  const adapter = new PrismaPg(pool)
+
+  return new PrismaClient({ adapter })
 }
 
-const prisma = globalForPrisma.prisma ?? new PrismaClient({
-  datasources: {
-    db: {
-      url: process.env.DATABASE_URL,
-    },
-  },
-})
+const prisma = globalForPrisma.prisma ?? createPrismaClient()
 
 if (process.env.NODE_ENV !== 'production') {
-    globalForPrisma.prisma = prisma
+  globalForPrisma.prisma = prisma
 }
 
 export default prisma

src/controllers/credential.controller.ts

@@ -96,7 +96,7 @@ export class CredentialController {
           user: {
             select: {
               id: true,
-              name: true,
+              username: true,
               email: true,
             },
           },
@@ -178,7 +178,7 @@ export class CredentialController {
           user: {
             select: {
               id: true,
-              name: true,
+              username: true,
               email: true,
             },
           },
@@ -209,7 +209,7 @@ export class CredentialController {
         data: {
           id: credential.id,
           userId: credential.userId,
-          holderName: credential.user.name,
+          holderName: credential.user.username,
           moduleId: credential.moduleId,
           moduleName: credential.module.title,
           moduleDescription: credential.module.description,
@@ -260,7 +260,7 @@ export class CredentialController {
           user: {
             select: {
               id: true,
-              name: true,
+              username: true,
             },
           },
           module: {
@@ -282,7 +282,7 @@ export class CredentialController {
             user: {
               select: {
                 id: true,
-                name: true,
+                username: true,
               },
             },
             module: {
@@ -307,7 +307,7 @@ export class CredentialController {
           valid: true,
           credential: {
             id: credential.id,
-            holderName: credential.user.name,
+            holderName: credential.user.username,
             moduleName: credential.module.title,
             moduleCategory: credential.module.category,
             moduleDifficulty: credential.module.difficulty,

src/controllers/employer.controller.ts

@@ -70,7 +70,7 @@ function locationForCandidate(email: string) {
 type CandidateRecord = {
   id: string
   email: string
-  name: string
+  username: string
   createdAt: Date
   completions: Array<{
     score: number
@@ -123,7 +123,7 @@ function profileFromCandidate(candidate: CandidateRecord) {
 
   return {
     id: candidate.id,
-    name: candidate.name,
+    name: candidate.username,
     location: locationForCandidate(candidate.email),
     joinedAt: candidate.createdAt,
     skills: derivedSkills(candidate),
@@ -178,7 +178,7 @@ export const searchTalent = async (req: Request, res: Response) => {
       ...(search
         ? {
             OR: [
-              { name: { contains: search, mode: 'insensitive' } },
+              { username: { contains: search, mode: 'insensitive' } },
               { email: { contains: search, mode: 'insensitive' } },
             ],
           }
@@ -358,7 +358,7 @@ export const contactCandidate = async (req: Request, res: Response) => {
     select: {
       id: true,
       email: true,
-      name: true,
+      username: true,
     },
   })