summaryrefslogtreecommitdiffstats
path: root/extensions/Push/lib/Queue.pm
diff options
context:
space:
mode:
authorPerl Tidy <perltidy@bugzilla.org>2018-12-05 21:38:52 +0100
committerDylan William Hardison <dylan@hardison.net>2018-12-05 23:49:08 +0100
commit8ec8da0491ad89604700b3e29a227966f6d84ba1 (patch)
tree9d270f173330ca19700e0ba9f2ee931300646de1 /extensions/Push/lib/Queue.pm
parenta7bb5a65b71644d9efce5fed783ed545b9336548 (diff)
downloadbugzilla-8ec8da0491ad89604700b3e29a227966f6d84ba1.tar.gz
bugzilla-8ec8da0491ad89604700b3e29a227966f6d84ba1.tar.xz
no bug - reformat all the code using the new perltidy rules
Diffstat (limited to 'extensions/Push/lib/Queue.pm')
-rw-r--r--extensions/Push/lib/Queue.pm71
1 files changed, 33 insertions, 38 deletions
diff --git a/extensions/Push/lib/Queue.pm b/extensions/Push/lib/Queue.pm
index 3ee0321d9..f59423e6a 100644
--- a/extensions/Push/lib/Queue.pm
+++ b/extensions/Push/lib/Queue.pm
@@ -15,59 +15,54 @@ use Bugzilla;
use Bugzilla::Extension::Push::Message;
sub new {
- my ($class) = @_;
- my $self = {};
- bless($self, $class);
- return $self;
+ my ($class) = @_;
+ my $self = {};
+ bless($self, $class);
+ return $self;
}
sub count {
- my ($self) = @_;
- my $dbh = Bugzilla->dbh;
- return $dbh->selectrow_array("SELECT COUNT(*) FROM push");
+ my ($self) = @_;
+ my $dbh = Bugzilla->dbh;
+ return $dbh->selectrow_array("SELECT COUNT(*) FROM push");
}
sub oldest {
- my ($self) = @_;
- my @messages = $self->list(limit => 1);
- return scalar(@messages) ? $messages[0] : undef;
+ my ($self) = @_;
+ my @messages = $self->list(limit => 1);
+ return scalar(@messages) ? $messages[0] : undef;
}
sub by_id {
- my ($self, $id) = @_;
- my @messages = $self->list(
- limit => 1,
- filter => "AND (push.id = $id)",
- );
- return scalar(@messages) ? $messages[0] : undef;
+ my ($self, $id) = @_;
+ my @messages = $self->list(limit => 1, filter => "AND (push.id = $id)",);
+ return scalar(@messages) ? $messages[0] : undef;
}
sub list {
- my ($self, %args) = @_;
- $args{limit} ||= 10;
- $args{filter} ||= '';
- my @result;
- my $dbh = Bugzilla->dbh;
+ my ($self, %args) = @_;
+ $args{limit} ||= 10;
+ $args{filter} ||= '';
+ my @result;
+ my $dbh = Bugzilla->dbh;
- my $sth = $dbh->prepare("
+ my $sth = $dbh->prepare("
SELECT id, push_ts, payload, change_set, routing_key
FROM push
- WHERE (1 = 1) " .
- $args{filter} . "
- ORDER BY push_ts " .
- $dbh->sql_limit($args{limit})
- );
- $sth->execute();
- while (my $row = $sth->fetchrow_hashref()) {
- push @result, Bugzilla::Extension::Push::Message->new({
- id => $row->{id},
- push_ts => $row->{push_ts},
- payload => $row->{payload},
- change_set => $row->{change_set},
- routing_key => $row->{routing_key},
- });
- }
- return @result;
+ WHERE (1 = 1) " . $args{filter} . "
+ ORDER BY push_ts " . $dbh->sql_limit($args{limit}));
+ $sth->execute();
+ while (my $row = $sth->fetchrow_hashref()) {
+ push @result,
+ Bugzilla::Extension::Push::Message->new({
+ id => $row->{id},
+ push_ts => $row->{push_ts},
+ payload => $row->{payload},
+ change_set => $row->{change_set},
+ routing_key => $row->{routing_key},
+ });
+ }
+ return @result;
}
1;