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;