lib/NDWeb/Controller/JSRPC.pm

   1 package NDWeb::Controller::JSRPC;
   2
   3 use strict;
   4 use warnings;
   5 use parent 'Catalyst::Controller';
   6
   7 use DateTime::TimeZone;
   8
   9 =head1 NAME
  10
  11 NDWeb::Controller::JSRPC - Catalyst Controller
  12
  13 =head1 DESCRIPTION
  14
  15 Catalyst Controller.
  16
  17 =head1 METHODS
  18
  19 =cut
  20
  21
  22 =head2 index
  23
  24 =cut
  25
  26 sub index :Path :Args(0) {
  27         my ( $self, $c ) = @_;
  28
  29         $c->response->body('Matched NDWeb::Controller::JSRPC in JSRPC.');
  30 }
  31
  32 sub update : Local {
  33         my ($self, $c, $raid, $from, $target) = @_;
  34         my $dbh = $c->model;
  35
  36         $c->forward('/raids/findRaid');
  37         $raid = $c->stash->{raid};
  38
  39         my $targets;;
  40         if ($from){
  41                 my ($timestamp) = $dbh->selectrow_array("SELECT MAX(modified)::timestamp AS modified FROM raid_targets");
  42                 $c->stash(timestamp => $timestamp);
  43                 $targets = $dbh->prepare(q{SELECT r.id,r.planet FROM raid_targets r
  44                         WHERE r.raid = ? AND modified > ?
  45                 });
  46                 $targets->execute($raid->{id},$from);
  47         }elsif($target){
  48                 $targets = $dbh->prepare(q{SELECT r.id,r.planet FROM raid_targets r
  49                         WHERE r.raid = $1 AND r.id = $2
  50                 });
  51                 $targets->execute($raid->{id},$target);
  52         }
  53
  54         my $claims =  $dbh->prepare(qq{ SELECT username,joinable,launched FROM raid_claims
  55                 NATURAL JOIN users WHERE target = ? AND wave = ?});
  56         my @targets;
  57         while (my $target = $targets->fetchrow_hashref){
  58                 my %target;
  59                 $target{id} = $target->{id};
  60                 my @waves;
  61                 for (my $i = 1; $i <= $raid->{waves}; $i++){
  62                         my %wave;
  63                         $wave{id} = $i;
  64                         $claims->execute($target->{id},$i);
  65                         my $joinable = 0;
  66                         my $claimers;
  67                         if ($claims->rows != 0){
  68                                 my $owner = 0;
  69                                 my @claimers;
  70                                 while (my $claim = $claims->fetchrow_hashref){
  71                                         $owner = 1 if ($c->user->username eq $claim->{username});
  72                                         $joinable = 1 if ($claim->{joinable});
  73                                         $claim->{username} .= '*' if ($claim->{launched});
  74                                         push @claimers,$claim->{username};
  75                                 }
  76                                 $claimers = join '/', @claimers;
  77                                 if ($owner){
  78                                         $wave{command} = 'unclaim';
  79                                 }elsif ($joinable){
  80                                         $wave{command} = 'join';
  81                                 }else{
  82                                         $wave{command} = 'taken';
  83                                 }
  84                         }else{
  85                                 $wave{command} = 'claim';
  86                         }
  87                         $wave{claimers} = $claimers;
  88                         $wave{joinable} = $joinable;
  89                         push @waves,\%wave;
  90                 }
  91                 $target{waves} = \@waves;
  92                 push @targets,\%target;
  93         }
  94         $c->stash(targets => \@targets);
  95
  96 }
  97
  98 sub claim : Local {
  99         my ($self, $c, $raid, $from, $target, $wave) = @_;
 100         my $dbh = $c->model;
 101
 102         $dbh->begin_work;
 103         $c->forward('assertTarget');
 104
 105         my $claims = $dbh->prepare(qq{SELECT username FROM raid_claims
 106                 NATURAL JOIN users WHERE target = ? AND wave = ?
 107                 });
 108         $claims->execute($target,$wave);
 109         if ($claims->rows == 0){
 110                 my $query = $dbh->prepare(q{INSERT INTO raid_claims (target,uid,wave) VALUES(?,?,?)});
 111                 $query->execute($target,$c->user->id,$wave);
 112                 $c->forward('/raids/log',[$raid, "Claimed target $target wave $wave"]);
 113                 $c->forward('/listTargets');
 114         }
 115         $dbh->commit;
 116
 117         $c->stash(template => 'jsrpc/update.tt2');
 118         $c->forward('update');
 119 }
 120
 121
 122 sub join : Local {
 123         my ($self, $c, $raid, $from, $target, $wave) = @_;
 124         my $dbh = $c->model;
 125
 126         $dbh->begin_work;
 127         $c->forward('assertTarget');
 128
 129         my $claims = $dbh->prepare(q{SELECT username FROM raid_claims
 130                 NATURAL JOIN users WHERE target = ? AND wave = ? AND joinable = TRUE
 131                 });
 132         $claims->execute($target,$wave);
 133         if ($claims->rows != 0){
 134                 my $query = $dbh->prepare(q{INSERT INTO raid_claims (target,uid,wave,joinable)
 135                         VALUES(?,?,?,TRUE)
 136                 });
 137                 $query->execute($target,$c->user->id,$wave);
 138                 $c->forward('/raids/log',[$raid, "Joined target $target wave $wave"]);
 139                 $c->forward('/listTargets');
 140         }
 141         $dbh->commit;
 142
 143         $c->stash(template => 'jsrpc/update.tt2');
 144         $c->forward('update');
 145 }
 146
 147 sub unclaim : Local {
 148         my ($self, $c, $raid, $from, $target, $wave) = @_;
 149         my $dbh = $c->model;
 150
 151         $dbh->begin_work;
 152         my $query = $dbh->prepare(q{DELETE FROM raid_claims WHERE target = ?
 153                 AND uid = ? AND wave = ?
 154                 });
 155         $query->execute($target,$c->user->id,$wave);
 156         $c->forward('/raids/log',[$raid, "Unclaimed target $target wave $wave"]);
 157         $dbh->commit;
 158
 159         $c->stash(template => 'jsrpc/update.tt2');
 160         $c->forward('/listTargets');
 161         $c->forward('update');
 162 }
 163
 164 sub joinable : Local {
 165         my ($self, $c, $raid, $from, $target, $wave,$joinable) = @_;
 166         my $dbh = $c->model;
 167
 168         my $claims = $dbh->prepare(q{SELECT username FROM raid_claims NATURAL JOIN users
 169                 WHERE target = ? AND wave = ? AND uid = ?
 170                 });
 171         $claims->execute($target,$wave,$c->user->id);
 172         if ($claims->rows != 0){
 173                 my $query = $dbh->prepare(q{UPDATE raid_claims SET joinable = NOT ?
 174                         WHERE target = ? AND wave = ?
 175                 });
 176                 $query->execute($joinable,$target,$wave);
 177                 $c->forward('/listTargets');
 178         }
 179
 180         $c->stash(template => 'jsrpc/update.tt2');
 181         $c->forward('/listTargets');
 182         $c->forward('update');
 183 }
 184
 185 sub listTargets : Local {
 186         my ($self, $c) = @_;
 187
 188         $c->stash(template => 'jsrpc/update.tt2');
 189         $c->forward('/listTargets');
 190 }
 191
 192 sub tzcountries : Local {
 193         my ($self, $c, $cat) = @_;
 194
 195         my @countries = DateTime::TimeZone->names_in_category($cat);
 196         $c->stash(tzcountries => \@countries);
 197 }
 198
 199 sub access_denied : Private {
 200         my ($self, $c) = @_;
 201         $c->stash(template => 'jsrpc/access_denied.tt2');
 202         $c->res->status(403);
 203 }
 204
 205 sub assertTarget : Private {
 206         my ($self, $c, $raid, $from, $target, $wave) = @_;
 207         my $dbh = $c->model;
 208
 209         my $findtarget = $dbh->prepare(q{SELECT rt.id FROM raid_targets rt
 210                 NATURAL JOIN raid_access ra NATURAL JOIN groupmembers
 211                 WHERE uid = ? AND id = ?
 212                 FOR UPDATE
 213         });
 214
 215         my $result = $dbh->selectrow_array($findtarget,undef,$c->user->id,$target);
 216         if ($result != $target){
 217                 $dbh->rollback;
 218                 die 'Access denied';
 219         }
 220 }
 221
 222 sub end : ActionClass('RenderView') {
 223         my ($self,$c) = @_;
 224         $c->res->content_type('application/xml');
 225
 226         if (scalar @{ $c->error } ){
 227                 if ($c->error->[0] =~ m/Can't call method "id" on an undefined value at/){
 228                         $c->stash->{template} = 'jsrpc/access_denied.tt2';
 229                         $c->res->status(403);
 230                         $c->clear_errors;
 231                 }elsif ($c->error->[0] =~ m/Missing roles: /){
 232                         $c->stash->{template} = 'jsrpc/access_denied.tt2';
 233                         $c->res->status(403);
 234                         $c->clear_errors;
 235                 }
 236         }
 237 }
 238
 239 =head1 AUTHOR
 240
 241 Michael Andreen (harv@ruin.nu)
 242
 243 =head1 LICENSE
 244
 245 GPL 2.0, or later
 246
 247 =cut
 248
 249 1;