Function addParticipantToLottery

lottery/lottery.ts:361–402

(lotteryId: number, participant: any)

      // Check current participant count
      const countStmt = db.prepare(`SELECT COUNT(*) as count FROM lottery_participants WHERE lottery_id = ?`);
      const countResult = countStmt.get(lotteryId) as { count: number } | undefined;
      const currentCount = countResult?.count || 0;
      
      // Check lottery max participants
      const lotteryStmt = db.prepare(`SELECT max_participants FROM lottery_config WHERE id = ?`);
      const lottery = lotteryStmt.get(lotteryId) as { max_participants: number } | undefined;
      
      if (!lottery || currentCount >= lottery.max_participants) {
        throw new Error("Lottery full or not found");
      }
      
      // Check if user already participated
      const existsStmt = db.prepare(`SELECT 1 FROM lottery_participants WHERE lottery_id = ? AND user_id = ?`);
      const exists = existsStmt.get(lotteryId, participant.user_id);
      
      if (exists) {
        throw new Error("User already participated");
      }
      
      // Add participant
      const insertStmt = db.prepare(`
        INSERT INTO lottery_participants (lottery_id, user_id, username, first_name, last_name, joined_at)
        VALUES (?, ?, ?, ?, ?, ?)
      `);
      insertStmt.run(lotteryId, String(participant.user_id), participant.username || null, participant.first_name || null, participant.last_name || null, Date.now());
    });
    
    transaction();
    return true;
  } catch (error) {
    console.error("Failed to add participant:", error);
    return false;
  }
}

function getLotteryParticipants(lotteryId: number): any[] {
  if (!db) return [];
  
  const stmt = db.prepare(`
    SELECT * FROM lottery_participants 
    WHERE lottery_id = ? ORDER BY joined_at
  `);
  return stmt.all(lotteryId);
}