File Coverage

blib/lib/App/bif/log/topic.pm

Criterion	Covered	Total	%
statement	15	29	51.7
branch			n/a
condition			n/a
subroutine	5	5	100.0
pod	1	1	100.0
total	21	35	60.0

package App::bif::log::topic;
use strict;
use warnings;
use feature 'state';
use Bif::Mo;

our $VERSION = '0.1.5_6';
extends 'App::bif::log';

sub run {
    my $self = shift;
    my $opts = $self->opts;
    my $db   = $self->db;
    my $info = $self->get_node( $opts->{id}, 'topic' );

    state $have_dbix = DBIx::ThinSQL->import(qw/ qv concat coalesce/);
    my $now = $self->now;

    my $sth = $db->xprepare(
        select => [
            'ltd.topic_id AS id',
            'n.uuid AS uuid',
            concat( qv('c'), 'ltd.change_id' )->as('change_id'),
            'c.uuid AS change_uuid',
            'ltd.title',
            'c.mtime AS mtime',
            "c.mtimetz AS mtimetz",
            'c.mtimetzhm AS mtimetzhm',
            "$now - c.mtime AS mtime_age",
            'c.action',
            'COALESCE(c.author,e.name) AS author',
            "COALESCE(c.author_contact_method || ': ' || "
              . "c.author_contact, ecm.method || ': ' || "
              . "ecm.mvalue) AS contact",
            'ts.status',
            'ts.status',
            'p.title AS project_title',
            'ct.depth',
            'c.message',
        ],
        from       => 'topics t',
        inner_join => 'link_topic_deltas ltd',
        on         => 'ltd.link_topic_id = t.link_topic_id',
        inner_join => 'changes c',
        on         => 'c.id = ltd.change_id',
        inner_join => 'entities e',
        on         => 'e.id = c.identity_id',
        inner_join => 'entity_contact_methods ecm',
        on         => 'ecm.id = e.default_contact_method_id',
        inner_join => 'nodes n',
        on         => 'n.id = t.id',
        left_join  => 'topic_status ts',
        on         => 'ts.id = ltd.topic_status_id',
        left_join  => 'projects p',
        on         => 'p.id = ts.project_id',
        left_join  => 'hubs h',
        on         => 'h.id = p.default_hub_id',
        inner_join => 'changes_tree ct',
        on         => {
            'ct.parent' => $info->{first_change_id},
            'ct.child'  => \'ltd.change_id'
        },
        where    => { 't.id' => $info->{id} },
        order_by => 'c.path ASC',
    );

    $sth->execute;

    $self->start_pager;

    my $first = $sth->hashref;
    $first->{ctime}     = $first->{mtime};
    $first->{ctimetz}   = $first->{mtimetz};
    $first->{ctimetzhm} = $first->{mtimetzhm};
    $first->{ctime_age} = $first->{mtime_age};
    $self->log_item( $first, 'topic' );

    $self->log_comment($_) for $sth->hashrefs;

    return $self->ok( 'Log' . ucfirst( $info->{tkind} ) );
}

1;
__END__