Method getHubData

server/src/db/community-db.ts:880–929

(userId: string)

  // =====================================================

  async getHubData(userId: string): Promise<HubData> {
    // Fetch user profile
    const profileResult = await query<CommunityProfile & { first_name: string; last_name: string; city: string | null; country: string | null; email: string | null }>(
      `SELECT workos_user_id, slug, headline, bio, avatar_url, expertise, interests,
              linkedin_url, twitter_url, github_username, is_public, open_to_coffee_chat, open_to_intros,
              first_name, last_name, city, country, email
       FROM users WHERE workos_user_id = $1`,
      [userId]
    );

    const profile = profileResult.rows[0];
    if (!profile) {
      throw new Error('User not found');
    }

    // Parallel fetch all hub data
    const [
      totalPoints,
      badges,
      suggestedConnections,
      recentProfiles,
      upcomingEvents,
      workingGroups,
      connectionCount,
      pendingRequestCount,
    ] = await Promise.all([
      this.getUserPoints(userId),
      this.getUserBadges(userId),
      this.getSuggestedConnections(userId, 4),
      this.getRecentPublicProfiles(5),
      this.getUpcomingEvents(userId, profile.email ?? undefined),
      this.getUserWorkingGroupsWithCount(userId),
      this.getConnectionCount(userId),
      this.getPendingRequestCount(userId),
    ]);

    return {
      profile,
      profile_completeness: this.getProfileCompleteness(profile),
      total_points: totalPoints,
      tier: this.getTierName(totalPoints),
      badges,
      suggested_connections: suggestedConnections,
      recent_profiles: recentProfiles.filter(p => p.workos_user_id !== userId),
      upcoming_events: upcomingEvents,
      working_groups: workingGroups,
      connection_count: connectionCount,
      pending_request_count: pendingRequestCount,
    };
  }

  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)