Bug 1371464 - Delete code for Aha push connector

* Add install_update_db to Extension.pm

2 files changed, 9 insertions, 183 deletions

diff --git a/extensions/Push/Extension.pm b/extensions/Push/Extension.pm
index f682dea35..a5ec24639 100644
--- a/extensions/Push/Extension.pm
+++ b/extensions/Push/Extension.pm
@@ -656,4 +656,13 @@ sub db_sanitize {
     $dbh->do("DELETE FROM push_options");
 }
 
+
+sub install_update_db {
+    my $dbh = Bugzilla->dbh;
+    $dbh->do("DELETE FROM push_options WHERE connector = ?", undef, "Aha");
+    $dbh->do("DELETE FROM push_log WHERE connector = ?", undef, "Aha");
+    $dbh->do("DELETE FROM push_backlog WHERE connector = ?", undef, "Aha");
+    $dbh->do("DELETE FROM push_backoff WHERE connector = ?", undef, "Aha");
+}
+
 __PACKAGE__->NAME;
diff --git a/extensions/Push/lib/Connector/Aha.pm b/extensions/Push/lib/Connector/Aha.pm
deleted file mode 100644
index e85b5fadf..000000000
--- a/extensions/Push/lib/Connector/Aha.pm
+++ /dev/null
@@ -1,183 +0,0 @@
-# This Source Code Form is subject to the terms of the Mozilla Public
-# License, v. 2.0. If a copy of the MPL was not distributed with this
-# file, You can obtain one at http://mozilla.org/MPL/2.0/.
-#
-# This Source Code Form is "Incompatible With Secondary Licenses", as
-# defined by the Mozilla Public License, v. 2.0.
-
-package Bugzilla::Extension::Push::Connector::Aha;
-
-use 5.10.1;
-use strict;
-use warnings;
-
-use base 'Bugzilla::Extension::Push::Connector::Base';
-
-use Bugzilla::Constants;
-use Bugzilla::Extension::Push::Constants;
-use Bugzilla::Extension::Push::Util;
-use Bugzilla::Bug;
-use Bugzilla::Attachment;
-use Bugzilla::BugUrl::Aha;
-
-use DateTime;
-use JSON 'decode_json', 'encode_json';
-use LWP::UserAgent;
-
-BEGIN {
-    unless (LWP::UserAgent->can("put")) {
-        *LWP::UserAgent::put = sub {
-            require HTTP::Request::Common;
-            my($self, @parameters) = @_;
-            my @suff = $self->_process_colonic_headers(\@parameters, (ref($parameters[1]) ? 2 : 1));
-            return $self->request( HTTP::Request::Common::PUT( @parameters ), @suff );
-        };
-    }
-}
-
-sub options {
-    return (
-        {
-            name     => 'account_domain',
-            label    => 'Account domain for Aha',
-            type     => 'string',
-            default  => 'bugzilla.aha.io',
-            required => 1,
-        },
-        {
-            name     => 'account_realm',
-            label    => 'Aha! auth realm',
-            type     => 'string',
-            default  => 'Aha! API',
-            required => 1,
-        },
-        {
-            name     => 'username',
-            label    => 'Username',
-            type     => 'string',
-            default  => 'guest',
-            required => 1,
-        },
-        {
-            name     => 'password',
-            label    => 'Password',
-            type     => 'password',
-            default  => 'guest',
-            required => 1,
-        },
-    );
-}
-
-sub stop {
-    my ($self) = @_;
-}
-
-sub should_send {
-    my ($self, $message) = @_;
-
-    if ($message->routing_key =~ /^bug\.modify:.*\bbug_status\b/) {
-        my $payload = $message->payload_decoded();
-        my $target  = $payload->{event}->{target};
-        my $bug     = $payload->{$target};
-
-        return $bug->{status}{name} eq 'RESOLVED' && $bug->{resolution} eq 'FIXED';
-    }
-    else {
-        # We're not interested in the message.
-        return 0;
-    }
-}
-
-sub _user_agent {
-    my ($self) = @_;
-
-    my $ua = LWP::UserAgent->new(agent => 'Bugzilla');
-    $ua->timeout(10);
-    $ua->protocols_allowed(['http', 'https']);
-    if (my $proxy_url = Bugzilla->params->{proxy_url}) {
-        $ua->proxy(['http', 'https'], $proxy_url);
-    }
-    else {
-        $ua->env_proxy();
-    }
-
-    $ua->credentials($self->config->{account_domain} . ":443",
-                     $self->config->{account_realm},
-                     $self->config->{username},
-                     $self->config->{password});
-    return $ua;
-}
-
-sub _aha_uri {
-    my ($self, $path) = @_;
-
-    return URI->new("https://" . $self->config->{account_domain} . "/" . $path);
-}
-
-sub _aha_feature_uri {
-    my ($self, $feature_id) = @_;
-
-    return $self->_aha_uri("api/v1/features/$feature_id");
-}
-
-sub _aha_update_feature {
-    my ($self, $feature_id, $workflow_status) = @_;
-    my $feature_uri = $self->_aha_feature_uri($feature_id);
-    my $ua          = $self->_user_agent;
-    my $content     = encode_json({ workflow_status => $workflow_status });
-    my $resp        = $ua->put($feature_uri, 'Content-Type' => 'application/json', Content => $content);
-
-    if ($resp->code != 200) {
-        die "Expected HTTP 200 resposne, got " . $resp->code;
-    }
-}
-
-sub _aha_get_feature {
-    my ($self, $feature_id) = @_;
-    my $feature_uri = $self->_aha_feature_uri($feature_id);
-    my $resp        = $self->_user_agent->get($feature_uri);
-
-    if ($resp->code == 200) {
-        my $result = eval { decode_json($resp->content) };
-        if ($@) {
-            die "Unable to parse JSON";
-        }
-        return $result;
-    }
-    else {
-        die "Expected HTTP 200 resposne, got " . $resp->code;
-    }
-}
-
-sub send {
-    my ($self, $message) = @_;
-    my $logger = Bugzilla->push_ext->logger;
-    my $config = $self->config;
-
-    eval {
-        my $payload = $message->payload_decoded();
-        my $target  = $payload->{event}->{target};
-        my $bug     = Bugzilla::Bug->check($payload->{$target}->{id});
-        foreach my $see_also (@{ $bug->see_also }) {
-            if ($see_also->isa('Bugzilla::BugUrl::Aha')) {
-                my $feature_id = $see_also->get_feature_id;
-                my $feature = $self->_aha_get_feature($feature_id);
-                if ($feature->{error}) {
-                    next;
-                }
-
-                unless (lc($feature->{feature}{workflow_status}{name}) eq 'shipped') {
-                    $self->_aha_update_feature($feature_id, "Ready to ship");
-                }
-            }
-        }
-    };
-    if ($@) {
-        return (PUSH_RESULT_TRANSIENT, clean_error($@));
-    }
-
-    return PUSH_RESULT_OK;
-}
-
-
-1;