Mercurial > eagle-eye
diff Ikariam.pm @ 370:ba1643654e6d
added locking for avoid duplicated instance.
author | "Rex Tsai <chihchun@kalug.linux.org.tw>" |
---|---|
date | Tue, 14 Apr 2009 16:57:51 +0800 |
parents | d9d3cdff27c6 |
children | 5d6f429e5f19 |
line wrap: on
line diff
--- a/Ikariam.pm Thu Mar 05 17:36:03 2009 +0800 +++ b/Ikariam.pm Tue Apr 14 16:57:51 2009 +0800 @@ -110,13 +110,14 @@ use Data::Dumper; use LWP; +use Fcntl qw (:flock); use HTTP::Cookies; +use IO::Uncompress::Gunzip qw(gunzip $GunzipError) ; +use JSON;; +use POSIX; use WWW::Mechanize; use XML::LibXML qw(:encoding); use YAML qw/LoadFile Dump DumpFile/; -use IO::Uncompress::Gunzip qw(gunzip $GunzipError) ; -use POSIX; -use JSON;; use utf8; sub new @@ -133,6 +134,7 @@ user => $user, pass => $pass, debug => undef, + lock => undef, }; @@ -623,6 +625,64 @@ return $out; } +sub defendPort { + my $self = shift; + my $cityId = shift; + my $fields = shift; + + # defendDuration + $self->{mech}->get(sprintf("http://%s/index.php?view=defendPort&destinationCityId=%d", $self->{server}, $cityId)); + $self->{mech}->form_number(1); + foreach my $k (keys(%{$fields})) { + eval{ + $self->{mech}->field($k, $fields->{$k}) + }; + warn $@ if($@); + } + $self->{mech}->submit(); +} + +sub defendCity { + my $self = shift; + my $cityId = shift; + my $fields = shift; + + # defendDuration + $self->{mech}->get(sprintf("http://%s/index.php?view=defendCity&destinationCityId=%d", $self->{server}, $cityId)); + $self->{mech}->form_number(1); + foreach my $k (keys(%{$fields})) { + eval{ + $self->{mech}->field($k, $fields->{$k}) + }; + warn $@ if($@); + } + $self->{mech}->submit(); +} + +sub deploymentArmy { + my $self = shift; + my $cityId = shift; + my $fields = shift; + $self->deployment($cityId, "army", $fields); +} + +sub deployment { + my $self = shift; + my $cityId = shift; + my $type = shift; + my $fields = shift; + + $self->{mech}->get(sprintf("http://%s/index.php?view=deployment&deploymentType=%s&destinationCityId=%d", $self->{server}, $type, $cityId)); + $self->{mech}->form_number(1); + foreach my $k (keys(%{$fields})) { + eval{ + $self->{mech}->field($k, $fields->{$k}) + }; + warn $@ if($@); + } + $self->{mech}->submit(); +} + sub plunderCity { my $self = shift; my $cityId = shift; @@ -664,7 +724,6 @@ } } - sub blockadeCity { my $self = shift; my $cityId = shift; @@ -785,6 +844,7 @@ $self->{'cities'}->{$cityId}->{transporters}->{sum} = $extractor->find('//span[@id="value_transSum"]/text()'); $self->{'cities'}->{$cityId}->{transporters}->{sum} =~ s/[\(|\)]//g; $self->{'cities'}->{$cityId}->{maxActionPoints} = $extractor->find('//span[@id="value_maxActionPoints"]');; + return $self->{'cities'}->{$cityId}; } sub checkAcademy { @@ -1260,22 +1320,30 @@ { my $self = shift; $self->{mech}->get(sprintf('http://%s/index.php?action=loginAvatar&function=logout', $self->{server})); + close $self->{lock} or die "Cannot close lock file"; } sub login { my $self = shift; - my $res = $self->{mech}->post(sprintf("http://%s/index.php?action=loginAvatar&function=login", $self->{server}), [ - name => $self->{user}, - password => $self->{pass}, - ]); + # lock + open LOCKFILE, ">>.ikariam.lck" or die "Cannot open lock_file"; + flock(LOCKFILE, LOCK_EX); + $self->{lock} = \&LOCKFILE; while (1) { + + my $res = $self->{mech}->post(sprintf("http://%s/index.php?action=loginAvatar&function=login", $self->{server}), [ + name => $self->{user}, + password => $self->{pass}, + ]); + my @cities = Ikariam::Extractor->new(content => $res->content)->find('//option[@class="avatarCities coords"]/@value'); if($#cities<0) { warn ("login failed\n"); + sleep(10); next; } foreach (@cities) {