feat: add featured events route

Author: brage-andreas

apps/rpc/package.json

@@ -38,7 +38,7 @@
     "@dotkomonline/utils": "workspace:*",
     "@fastify/cors": "^11.0.0",
     "@opentelemetry/api": "^1.9.0",
-    "@prisma/client": "^6.8.2",
+    "@prisma/client": "^6.19.0",
     "@sentry/node": "^9.24.0",
     "@trpc/server": "11.4.4",
     "auth0": "^4.23.1",

apps/rpc/src/modules/event/event-repository.ts

@@ -1,4 +1,5 @@
 import type { DBHandle } from "@dotkomonline/db"
+import { findFeaturedEvents } from "@dotkomonline/db"
 import {
   type AttendanceId,
   type CompanyId,
@@ -12,6 +13,8 @@ import {
   type EventId,
   EventSchema,
   type EventWrite,
+  type FeaturedEvent,
+  FeaturedEventSchema,
   type GroupId,
   type UserId,
 } from "@dotkomonline/types"
@@ -41,6 +44,8 @@ const INCLUDE_COMPANY_AND_GROUPS = {
 export interface EventRepository {
   create(handle: DBHandle, data: EventWrite): Promise<Event>
   update(handle: DBHandle, eventId: EventId, data: Partial<EventWrite>): Promise<Event>
+  updateEventAttendance(handle: DBHandle, eventId: EventId, attendanceId: AttendanceId): Promise<Event>
+  updateEventParent(handle: DBHandle, eventId: EventId, parentEventId: EventId | null): Promise<Event>
   /**
    * Soft-delete an event by setting its status to "DELETED".
    */
@@ -81,15 +86,17 @@ export interface EventRepository {
     page: Pageable
   ): Promise<Event[]>
   findByParentEventId(handle: DBHandle, parentEventId: EventId): Promise<Event[]>
+  findEventsWithUnansweredFeedbackFormByUserId(handle: DBHandle, userId: UserId): Promise<Event[]>
+  findManyDeregisterReasonsWithEvent(handle: DBHandle, page: Pageable): Promise<DeregisterReasonWithEvent[]>
+  // This cannot use `Pageable` due to raw query needing numerical offset and not cursor based pagination
+  findFeaturedEvents(handle: DBHandle, offset: number, limit: number): Promise<FeaturedEvent["event"][]>
+
   addEventHostingGroups(handle: DBHandle, eventId: EventId, hostingGroupIds: Set<GroupId>): Promise<void>
-  addEventCompanies(handle: DBHandle, eventId: EventId, companyIds: Set<CompanyId>): Promise<void>
   deleteEventHostingGroups(handle: DBHandle, eventId: EventId, hostingGroupIds: Set<GroupId>): Promise<void>
+  addEventCompanies(handle: DBHandle, eventId: EventId, companyIds: Set<CompanyId>): Promise<void>
   deleteEventCompanies(handle: DBHandle, eventId: EventId, companyIds: Set<CompanyId>): Promise<void>
-  updateEventAttendance(handle: DBHandle, eventId: EventId, attendanceId: AttendanceId): Promise<Event>
-  updateEventParent(handle: DBHandle, eventId: EventId, parentEventId: EventId | null): Promise<Event>
-  findEventsWithUnansweredFeedbackFormByUserId(handle: DBHandle, userId: UserId): Promise<Event[]>
+
   createDeregisterReason(handle: DBHandle, data: DeregisterReasonWrite): Promise<DeregisterReason>
-  findManyDeregisterReasonsWithEvent(handle: DBHandle, page: Pageable): Promise<DeregisterReasonWithEvent[]>
 }
 
 export function getEventRepository(): EventRepository {
@@ -310,6 +317,27 @@ export function getEventRepository(): EventRepository {
       )
     },
 
+    async findFeaturedEvents(handle, offset, limit) {
+      // This is a complex task to do, and we will try to make it as simple as possible for now.
+      //
+      // Events will primarily be ranked by their type in the following order (lower number is higher ranking):
+      // 1. GENERAL_ASSEMBLY
+      // 2. COMPANY, ACADEMIC
+      // 3. SOCIAL, INTERNAL, OTHER, WELCOME
+      //
+      // Within each bucket they will be ranked like this:
+      // 1. Event in future, registration open and not full AND attendance capacity is limited (>0)
+      // 2. Event in future, registration not started yet (attendance capacity does not matter)
+      // 3. Event in future, no attendance registration OR attendance capacity is unlimited (=0)
+      // 4. Event in future, registration full (registration status does not matter)
+      //
+      // Past events are not featured. We would rather have no featured events than "stale" events.
+      const events = await handle.$queryRawTyped(findFeaturedEvents(offset, limit))
+
+      // FeaturedEventSchema includes attendance, so we pick just the event shape here
+      return parseOrReport(FeaturedEventSchema.shape.event.array(), events)
+    },
+
     async addEventHostingGroups(handle, eventId, hostingGroupIds) {
       await handle.eventHostingGroup.createMany({
         data: hostingGroupIds

apps/rpc/src/modules/event/event-router.ts

@@ -6,6 +6,7 @@ import {
   EventSchema,
   EventWithAttendanceSchema,
   EventWriteSchema,
+  FeaturedEventSchema,
   GroupSchema,
   UserSchema,
 } from "@dotkomonline/types"
@@ -290,6 +291,33 @@ const findManyDeregisterReasonsWithEventProcedure = procedure
     }
   })
 
+export type FindFeaturedEventsInput = inferProcedureInput<typeof findFeaturedEventsProcedure>
+export type FindFeaturedEventsOutput = inferProcedureOutput<typeof findFeaturedEventsProcedure>
+const findFeaturedEventsProcedure = procedure
+  .input(
+    z.object({
+      offset: z.number().min(0).default(0),
+      limit: z.number().min(1).max(100).default(10),
+    })
+  )
+  .output(FeaturedEventSchema.array())
+  .use(withDatabaseTransaction())
+  .query(async ({ input, ctx }) => {
+    const events = await ctx.eventService.findFeaturedEvents(ctx.handle, input.offset, input.limit)
+
+    const attendances = await ctx.attendanceService.getAttendancesByIds(
+      ctx.handle,
+      events.map((item) => item.attendanceId).filter((id) => id !== null)
+    )
+
+    const eventsWithAttendance = events.map((event) => ({
+      event,
+      attendance: attendances.find((attendance) => attendance.id === event.attendanceId) || null,
+    }))
+
+    return eventsWithAttendance
+  })
+
 export type CreateFileUploadInput = inferProcedureInput<typeof createFileUploadProcedure>
 export type CreateFileUploadOutput = inferProcedureOutput<typeof createFileUploadProcedure>
 const createFileUploadProcedure = procedure

apps/rpc/src/modules/event/event-service.ts

@@ -12,6 +12,7 @@ import type {
   EventFilterQuery,
   EventId,
   EventWrite,
+  FeaturedEvent,
   GroupId,
   UserId,
 } from "@dotkomonline/types"
@@ -45,6 +46,7 @@ export interface EventService {
   findByParentEventId(handle: DBHandle, parentEventId: EventId): Promise<Event[]>
   findEventById(handle: DBHandle, eventId: EventId): Promise<Event | null>
   findEventsWithUnansweredFeedbackFormByUserId(handle: DBHandle, userId: UserId): Promise<Event[]>
+  findFeaturedEvents(handle: DBHandle, offset: number, limit: number): Promise<FeaturedEvent["event"][]>
   /**
    * Get an event by its id
    *
@@ -98,6 +100,10 @@ export function getEventService(
       return await eventRepository.findEventsWithUnansweredFeedbackFormByUserId(handle, userId)
     },
 
+    async findFeaturedEvents(handle, offset, limit) {
+      return await eventRepository.findFeaturedEvents(handle, offset, limit)
+    },
+
     async getEventById(handle, eventId) {
       const event = await eventRepository.findById(handle, eventId)
       if (!event) {

apps/web/src/app/page.tsx

@@ -10,7 +10,7 @@ import type { Attendance, Event, EventWithAttendance, UserId } from "@dotkomonli
 import { RichText, cn } from "@dotkomonline/ui"
 import { Text, Tilt, Title } from "@dotkomonline/ui"
 import { Button } from "@dotkomonline/ui"
-import { getCurrentUTC, slugify } from "@dotkomonline/utils"
+import { slugify } from "@dotkomonline/utils"
 import { IconArrowRight, IconCalendarEvent } from "@tabler/icons-react"
 import { formatDate } from "date-fns"
 import { nb } from "date-fns/locale"
@@ -20,17 +20,8 @@ import type { FC } from "react"
 export default async function App() {
   const [session, isStaff] = await Promise.all([auth.getServerSession(), server.user.isStaff.query()])
 
-  const { items: events } = await server.event.all.query({
-    take: 3,
-    filter: {
-      byEndDate: {
-        max: null,
-        min: getCurrentUTC(),
-      },
-      excludingOrganizingGroup: ["velkom"],
-      excludingType: isStaff ? [] : undefined,
-      orderBy: "asc",
-    },
+  const events = await server.event.findFeaturedEvents.query({
+    limit: 3,
   })
 
   const featuredEvent = events[0] ?? null

package.json

@@ -21,11 +21,11 @@
     "dev": "pnpm -rc --parallel -F @dotkomonline/ui -F @dotkomonline/web -F @dotkomonline/dashboard -F @dotkomonline/rpc -F @dotkomonline/invoicification -F @dotkomonline/rif exec doppler run --preserve-env pnpm run dev",
     "dev:web": "pnpm -rc --parallel -F @dotkomonline/ui -F @dotkomonline/web -F @dotkomonline/dashboard -F @dotkomonline/rpc exec doppler run --preserve-env pnpm run dev",
     "prisma": "pnpm -F @dotkomonline/db prisma",
-    "generate": "pnpm -F @dotkomonline/db generate",
-    "migrate:dev": "pnpm -F @dotkomonline/db migrate",
-    "migrate:dev-with-fixtures": "pnpm -F @dotkomonline/db prisma migrate dev && pnpm -F @dotkomonline/db apply-fixtures",
-    "migrate:deploy": "pnpm -F @dotkomonline/db prisma migrate deploy",
-    "migrate:deploy-with-fixtures": "pnpm -F @dotkomonline/db prisma migrate deploy && pnpm -F @dotkomonline/db apply-fixtures",
+    "generate": "doppler run --project monoweb-rpc -- pnpm -F @dotkomonline/db generate",
+    "migrate:dev": "doppler run --project monoweb-rpc -- pnpm -F @dotkomonline/db migrate",
+    "migrate:dev-with-fixtures": "doppler run --project monoweb-rpc -- pnpm -F @dotkomonline/db prisma migrate dev && pnpm -F @dotkomonline/db apply-fixtures",
+    "migrate:deploy": "doppler run --project monoweb-rpc -- pnpm -F @dotkomonline/db prisma migrate deploy",
+    "migrate:deploy-with-fixtures": "doppler run --project monoweb-rpc -- pnpm -F @dotkomonline/db prisma migrate deploy && pnpm -F @dotkomonline/db apply-fixtures",
     "migrate:staging": "doppler run --config stg --project monoweb-rpc -- pnpm migrate:deploy",
     "migrate:prod": "doppler run --config prd --project monoweb-rpc -- pnpm migrate:deploy",
     "storybook": "pnpm run -r --filter=storybook storybook",

packages/db/package.json

@@ -23,14 +23,14 @@
     "type-check": "tsc --noEmit",
     "prisma": "prisma",
     "migrate": "prisma migrate dev",
-    "generate": "prisma generate",
-    "postinstall": "prisma generate",
+    "generate": "prisma generate --sql",
+    "postinstall": "prisma generate --sql",
     "apply-fixtures": "tsx src/fixtures.ts"
   },
   "dependencies": {
     "@dotkomonline/logger": "workspace:*",
     "@dotkomonline/utils": "workspace:*",
-    "@prisma/client": "^6.8.2",
+    "@prisma/client": "^6.19.0",
     "@testcontainers/postgresql": "^11.5.1",
     "date-fns": "^4.1.0",
     "pg": "^8.16.0",
@@ -44,7 +44,7 @@
     "@types/node": "22.18.6",
     "@types/pg": "8.15.6",
     "common-tags": "1.8.2",
-    "prisma": "6.8.2",
+    "prisma": "6.19.0",
     "tsx": "4.20.6",
     "typescript": "5.9.3"
   }

packages/db/prisma.config.ts

@@ -0,0 +1,12 @@
+import { defineConfig } from "prisma/config"
+
+if (process.env.DATABASE_URL === undefined) {
+  throw new Error("Missing database url")
+}
+
+export default defineConfig({
+  schema: "./prisma/schema.prisma",
+  typedSql: {
+    path: "./prisma/sql",
+  },
+})

packages/db/prisma/schema.prisma

@@ -1,6 +1,6 @@
 generator client {
   provider        = "prisma-client-js"
-  previewFeatures = ["relationJoins"]
+  previewFeatures = ["relationJoins", "typedSql"]
 }
 
 generator zod {
@@ -222,14 +222,25 @@ enum EventStatus {
   @@map("event_status")
 }
 
+// IMPORTANT: The ordering here matters.
+// Ascending sort will sort from top to bottom, and it is used in our code for sorting events by significance. Mind
+// this when adding new event types, as they are supposed to be ordered in significance. General assembly will always
+// be the most significant event type, followed by company events etc.
 enum EventType {
-  SOCIAL           @map("SOCIAL")
-  ACADEMIC         @map("ACADEMIC")
-  COMPANY          @map("COMPANY")
-  // This is called "Generalforsamling" in Norwegian and happens twice a year.
+  /// Generalforsamling
   GENERAL_ASSEMBLY @map("GENERAL_ASSEMBLY")
+  /// Bedriftspresentasjon
+  COMPANY          @map("COMPANY")
+  /// Kurs
+  ACADEMIC         @map("ACADEMIC")
+  SOCIAL           @map("SOCIAL")
+  // These are for the rare occations we have events that are only open to committee members
   INTERNAL         @map("INTERNAL")
   OTHER            @map("OTHER")
+  // These are for a committe called "velkom" and are special social events for new students.
+  // These have a separate type because we have historically hid these from event lists to not
+  // spam students that are not new with these events. In older versions of OnlineWeb these
+  // were even treated as a completely separate event entity.
   WELCOME          @map("WELCOME")
 
   @@map("event_type")

packages/db/prisma/sql/findFeaturedEvents.sql

@@ -0,0 +1,98 @@
+-- @param {Int} $1:offset
+-- @param {Int} $2:limit
+
+-- DOCS: https://www.prisma.io/docs/orm/prisma-client/using-raw-sql/typedsql
+
+-- This SQL query is used in EventRepository#findFeaturedEvents to find featured events, as this is too complex to do
+-- with Prisma's normal query API.
+
+-- Events will primarily be ranked by their type in the following order (lower number is higher ranking):
+--   1. GENERAL_ASSEMBLY
+--   2. COMPANY, ACADEMIC
+--   3. SOCIAL, INTERNAL, OTHER, WELCOME
+--
+-- Within each bucket they will be ranked like this:
+--   1. Event in future, registration open and not full AND attendance capacity is limited (>0)
+--   2. Event in future, registration not started yet (attendance capacity does not matter)
+--   3. Event in future, no attendance registration OR attendance capacity is unlimited (=0)
+--   4. Event in future, registration full (registration status does not matter)
+--
+-- Past events are not featured. We would rather have no featured events than "stale" events.
+
+WITH caps AS (
+  SELECT
+    "attendanceId",
+    SUM("capacity") AS total_capacity
+  FROM "attendance_pool"
+  GROUP BY "attendanceId"
+),
+att_counts AS (
+  SELECT
+    "attendanceId",
+    COUNT(*) AS attendee_count
+  FROM "attendee"
+  GROUP BY "attendanceId"
+)
+SELECT
+  e.*,
+  COALESCE(caps.total_capacity, 0)        AS "totalCapacity",
+  COALESCE(att_counts.attendee_count, 0)  AS "attendeeCount",
+
+  -- 1,2,3: event type buckets
+  CASE e."type"
+    WHEN 'GENERAL_ASSEMBLY' THEN 1
+    WHEN 'COMPANY'          THEN 2
+    WHEN 'ACADEMIC'         THEN 2
+    ELSE 3
+  END AS "typeRank",
+
+  -- 1-4: registration buckets
+  CASE
+    -- 1. Future, registration open and not full AND capacity limited (> 0)
+    WHEN e."attendanceId" IS NOT NULL
+      AND NOW() BETWEEN a."registerStart" AND a."registerEnd"
+      AND COALESCE(caps.total_capacity, 0) > 0
+      AND COALESCE(att_counts.attendee_count, 0) < COALESCE(caps.total_capacity, 0)
+    THEN 1
+
+    -- 2. Future, registration not started yet (capacity doesn't matter)
+    WHEN e."attendanceId" IS NOT NULL
+      AND NOW() < a."registerStart"
+    THEN 2
+
+    -- 3. Future, no registration OR unlimited capacity (total capacity = 0)
+    WHEN e."attendanceId" IS NULL
+      OR COALESCE(caps.total_capacity, 0) = 0
+    THEN 3
+
+    -- 4. Future, registration full (status doesn't matter)
+    WHEN e."attendanceId" IS NOT NULL
+      AND COALESCE(caps.total_capacity, 0) > 0
+      AND COALESCE(att_counts.attendee_count, 0) >= COALESCE(caps.total_capacity, 0)
+    THEN 4
+
+    -- Fallback: treat as bucket 4
+    ELSE 4
+  END AS "registrationBucket"
+
+FROM "event" e
+LEFT JOIN "attendance" a
+  ON a."id" = e."attendanceId"
+LEFT JOIN caps
+  ON caps."attendanceId" = e."attendanceId"
+LEFT JOIN att_counts
+  ON att_counts."attendanceId" = e."attendanceId"
+
+WHERE
+  e."status" = 'PUBLIC'
+  -- Past events are not featured
+  AND e."start" > NOW()
+
+ORDER BY
+  "typeRank" ASC,
+  "registrationBucket" ASC,
+  -- Tie breaker with earlier events first
+  e."start" ASC
+
+OFFSET $1
+LIMIT $2;