Method checkAndAwardBadges

server/src/db/community-db.ts:685–756

* Check badge thresholds and award any that have been earned. * Safe to call repeatedly — uses ON CONFLICT DO NOTHING.

(userId: string, context: 'connection' | 'profile' | 'event' | 'wg' | 'content')

   * Safe to call repeatedly — uses ON CONFLICT DO NOTHING.
   */
  async checkAndAwardBadges(userId: string, context: 'connection' | 'profile' | 'event' | 'wg' | 'content'): Promise<string[]> {
    const awarded: string[] = [];

    const BADGE_LABELS: Record<string, string> = {
      connector: 'Connector',
      networker: 'Networker',
      profile_complete: 'Profile complete',
      event_regular: 'Event regular',
      working_group_member: 'Working group member',
      contributor: 'Contributor',
    };

    const tryAward = async (badgeId: string) => {
      const isNew = await this.awardBadge(userId, badgeId);
      if (isNew) {
        awarded.push(badgeId);
        // Lazy-import to avoid circular dependencies
        const { notifyUser } = await import('../notifications/notification-service.js');
        notifyUser({
          recipientUserId: userId,
          type: 'badge_earned',
          referenceId: badgeId,
          referenceType: 'badge',
          title: `You earned the "${BADGE_LABELS[badgeId] || badgeId}" badge`,
          url: '/community',
        }).catch(err => logger.error({ err }, 'Failed to send badge notification'));
      }
    };

    if (context === 'connection') {
      const count = await this.getConnectionCount(userId);
      if (count >= 10) await tryAward('connector');
      if (count >= 25) await tryAward('networker');
    }

    if (context === 'profile') {
      const profile = await this.getProfile(userId);
      if (profile) {
        const completeness = this.getProfileCompleteness(profile);
        if (completeness === 100) await tryAward('profile_complete');
      }
    }

    if (context === 'event') {
      const result = await query<{ count: string }>(
        `SELECT COUNT(*) as count FROM event_registrations WHERE workos_user_id = $1`,
        [userId]
      );
      const count = parseInt(result.rows[0]?.count || '0', 10);
      if (count >= 3) await tryAward('event_regular');
    }

    if (context === 'wg') {
      const result = await query<{ count: string }>(
        `SELECT COUNT(*) as count FROM working_group_memberships WHERE workos_user_id = $1 AND status = 'active'`,
        [userId]
      );
      const count = parseInt(result.rows[0]?.count || '0', 10);