Function validateUserConditions

lottery/lottery.ts:429–474

(client: TelegramClient, user: any, lottery: any, chatId: string)

    // Check avatar requirement
    if (lottery.require_avatar) {
      const userId = user.id || user;
      const userEntity = await getEntityWithHash(client, userId);
      if (userEntity && "photo" in userEntity && !userEntity.photo) {
        return { valid: false, reason: "需要设置头像才能参与抽奖" };
      }
    }

    // Check username requirement
    if (lottery.require_username && !user.username) {
      return { valid: false, reason: "需要设置用户名才能参与抽奖" };
    }

    // Check channel subscription requirement
    if (lottery.required_channel) {
      try {
        const userId = user.id || user;
        const channelEntity = await client.getEntity(lottery.required_channel);
        const participant = await client.invoke(
          new Api.channels.GetParticipant({
            channel: channelEntity,
            participant: userId,
          })
        );
        if (!participant) {
          return { valid: false, reason: `需要关注频道 ${lottery.required_channel} 才能参与抽奖` };
        }
      } catch (error) {
        return { valid: false, reason: `需要关注指定频道才能参与抽奖` };
      }
    }

    return { valid: true };
  } catch (error) {
    console.error("Error validating user conditions:", error);
    return { valid: true }; // Default to allow if validation fails
  }
}

// Prize distribution status functions
function updateWinnerStatus(winnerId: number, status: PrizeStatus, claimedAt?: number): void {
  if (!db) return;
  
  const stmt = db.prepare(`
    UPDATE lottery_winners 
    SET status = ?, claimed_at = ? 
    WHERE id = ?
  `);
  stmt.run(status, claimedAt || null, winnerId);
}