File Coverage

blib/lib/Bif/DB/Plugin/ChangeUUIDv1.pm

Criterion	Covered	Total	%
statement	31	56	55.3
branch	2	8	25.0
condition	4	20	20.0
subroutine	4	5	80.0
pod			n/a
total	41	89	46.0

package Bif::DB::Plugin::ChangeUUIDv1;
use strict;
use warnings;
use DBIx::ThinSQL qw/case qv/;

our $VERSION = '0.1.5_6';

our %statements = (
    new_hub => [
        select => [
            '"new_hub" AS _delta',
            'hd.location AS location',
            'n.uuid AS uuid',
        ],
        from       => 'hub_deltas hd',
        inner_join => 'nodes n',
        on         => 'n.id = hd.hub_id',
        where      => 'hd.id = ?',
    ],

    update_hub => [
        select => [
            '"update_hub" AS _delta',
            'nd.name AS name',
            'pd.title AS title',
            'n.uuid AS uuid',
        ],
        from       => 'project_deltas pd',
        inner_join => 'node_deltas nd',
        on         => 'nd.id = pd.id',
        inner_join => 'nodes n',
        on         => 'n.id = pd.project_id',
        where      => 'pd.id = ?',
    ],

    new_hub_repo => [
        select => [
            '"new_hub_repo" AS _delta',
            'h.uuid AS hub_uuid',
            'hrd.location AS location',
            'hr.uuid AS uuid',
        ],
        from       => 'hub_repo_deltas hrd',
        inner_join => 'nodes hr',
        on         => 'hr.id = hrd.hub_repo_id',
        left_join  => 'nodes h',
        on         => 'h.id = hrd.hub_id',
        where      => 'hrd.id = ?',
    ],

    update_hub_repo => [
        select => [
            '"update_hub_repo" AS _delta',
            'h.uuid AS hub_uuid',    # should never change, remove?
            'hrd.location AS location',
            'hr.uuid AS uuid',
        ],
        from       => 'hub_repo_deltas hrd',
        inner_join => 'nodes hr',
        on         => 'hr.id = hrd.hub_repo_id',
        left_join  => 'nodes h',
        on         => 'h.id = hrd.hub_id',
        where      => 'hrd.id = ?',
    ],

    new_identity => [
        select => [
            '"new_identity" AS _delta',
            'ed.name AS name',
            'id.shortname AS shortname',
            'con.uuid AS contact_uuid',
            'dcm.uuid AS default_contact_method_uuid',
            'i.uuid AS uuid',
        ],
        from       => 'identity_deltas id',
        inner_join => 'entity_deltas ed',
        on         => 'ed.id = id.id',
        inner_join => 'nodes i',
        on         => 'i.id = id.identity_id',
        left_join  => 'nodes con',
        on         => 'con.id = ed.contact_id',
        left_join  => 'nodes dcm',
        on         => 'dcm.id = ed.default_contact_method_id',
        where      => 'id.id = ?',
    ],

    update_identity => [
        select => [
            '"update_identity" AS _delta',
            'n.uuid AS uuid',
            'ed.name AS name',
            'id.shortname AS shortname',
            'con.uuid AS contact_uuid',
            'dcm.uuid AS default_contact_method_uuid',
        ],
        from       => 'identity_deltas id',
        inner_join => 'entity_deltas ed',
        on         => 'ed.id = id.id',
        inner_join => 'nodes n',
        on         => 'n.id = id.identity_id',
        left_join  => 'nodes con',
        on         => 'con.id = ed.contact_id',
        left_join  => 'nodes dcm',
        on         => 'dcm.id = ed.default_contact_method_id',
        where      => 'id.id = ?',
    ],

    new_identity_contact_method => [
        select => [
            '"new_identity_contact_method" AS _delta',
            'i.uuid AS identity_uuid',
            'ecmd.method AS method',
            'ecmd.mvalue AS mvalue',
            'ecmn.uuid AS uuid',
        ],
        from       => 'entity_contact_method_deltas ecmd',
        inner_join => 'entity_contact_methods ecm',
        on         => 'ecm.id = ecmd.entity_contact_method_id',
        inner_join => 'nodes ecmn',
        on         => 'ecmn.id = ecm.id',
        inner_join => 'nodes i',
        on         => 'i.id = ecm.entity_id',
        where      => 'ecmd.id = ?',
    ],

    update_identity_contact_method => [
        select => [
            'n.uuid AS identity_contact_method_uuid',
            'ecmd.method AS method',
            'ecmd.mvalue AS mvalue',
        ],
        from       => 'entity_contact_method_deltas ecmd',
        inner_join => 'nodes n',
        on         => 'n.id = ecmd.id',
        where      => 'ecmd.id = ?',
    ],

    new_project => [
        select => [
            '"new_project" AS _delta',
            'nd.name AS name',
            'pp.uuid AS parent_uuid',
            'pd.title AS title',
            'p.uuid AS uuid',
        ],
        from       => 'project_deltas pd',
        inner_join => 'node_deltas nd',
        on         => 'nd.id = pd.id',
        inner_join => 'nodes p',
        on         => 'p.id = pd.project_id',
        left_join  => 'nodes pp',
        on         => 'pp.id = nd.parent_id',
        where      => 'pd.id = ?',
    ],

    update_project => [
        select => [
            '"update_project" AS _delta',
            'h.uuid AS hub_uuid',
            'nd.name AS name',
            'pp.uuid AS parent_uuid',
            'ps.uuid AS project_status_uuid',
            'pd.title AS title',
            'p.uuid AS uuid',
        ],
        from       => 'project_deltas pd',
        inner_join => 'node_deltas nd',
        on         => 'nd.id = pd.id',
        inner_join => 'nodes p',
        on         => 'p.id = pd.project_id',
        left_join  => 'nodes ps',
        on         => 'ps.id = pd.project_status_id',
        left_join  => 'nodes pp',
        on         => 'pp.id = nd.parent_id',
        left_join  => 'nodes h',
        on         => 'h.id = pd.hub_id',
        where      => 'pd.id = ?',
    ],

    new_project_status => [
        select => [
            '"new_project_status" AS _delta',
            'p.uuid AS project_uuid',
            'psd.rank AS rank',
            'psd.status AS status',
            'n.uuid AS uuid',
        ],
        from       => 'project_status_deltas psd',
        inner_join => 'project_status ps',
        on         => 'ps.id = psd.project_status_id',
        inner_join => 'nodes n',
        on         => 'n.id = ps.id',
        inner_join => 'nodes p',
        on         => 'p.id = ps.project_id',
        where      => 'psd.id = ?',
    ],

    update_project_status => [
        select => [
            '"update_project_status" AS _delta',
            'psd.rank AS rank',
            'psd.status AS status',
            'ps.uuid AS uuid',
        ],
        from       => 'project_status_deltas psd',
        inner_join => 'nodes ps',
        on         => 'ps.id = psd.project_status_id',
        where      => 'psd.id = ?',
    ],

    new_link_topic => [
        select     => [ '"new_link_topic" AS _delta', 'n.uuid AS uuid', ],
        from       => 'node_deltas nd',
        inner_join => 'nodes n',
        on         => 'n.id = nd.node_id',
        where      => 'nd.id = ?',
    ],

    new_topic => [
        select => [
            '"new_topic" AS _delta',
            'ts.uuid AS topic_status_uuid',
            'lt.uuid AS link_topic_uuid',
            'ltd.title AS title',
            't.tkind AS tkind',
            'p.uuid AS project_uuid',
            'n.uuid AS uuid',
        ],
        from       => 'link_topic_deltas ltd',
        inner_join => 'nodes n',
        on         => 'n.id = ltd.topic_id',
        inner_join => 'topics t',
        on         => 't.id = ltd.topic_id',
        inner_join => 'nodes lt',
        on         => 'lt.id = t.link_topic_id',
        inner_join => 'nodes p',
        on         => 'p.id = t.project_id',
        inner_join => 'nodes ts',
        on         => 'ts.id = ltd.topic_status_id',
        where      => 'ltd.id = ?',
    ],

    update_topic => [
        select => [
            '"update_topic" AS _delta',
            'ts.uuid AS topic_status_uuid',
            'ltd.title AS title',
            'n.uuid AS uuid',
        ],
        from       => 'link_topic_deltas ltd',
        inner_join => 'nodes n',
        on         => 'n.id = ltd.topic_id',
        left_join  => 'nodes ts',
        on         => 'ts.id = ltd.topic_status_id',
        where      => 'ltd.id = ?',
    ],

    new_topic_status => [
        select => [
            '"new_topic_status" AS _delta',
            'tsd.def AS def',
            'p.uuid AS project_uuid',
            'ts.tkind AS tkind',
            'tsd.rank AS rank',
            'tsd.status AS status',
            'n.uuid AS uuid',
        ],
        from       => 'topic_status_deltas tsd',
        inner_join => 'topic_status ts',
        on         => 'ts.id = tsd.topic_status_id',
        inner_join => 'nodes n',
        on         => 'n.id = ts.id',
        inner_join => 'nodes p',
        on         => 'p.id = ts.project_id',
        where      => 'tsd.id = ?',
    ],

    update_topic_status => [
        select => [
            '"update_topic_status" AS _delta',
            'tsd.def AS def',
            'tsd.rank AS rank',
            'tsd.status AS status',
            'ts.uuid AS uuid',
        ],
        from       => 'topic_status_deltas tsd',
        inner_join => 'nodes ts',
        on         => 'ts.id = ts.id',
        where      => 'tsd.id = ?',
    ],

    new_work => [
        select => [
            '"new_work" AS _delta',
            'wd.offset AS offset',
            'wd.start AS start',
            'wd.stop AS stop',
            'wd.start_comment AS start_comment',
            'wd.stop_comment AS stop_comment',
            'n.uuid AS node_uuid',
        ],
        from       => 'work_deltas wd',
        inner_join => 'nodes n',
        on         => 'n.id = wd.node_id',
        where      => 'wd.id = ?',
    ],

);

my %prepared;

sub Bif::DB::db::uchangeset_v1 {
    my $self      = shift;
    my $id        = shift;
    my @changeset = ();

    my $begin_change = $prepared{$self}{begin_change} ||= $self->xprepare(
        select => [
            'p.uuid AS parent_uuid',
            'c.mtime AS mtime',
            'c.mtimef AS mtimef',
            'c.mtimetz AS mtimetz',
            'c.author AS author',
            'c.author_contact AS author_contact',
            'c.author_contact_method AS author_contact_method',
            'c.author_shortname AS author_shortname',
            'c.lang AS lang',
        ],
        from      => 'changes c',
        left_join => 'changes p',
        on        => 'p.id = c.parent_id',
        where     => 'c.id = ?',
    );
    $begin_change->execute($id);
    push( @changeset, $begin_change->hashref );
    $begin_change->finish;

    my $deltas = $prepared{$self}{deltas} ||= $self->xprepare(
        select   => [ 'd.id AS id', 'd.action AS action', ],
        from     => 'deltas d',
        where    => 'd.change_id = ?',
        order_by => 'd.id',
    );
    $deltas->execute($id);

    my $sth;
    foreach my $delta ( $deltas->hashrefs ) {
        $sth = $prepared{$self}{ $delta->{action} } ||= $self->xprepare(
            @{
                $statements{ $delta->{action} }
                  || die "action unimplemented: $delta->{action}"
            }
        );
        $sth->execute( $delta->{id} );
        if ( my $ref = $sth->hashref ) {
            push( @changeset, $ref );
        }
        else {
            warn "missing delta $delta->{id}: $delta->{action}";
        }
        $sth->finish;
    }

    my $end_change = $prepared{$self}{end_change} ||= $self->xprepare(
        select => [
            'c.action_format AS action_format',
            'n1.uuid AS action_node_uuid_1',
            'n2.uuid AS action_node_uuid_2',
            'i.uuid AS identity_uuid',
            'c.message AS message',
            'c.uuid AS uuid',
        ],
        from       => 'changes c',
        inner_join => 'nodes i',
        on         => 'i.id = c.identity_id',
        left_join  => 'nodes n1',
        on         => 'n1.id = c.action_node_id_1',
        left_join  => 'nodes n2',
        on         => 'n2.id = c.action_node_id_2',
        where      => 'c.id = ?',
    );

    $end_change->execute($id);
    push( @changeset, $end_change->hashref );
    $end_change->finish;

    return \@changeset;
}

our %import = (
    new_hub                     => 'func_import_new_hub',
    new_hub_repo                => 'func_import_new_hub_repo',
    new_identity_contact_method => 'func_import_new_identity_contact_method',
    new_identity                => 'func_import_new_identity',
    new_project                 => 'func_import_new_project',
    new_project_status          => 'func_import_new_project_status',
    new_topic                   => 'func_import_new_topic',
    new_link_topic              => 'func_import_new_link_topic',
    new_topic_status            => 'func_import_new_topic_status',
    new_work                    => 'func_import_new_work',
    update_hub                  => 'func_import_update_hub',
    update_hub_repo             => 'func_import_update_hub_repo',
    update_identity_contact_method =>
      'func_import_update_identity_contact_method',
    update_identity => 'func_import_update_identity',
    update_project  => 'func_import_update_project',
    update_topic    => 'func_import_update_topic',
);

sub Bif::DB::db::save_uchangeset_v1 {
    my $self      = shift;
    my $changeset = shift;

    my $begin = shift @$changeset;
    my $end   = pop @$changeset;

    my @keys = sort keys %$begin;
    my @values = map { qv( $begin->{$_} ) } @keys;

    # Only insert if the uuid does not exist
    my $have_change = $prepared{$self}{have_change} ||= $self->xprepare(
        select => 'count(id)',
        from   => 'changes c',
        where  => {
            'c.uuid' => $end->{uuid},
        },
    );
    $have_change->execute( $end->{uuid} );
    my $res = $have_change->val;
    $have_change->finish;
    return ( 0, $end->{uuid} ) if $res;

    $self->xdo(
        insert_into => 'func_import_begin_change',
        values      => $begin,
    );

    foreach my $delta (@$changeset) {
        my $delta_action = $delta->{_delta};
        my $func         = $import{ delete $delta->{_delta} }
          || die "Missing \%import for $delta";

        $self->xdo(
            insert_into => $func,
            values      => $delta,
        );
    }

    $self->xdo(
        insert_into => 'func_import_end_change',
        values      => $end,
    );

    my $is_valid = $prepared{$self}{is_valid} ||= $self->xprepare(
        select => case (
            when => 'c.valid = 0',
            then => -1,
            else => 1
        ),
        from  => 'changes c',
        where => {
            'c.uuid' => $end->{uuid},
        },
    );
    $is_valid->execute( $end->{uuid} );
    $res = $is_valid->val;
    $is_valid->finish;

    $self->xdo(
        delete_from => 'changes',
        where       => { uuid => $end->{uuid} },
    ) if -1 == $res;

    return ( $res, $end->{uuid} );
}

1;

=head1 NAME

=for bif-doc #perl

Bif::DB::Plugin::ChangeUUIDv1 - read-write helper methods for a bif
database

=head1 VERSION

0.1.5_6 (2015-10-20)

=head1 SYNOPSIS

    use strict;
    use warnings;
    use Bif::DB;
    use Bif::DB::Plugin::ChangeUUIDv1;

    my $db = Bif::DB->connect(...);

    # Now use dbh/st methods from ChangeUUIDv1

=head1 DESCRIPTION

B adds some changeet methods to
L.

=head1 DBH METHODS

=over

=item xprepare_uchangeset_v1() -> $sth

=back

=head1 ST METHODS

=over

=item uchangeset_v1() -> ArrayRef

=back

=head1 SEE ALSO

L

=head1 AUTHOR

Mark Lawrence [e-mail]

=head1 COPYRIGHT AND LICENSE

Copyright 2013-2015 Mark Lawrence

This program is free software; you can redistribute it and/or modify it
under the terms of the GNU General Public License as published by the
Free Software Foundation; either version 3 of the License, or (at your
option) any later version.