Subversion Repositories VORC

	my $qdbh = WebDB::connect ("session");

	my $qdbh = WebDB::connect ("session");

	if ($RCAUTH) {

	if ($RCAUTH) {

	  # If the user is already logged in, bypass the queue check.

	  # If the user is already logged in, bypass the queue check.

   	my ($active) = $qdbh->selectrow_array ("select count(*) from session where email = ? and timestamp > (now() - interval 30 minute)", undef, $email);

   	my ($active) = $qdbh->selectrow_array ("select count(*) from session where email = ? and timestampdiff(minute, timestamp, now()) < 30", undef, $email);

    return if $active;

    return if $active;

 	my ($active_users) = $qdbh->selectrow_array ("select count(*) from session where timestamp > (now() - interval 30 minute)");

 	my ($active_users) = $qdbh->selectrow_array ("select count(*) from session where timestampdiff(minute, timestamp, now()) < 30)");

	my @queued_users;

	my @queued_users;

  push @queued_users, map { @{$_} } @{ $qdbh->selectall_arrayref ("select queueid from queue where last_seen > (now() - interval 7 minute) and (timestamp <> last_seen or timestampdiff(minute, last_seen, now()) <= 1) order by timestamp") };

  push @queued_users, map { @{$_} } @{ $qdbh->selectall_arrayref ("select queueid from queue where timestampdiff(minute, last_seen, now()) < 7 and (timestamp <> last_seen or timestampdiff(second, last_seen, now()) <= 60) order by timestamp") };

 	my $RCqueueID = CGI::cookie('RCQUEUEID') // WebDB::trim CGI::param('RCqueueID') // "";

 	my $RCqueueID = CGI::cookie('RCQUEUEID') // WebDB::trim CGI::param('RCqueueID') // "";

  $RCqueueID = "" unless inQueue ($RCqueueID, \@queued_users);

  $RCqueueID = "" unless inQueue ($RCqueueID, \@queued_users);

 	my $your_wait = 0;

  if ($active_users >= $max_users) {

  if ($active_users >= $max_users) {

    # We are at max users. People have to wait.

    # We are at max users. People have to wait.

    if (!$RCqueueID) {

    if (!$RCqueueID) {

   	  use Digest::MD5 qw/md5_hex/;

   	  use Digest::MD5 qw/md5_hex/;

   	  $RCqueueID = time () ."-". md5_hex (rand ());

   	  push @queued_users, $RCqueueID;

   	  push @queued_users, $RCqueueID;

   	  $qdbh->do ("replace into queue (queueid, timestamp, last_seen) values (?, now(), now())", undef, $RCqueueID);

    } else {

    	($your_wait) = $qdbh->selectrow_array ("select timestampdiff(minute, timestamp, now()) from queue where queueid = ?", undef, $RCqueueID);

      $qdbh->do ("update queue set last_seen = now() where queueid = ?", undef, $RCqueueID);

      $qdbh->do ("update queue set last_seen = now() where queueid = ?", undef, $RCqueueID);

    }

    }

   	  use Digest::MD5 qw/md5_hex/;

   	  use Digest::MD5 qw/md5_hex/;

   	  $RCqueueID = time () ."-". md5_hex (rand ());

   	  $RCqueueID = time () ."-". md5_hex (rand ());

   	  push @queued_users, $RCqueueID;

   	  push @queued_users, $RCqueueID;

   	  $qdbh->do ("replace into queue (queueid, timestamp, last_seen) values (?, now(), now())", undef, $RCqueueID);

   	  $qdbh->do ("replace into queue (queueid, timestamp, last_seen) values (?, now(), now())", undef, $RCqueueID);

    } else {

    } else {

      $qdbh->do ("update queue set last_seen = now() where queueid = ?", undef, $RCqueueID);

      $qdbh->do ("update queue set last_seen = now() where queueid = ?", undef, $RCqueueID);

    }

    }

   	my $queue_position = inQueue ($RCqueueID, \@queued_users);

   	my $queue_position = inQueue ($RCqueueID, \@queued_users);

    if ($queue_position > ($max_users - $active_users)) {

    if ($queue_position > ($max_users - $active_users)) {

      printQueuePage ($RCqueueID, "($queue_position of ".scalar @queued_users." users)", $current_wait);

      printQueuePage ($RCqueueID, "($queue_position of ".scalar @queued_users." users)", $current_wait - $your_wait);

      exit;

      exit;

    }

    }

  }

  }