File Coverage

blib/lib/App/bif/drop/project.pm

Criterion	Covered	Total	%
statement	15	33	45.4
branch	0	6	0.0
condition			n/a
subroutine	5	7	71.4
pod	1	2	50.0
total	21	48	43.7

package App::bif::drop::project;
use strict;
use warnings;
use Bif::Mo;
use DBIx::ThinSQL qw/sq/;

our $VERSION = '0.1.5_7';
extends 'App::bif';

sub run {
    my $self = shift;
    my $opts = $self->opts;
    my $dbw  = $self->dbw;
    my $info = $self->get_project( $opts->{path} );

    if ( !$opts->{force} ) {
        print "Nothing dropped (missing --force, -f)\n";
        return $self->ok('DropNoForce');
    }

    $dbw->txn(
        sub {
            if ( $info->{default_hub_id} ) {
                $self->drop_shallow($info);

                print "Project dropped: $info->{path} (shallow)\n";
            }
            else {
                $dbw->xdo(
                    delete_from => 'projects',
                    where       => { id => $info->{id} },
                );

                print "Project dropped: $info->{path})\n";
            }
        }
    );

    return $self->ok('DropProjectShallow') if $info->{default_hub_id};
    return $self->ok('DropProject');
}

sub drop_shallow {
    my $self = shift;
    my $info = shift;
    my $dbw  = $self->dbw;

    # Drop topics that are not part of any other project
    my $res = $dbw->xdo(
        with => 'x',
        as   => sq(
            select => [ 't.link_topic_id', 'COUNT(t.link_topic_id) AS total' ],
            from   => 'topics t',
            where    => { 't.project_id' => $info->{id} },
            group_by => 't.id',
            having   => 'total = 1',
        ),
        delete_from => 'link_topics',
        where       => [
            'id IN ',
            sq(
                select => 'x.id',
                from   => 'x',
            )
        ],
    );

 # Delete project node entities, except those which are
 # our own identities, project entities, or are also
 # other project node entities.
 #    $res += $dbw->xdo(
 #        delete_from => 'entities',
 #        where       => [
 #            'id IN ',
 #            sq(
 #                select        => 'pte.entity_id',
 #                from          => 'project_node_entities pte',
 #                where         => { 'pte.project_id' => $info->{id} },
 #                except_select => 'x.entity_id',
 #                from          => sq(
 #                    select           => 'bif.identity_id AS entity_id',
 #                    from             => 'bifkv bif',
 #                    where            => { 'bif.key' => 'self' },
 #                    union_all_select => 'pe.entity_id',
 #                    from             => 'project_entities pe',
 #                    where            => { 'pe.project_id' => $info->{id} },
 #                    union_all_select => 'pte.entity_id',
 #                    from             => 'project_node_entities pte',
 #                    where            => { 'pte.project_id !' => $info->{id} },
 #                )->as('x'),
 #            ),
 #        ],
 #    );

    $res += $dbw->xdo(
        update => 'projects',
        set    => { local => 0 },
        where  => { id => $info->{id} },
    );
    return $res;
}

1;
__END__