1 package System::Introspector::Report::Publish::MediaWiki;
4 use Log::Contextual::WarnLogger;
5 use Log::Contextual qw( :log ),
6 -default_logger => Log::Contextual::WarnLogger->new({
7 env_prefix => 'SI_REPORT_MEDIAWIKI',
8 levels => [qw( error fatal warn )],
11 use aliased 'System::Introspector::Report::Publish::MediaWiki::Connection';
15 default => sub { {} },
19 has connection => (is => 'ro', lazy => 1, builder => 1, handles => {
24 has api_uri => (is => 'ro', required => 1);
25 has username => (is => 'ro', required => 1);
26 has password => (is => 'ro', required => 1);
27 has allow_create => (is => 'ro', default => sub { 0 });
28 has http_auth => (is => 'ro');
29 has http_realm => (is => 'ro');
31 sub _build_producer { Producer->new }
33 sub _build_connection {
35 return Connection->new(
36 api_uri => $self->api_uri,
37 username => $self->username,
38 password => $self->password,
39 allow_create => $self->allow_create,
42 http_realm => $self->http_realm,
48 my ($self, $reports) = @_;
49 my $pages = $self->page_options;
51 sprintf "Pushing reports to MediaWiki at '%s'", $self->api_uri;
53 for my $page (sort keys %$pages) {
54 $self->_publish_page($reports, $page, $pages->{$page});
56 log_info { "Finished pushing to MediaWiki" };
61 my ($self, $reports, $included) = @_;
63 $self->_prepare_matcher_from($_);
64 } ref($included) ? @{$included} : $included;
66 for my $report (@$reports) {
67 my ($group_idx) = grep {
68 $self->_match_id($report, $matchers[$_]);
70 if (defined $group_idx) {
71 push @{$grouped[$group_idx]}, $report;
74 return [ map { (@$_) } @grouped ];
77 sub _publish_dynamic {
78 my ($self, $reports, $page_name, $key, $options) = @_;
80 for my $report (@$reports) {
81 my $value = $report->{meta}{$key};
82 next unless defined $value;
83 push @{ $reports_by_key{$value} ||= [] }, $report;
85 for my $value (keys %reports_by_key) {
86 (my $effective_page = $page_name)
87 =~ s{\%\(meta:\Q$key\E\)}{$value};
88 my $assoc = $reports_by_key{$value};
89 $self->_publish_page($assoc, $effective_page, $options);
95 my ($self, $reports, $page_name, $options) = @_;
96 if ($page_name =~ m{\%\(meta:(.+?)\)}) {
97 return $self->_publish_dynamic($reports, $page_name, $1, $options);
99 my $sorted = $self->_sort_reports($reports, $options->{report} || []);
100 unless (scalar @$sorted) {
101 log_debug { "Skipping page '$page_name': No reports to publish" };
104 my $do_create = $options->{create};
106 my $page = $self->get_page($page_name);
107 if ($page->is_new and not $do_create) {
108 log_trace { "Skipping page '$page_name': Does not yet exist" };
111 my $is_changed = $page->update($sorted);
112 unless ($is_changed) {
113 log_debug { "Not pushing page '$page_name': No changes" };
116 log_debug { "Updating page '$page_name'" };
117 $self->put_page($page);
121 log_error { "Error during page update: $_" };
127 System::Introspector::Report::Publish::API