summaryrefslogtreecommitdiffstats
path: root/extensions/Push/lib/Admin.pm
blob: f579409bd7e8e72a1fc5ee8190a374bffc801c3f (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
# 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::Admin;

use strict;
use warnings;

use Bugzilla;
use Bugzilla::Error;
use Bugzilla::Extension::Push::Util;
use Bugzilla::Util qw(trim detaint_natural trick_taint);

use base qw(Exporter);
our @EXPORT = qw(
    admin_config
    admin_queues
    admin_log
);

sub admin_config {
    my ($vars) = @_;
    my $push = Bugzilla->push_ext;
    my $input = Bugzilla->input_params;

    if ($input->{save}) {
        my $dbh = Bugzilla->dbh;
        $dbh->bz_start_transaction();
        _update_config_from_form('global', $push->config);
        foreach my $connector ($push->connectors->list) {
            _update_config_from_form($connector->name, $connector->config);
        }
        $push->set_config_last_modified();
        $dbh->bz_commit_transaction();
        $vars->{message} = 'push_config_updated';
    }

    $vars->{push} = $push;
    $vars->{connectors} = $push->connectors;
}

sub _update_config_from_form {
    my ($name, $config) = @_;
    my $input = Bugzilla->input_params;

    # read values from form
    my $values = {};
    foreach my $option ($config->options) {
        my $option_name = $option->{name};
        $values->{$option_name} = trim($input->{$name . ".$option_name"});
    }

    # validate
    if ($values->{enabled} eq 'Enabled') {
        eval {
            $config->validate($values);
        };
        if ($@) {
            ThrowUserError('push_error', { error_message => clean_error($@) });
        }
    }

    # update
    foreach my $option ($config->options) {
        my $option_name = $option->{name};
        trick_taint($values->{$option_name});
        $config->{$option_name} = $values->{$option_name};
    }
    $config->update();
}

sub admin_queues {
    my ($vars, $page) = @_;
    my $push = Bugzilla->push_ext;
    my $input = Bugzilla->input_params;

    if ($page eq 'push_queues.html') {
        $vars->{push} = $push;

    } elsif ($page eq 'push_queues_view.html') {
        my $queue;
        if ($input->{connector}) {
            my $connector = $push->connectors->by_name($input->{connector})
                || ThrowUserError('push_error', { error_message => 'Invalid connector' });
            $queue = $connector->backlog;
        } else {
            $queue = $push->queue;
        }
        $vars->{queue} = $queue;

        my $id = $input->{message} || 0;
        detaint_natural($id)
            || ThrowUserError('push_error', { error_message => 'Invalid message ID' });
        my $message = $queue->by_id($id)
            || ThrowUserError('push_error', { error_message => 'Invalid message ID' });

        if ($input->{delete}) {
            $message->remove_from_db();
            $vars->{message} = 'push_message_deleted';

        } else {
            $vars->{message_obj} = $message;
            eval {
                $vars->{json} = to_json($message->payload_decoded, 1);
            };
        }
    }
}

sub admin_log {
    my ($vars) = @_;
    my $push = Bugzilla->push_ext;
    my $input = Bugzilla->input_params;

    $vars->{push} = $push;
}

1;