feature: direct referral system

docker-compose.yaml

@@ -13,6 +13,17 @@ services:
       - valkey-data:/data
     ports:
       - "6379:6379"
+  postgres:
+    image: postgres:latest
+    ports:
+      - "${POSTGRES_PORT}:5432"
+    volumes:
+      - postgres-data:/var/lib/postgresql/data
+    environment:
+      - POSTGRES_USER=${POSTGRES_USER}
+      - POSTGRES_PASSWORD=${POSTGRES_PASSWORD}
+      - POSTGRES_DB=${POSTGRES_DB}
 
 volumes:
-  valkey-data:
+  valkey-data:
+  postgres-data:

website/.env.example

@@ -51,4 +51,10 @@ INERTIA_PUBLIC_TZ=Europe/Lisbon
 INERTIA_PUBLIC_EVENT_COUNTDOWN_DATE=2025-04-11
 
 # Tuyau
-INERTIA_PUBLIC_APP_URL=http://127.0.0.1:3333
+INERTIA_PUBLIC_APP_URL=http://127.0.0.1:3333
+
+DB_CONNECTION=postgres
+POSTGRES_PORT=5432
+POSTGRES_USER=postgres
+POSTGRES_PASSWORD=
+POSTGRES_DB=postgres

website/app/controllers/referrals_controller.ts

@@ -0,0 +1,34 @@
+import type { HttpContext } from '@adonisjs/core/http'
+import { referralCodeCookie } from '../cookies/referrals_cookies.js'
+import ReferralService from '#services/referral_service'
+import { inject } from '@adonisjs/core'
+
+@inject()
+export default class ReferralsController {
+    constructor(private referralService: ReferralService) {}
+
+    async showReferralLink(ctx: HttpContext) {
+        const user = ctx.auth.getUserOrFail()
+        const referralLink = await this.referralService.getReferralLink(user)
+
+        return ctx.inertia.render('referrals', { referralLink })
+    }
+
+    async link(ctx: HttpContext) {
+        const referralCode = ctx.params.referralCode as string
+        const referrer = await this.referralService.getReferrerByCode(referralCode)
+
+        ctx.logger.debug(referrer, "Referrer with code %s", referralCode)
+
+        if (referrer) {
+            const user = ctx.auth.user
+            if (user) {
+                await this.referralService.linkUserToReferrer(user, referrer)
+            } else {
+                referralCodeCookie.set(ctx, referralCode, { maxAge: 7*24*3600 })
+            }
+        }
+
+        return ctx.response.redirect().toRoute('pages:home')
+    }
+}

website/app/cookies/referrals_cookies.ts

@@ -0,0 +1,3 @@
+import { TypedCookie } from "#lib/adonisjs/cookies.js";
+
+export const referralCodeCookie = new TypedCookie<string>('referrer')

website/app/jobs/update_order_status.ts

@@ -5,6 +5,8 @@ import { Job } from 'adonisjs-jobs'
 import ConfirmPaymentNotification from '#mails/confirm_payment_notification'
 import mail from '@adonisjs/mail/services/main'
 import db from '@adonisjs/lucid/services/db'
+import app from '@adonisjs/core/services/app'
+import User from '#models/user'
 
 type UpdateOrderStatusPayload = {
   requestId: string
@@ -29,13 +31,18 @@ export default class UpdateOrderStatus extends Job {
         this.logger.info(`Order status is no longer pending: ${order.status}`)
         return // Exit if the status is no longer "Pending"
       }
+
       const apiResponse = await axios.get(
         `https://api.ifthenpay.com/spg/payment/mbway/status?mbWayKey=${env.get('IFTHENPAY_MBWAY_KEY')}&requestId=${requestId}`
       )
 
       if (apiResponse.status === 200) {
-        const status = apiResponse.data.Message
+        let status = apiResponse.data.Message
         if (status) {
+          if (app.inDev) {
+            status = "Success"
+          }
+
           if (status === 'Pending') {
             await UpdateOrderStatus.dispatch({ requestId, email }, { delay: 10000 }) // Retry after 5 seconds
             this.logger.info(`Requeued job for requestId: ${requestId}`)
@@ -54,7 +61,19 @@ export default class UpdateOrderStatus extends Job {
 
             const total = order.total
             const orderId = order.id
+
             await mail.send(new ConfirmPaymentNotification(email, products, total, orderId))
+
+            const user = await User.find(order.userId)
+            if (user) {
+              await user.load('participantProfile')
+              const participantProfile = user.participantProfile
+              if (participantProfile) {
+                // FIXME - this is a hack
+                participantProfile.purchasedTicket = 'early-bird-with-housing'
+                await participantProfile.save()
+              }
+            }
           }
         } else {
           await UpdateOrderStatus.dispatch({ requestId, email }, { delay: 10000 }) // Retry after 5 seconds

website/app/middleware/link_to_user_middleware.ts

@@ -0,0 +1,30 @@
+import type { HttpContext } from '@adonisjs/core/http'
+import type { NextFn } from '@adonisjs/core/types/http'
+import { referralCodeCookie } from '../cookies/referrals_cookies.js'
+import ReferralService from '#services/referral_service'
+import { inject } from '@adonisjs/core'
+
+@inject()
+export default class LinkToUserMiddleware {
+  constructor(private referralService: ReferralService) {}
+
+  async handle(ctx: HttpContext, next: NextFn) {
+    const referralCode = referralCodeCookie.get(ctx)
+
+    if (referralCode) {
+      if (!ctx.auth.authenticationAttempted) await ctx.auth.check()
+
+      const user = ctx.auth.user
+      if (user) {
+        referralCodeCookie.clear(ctx)
+
+        const referrer = await this.referralService.getReferrerByCode(referralCode)
+        if (referrer) {
+          await this.referralService.linkUserToReferrer(user, referrer)
+        }
+      }
+    }
+
+    return next()
+  }
+}

website/app/models/participant_profile.ts

@@ -17,6 +17,10 @@ export default class ParticipantProfile extends BaseModel {
   @column.dateTime({ autoCreate: true, autoUpdate: true })
   declare updatedAt: DateTime
 
+  // Ticket Info
+  @column()
+  declare purchasedTicket: "early-bird-without-housing" | "early-bird-with-housing" | null
+
   // General Info
 
   @column()

website/app/models/promoter_profile.ts

@@ -0,0 +1,18 @@
+import { DateTime } from 'luxon'
+import { BaseModel, column, hasOne } from '@adonisjs/lucid/orm'
+import User from './user.js'
+import type { HasOne } from '@adonisjs/lucid/types/relations'
+
+export default class PromoterProfile extends BaseModel {
+  @column({ isPrimary: true })
+  declare id: number
+
+  @hasOne(() => User)
+  declare user: HasOne<typeof User>
+
+  @column.dateTime({ autoCreate: true })
+  declare createdAt: DateTime
+
+  @column.dateTime({ autoCreate: true, autoUpdate: true })
+  declare updatedAt: DateTime
+}

website/app/models/user.ts

@@ -1,8 +1,9 @@
 import { DateTime } from 'luxon'
 import { BaseModel, belongsTo, column, hasMany } from '@adonisjs/lucid/orm'
-import ParticipantProfile from './participant_profile.js'
-import type { BelongsTo, HasMany } from '@adonisjs/lucid/types/relations'
 import Account from './account.js'
+import type { BelongsTo, HasMany } from '@adonisjs/lucid/types/relations'
+import PromoterProfile from './promoter_profile.js'
+import ParticipantProfile from './participant_profile.js'
 
 export default class User extends BaseModel {
   @column({ isPrimary: true })
@@ -23,7 +24,33 @@ export default class User extends BaseModel {
   @hasMany(() => Account)
   declare accounts: HasMany<typeof Account>
 
-  // Profiles
+  // Referrals
+
+  @column()
+  declare referringPromoterId: number | null
+
+  @belongsTo(() => User, {
+    foreignKey: 'promoterId',
+  })
+  declare referringPromoter: BelongsTo<typeof User>
+
+  @column()
+  declare referrerId: number | null
+
+  @belongsTo(() => User, {
+    foreignKey: 'referrerId',
+  })
+  declare referrer: BelongsTo<typeof User>
+
+  // PromoterInfo
+
+  @column()
+  declare promoterProfileId: number | null
+
+  @belongsTo(() => PromoterProfile)
+  declare promoterProfile: BelongsTo<typeof PromoterProfile>
+
+  // ParticipantProfile
 
   @column()
   declare participantProfileId: number | null
@@ -33,7 +60,42 @@ export default class User extends BaseModel {
 
   // Functions
 
+  get role() {
+    if (this.isParticipant()) return 'participant' as const
+    if (this.isPromoter()) return 'promoter' as const
+    return 'unknown' as const
+  }
+
+  isPromoter() {
+    return this.promoterProfileId !== null
+  }
+
+  isParticipant() {
+    return this.participantProfileId !== null
+  }
+
   isEmailVerified() {
     return this.emailVerifiedAt !== null
   }
+
+  wasReferred() {
+    return this.referrerId !== null
+  }
+
+  static async hasPurchasedTicket(user: User) {
+    if (!user.isParticipant()) return false
+
+    await user.load('participantProfile')
+    return !!user.participantProfile.purchasedTicket
+  }
+
+  static async getReferringPromoter(user: User) {
+    await user.load('referringPromoter')
+    return user.referringPromoter
+  }
+
+  static async getReferrer(user: User) {
+    await user.load('referrer')
+    return user.referrer
+  }
 }