diff options
author | franck cuny <franck@lumberjaph.net> | 2010-06-28 08:18:24 +0200 |
---|---|---|
committer | franck cuny <franck@lumberjaph.net> | 2010-06-28 08:18:24 +0200 |
commit | 16fba276839729606736797a1708e63d0f898a98 (patch) | |
tree | 6ed9710264a4f698c6e3ca16ec55cfe6ee6464e0 /lib/presque | |
parent | fix (diff) | |
download | presque-worker-16fba276839729606736797a1708e63d0f898a98.tar.gz |
remove rest client; use net::presque from now
Diffstat (limited to '')
-rw-r--r-- | lib/presque/worker/Role/RESTClient.pm | 81 |
1 files changed, 0 insertions, 81 deletions
diff --git a/lib/presque/worker/Role/RESTClient.pm b/lib/presque/worker/Role/RESTClient.pm deleted file mode 100644 index 6961806..0000000 --- a/lib/presque/worker/Role/RESTClient.pm +++ /dev/null @@ -1,81 +0,0 @@ -package presque::worker::Role::RESTClient; - -use Moose::Role; - -use LWP::UserAgent; -use HTTP::Request; -use MooseX::Types::URI qw/Uri/; - -has base_uri => (is => 'ro', isa => Uri, coerce => 1, required => 1); -has ua => ( - is => 'rw', - isa => 'LWP::UserAgent', - lazy => 1, - default => sub { my $ua = LWP::UserAgent->new; $ua } -); - -sub _job_uri { - my $self = shift; - my $uri = $self->base_uri->clone; - $uri->path_segments($uri->path_segments, 'q', $self->queue_name); - $uri->query_form(worker_id => $self->worker_id); - $uri; -} - -sub _worker_uri { - my $self = shift; - my $uri = $self->base_uri->clone; - $uri->path_segments($uri->path_segments, 'w', $self->queue_name); - $uri; -} - -sub rest_register_worker { - my $self = shift; - my $request = HTTP::Request->new(POST => $self->_worker_uri); - $request->content(JSON::encode_json({worker_id => $self->worker_id})); - my $res = $self->ua->request($request); - die "can't register to ".$self->base_uri if (!$res->is_success); -} - -sub rest_unregister_worker { - my $self = shift; - my $uri = $self->_worker_uri; - $uri->query_form(worker_id => $self->worker_id); - my $request = HTTP::Request->new(DELETE => $uri); - my $res = $self->ua->request($request); -} - -sub rest_fetch_job { - my $self = shift; - - my $res = $self->ua->request(HTTP::Request->new(GET => $self->_job_uri)); - if ($res->is_success) { - return JSON::decode_json($res->content); - } - else { - $self->logger->log( - level => 'debug', - message => $res->code . ':' . $res->message - ); - } - return; -} - -sub rest_retry_job { - my ($self, $job) = @_; - - my $request = HTTP::Request->new(PUT => $self->_job_uri); - $request->header('Content-Type' => 'application/json'); - $request->content(JSON::encode_json($job)); - my $res = $self->ua->request($request); - if (!$res->is_success) { - $self->logger->log( - level => 'error', - message => 'failed to update job (' - . $res->code . ':' - . $res->message . ')', - ); - } -} - -1; |