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;
|
