Method getUpcomingEvents

server/src/db/community-db.ts:931–957

(userId: string, userEmail?: string)

  }

  private async getUpcomingEvents(userId: string, userEmail?: string): Promise<{ id: string; title: string; start_time: string; co_attendee_count: number }[]> {
    // Match registrations by workos_user_id OR email (Luma-synced registrations only have email)
    const userMatch = userEmail
      ? `(er.workos_user_id = $1 OR LOWER(er.email) = LOWER($2))`
      : `er.workos_user_id = $1`;
    const excludeSelf = userEmail
      ? `AND er2.workos_user_id != $1 AND LOWER(er2.email) != LOWER($2)`
      : `AND er2.workos_user_id != $1`;
    const params = userEmail ? [userId, userEmail] : [userId];

    const result = await query<{ id: string; title: string; start_time: string; co_attendee_count: number }>(
      `SELECT DISTINCT e.id, e.title, e.start_time,
              (SELECT COUNT(*) FROM event_registrations er2
               WHERE er2.event_id = e.id ${excludeSelf}
                 AND er2.registration_status IN ('registered', 'waitlisted')) as co_attendee_count
       FROM events e
       JOIN event_registrations er ON er.event_id = e.id
       WHERE ${userMatch}
         AND er.registration_status IN ('registered', 'waitlisted')
         AND e.start_time > NOW()
         AND e.status = 'published'
       ORDER BY e.start_time ASC
       LIMIT 5`,
      params
    );
    return result.rows;
  }

  private async getUserWorkingGroupsWithCount(userId: string): Promise<{ id: string; name: string; slug: string; member_count: number }[]> {
    const result = await query<{ id: string; name: string; slug: string; member_count: number }>(