lib/System/Introspector/Report/Publish/MediaWiki.pm

   1 package System::Introspector::Report::Publish::MediaWiki;
   2 use Moo;
   3 use Try::Tiny;
   4 use Log::Contextual qw( :log );
   5 use aliased 'System::Introspector::Report::Publish::MediaWiki::Connection';
   6
   7 has page_options => (
   8   is => 'ro',
   9   default => sub { {} },
  10   init_arg => 'page',
  11 );
  12
  13 has connection => (is => 'ro', lazy => 1, builder => 1, handles => {
  14   get_page => 'get',
  15   put_page => 'put',
  16 });
  17
  18 has api_uri         => (is => 'ro', required => 1);
  19 has username        => (is => 'ro', required => 1);
  20 has password        => (is => 'ro', required => 1);
  21 has allow_create    => (is => 'ro', default => sub { 0 });
  22 has http_auth       => (is => 'ro');
  23 has http_realm      => (is => 'ro');
  24
  25 sub _build_producer { Producer->new }
  26
  27 sub _build_connection {
  28   my ($self) = @_;
  29   return Connection->new(
  30     api_uri         => $self->api_uri,
  31     username        => $self->username,
  32     password        => $self->password,
  33     allow_create    => $self->allow_create,
  34     $self->http_auth ? (
  35       http_auth  => 1,
  36       http_realm => $self->http_realm,
  37     ) : (),
  38   );
  39 }
  40
  41 sub publish {
  42   my ($self, $reports) = @_;
  43   my $pages = $self->page_options;
  44   log_info { "Pushing reports to MediaWiki at '%s'", $self->api_uri };
  45   for my $page (sort keys %$pages) {
  46     $self->_publish_page($reports, $page, $pages->{$page});
  47   }
  48   log_info { "Finished pushing to MediaWiki" };
  49   return 1;
  50 }
  51
  52 sub _sort_reports {
  53   my ($self, $reports, $included) = @_;
  54   my @matchers = map {
  55     $self->_prepare_matcher_from($_);
  56   } ref($included) ? @{$included} : $included;
  57   my @grouped;
  58   for my $report (@$reports) {
  59     my ($group_idx) = grep {
  60       $self->_match_id($report, $matchers[$_]);
  61     } 0 .. $#matchers;
  62     if (defined $group_idx) {
  63       push @{$grouped[$group_idx]}, $report;
  64     }
  65   }
  66   return [ map { (@$_) } @grouped ];
  67 }
  68
  69 sub _publish_dynamic {
  70   my ($self, $reports, $page_name, $key, $options) = @_;
  71   my %reports_by_key;
  72   for my $report (@$reports) {
  73     my $value = $report->{meta}{$key};
  74     next unless defined $value;
  75     push @{ $reports_by_key{$value} ||= [] }, $report;
  76   }
  77   for my $value (keys %reports_by_key) {
  78     (my $effective_page = $page_name)
  79       =~ s{\%\(meta:\Q$key\E\)}{$value};
  80     my $assoc = $reports_by_key{$value};
  81     $self->_publish_page($assoc, $effective_page, $options);
  82   }
  83   return 1;
  84 }
  85
  86 sub _publish_page {
  87   my ($self, $reports, $page_name, $options) = @_;
  88   if ($page_name =~ m{\%\(meta:(.+?)\)}) {
  89     return $self->_publish_dynamic($reports, $page_name, $1, $options);
  90   }
  91   my $sorted = $self->_sort_reports($reports, $options->{report} || []);
  92   unless (scalar @$sorted) {
  93     log_trace { "Skipping page '$page_name': No reports to publish" };
  94     return 1;
  95   }
  96   log_debug { "Updating page '$page_name'" };
  97   my $do_create = $options->{create};
  98   return try {
  99     my $page = $self->get_page($page_name);
 100     if ($page->is_new and not $do_create) {
 101       log_trace { "Skipping page '$page_name': Does not yet exist" };
 102       return 1;
 103     }
 104     my $is_changed = $page->update($sorted);
 105     unless ($is_changed) {
 106       log_trace { "Not pushing page '$page_name': No changes" };
 107       return 1;
 108     }
 109     $self->put_page($page);
 110     return 1;
 111   }
 112   catch {
 113     log_error { "Error during page update: $_" };
 114     return 1;
 115   };
 116 }
 117
 118 with $_ for qw(
 119   System::Introspector::Report::Publish::API
 120 );
 121
 122 1;