File Coverage

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

Criterion	Covered	Total	%
statement	18	88	20.4
branch	0	20	0.0
condition	0	49	0.0
subroutine	6	10	60.0
pod	1	3	33.3
total	25	170	14.7

package App::bif::new::project;
use strict;
use warnings;
use Bif::Mo;
use IO::Prompt::Tiny qw/prompt/;
use DBIx::ThinSQL qw/ case qv sq/;

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

sub dup {
    my $self = shift;
    my $opts = $self->opts;
    my $dbw  = $self->dbw;

    my $path      = $opts->{path};
    my $dup_pinfo = $self->get_project( $opts->{dup} );

    $opts->{title} ||= $dbw->xval(
        select => 'p.title',
        from   => 'projects p',
        where  => { 'p.id' => $dup_pinfo->{id} },
    );

    my $src = $dbw->xval(
        select     => 'n.path',
        from       => 'projects p',
        inner_join => 'nodes n',
        on         => 'n.id = p.id',
        where      => { 'p.id' => $dup_pinfo->{id} },
    );

    $opts->{message} ||=
      $self->prompt_edit( txt => "[ dup: $src ]\n", opts => $self );

    $dbw->txn(
        sub {
            $opts->{id} ||= $dbw->nextval('nodes');
            $opts->{change_id} ||= $self->new_change;

            $dbw->xdo(
                insert_into => 'func_new_project',
                values      => {
                    change_id => $opts->{change_id},
                    id        => $opts->{id},
                    parent_id => $opts->{parent_id},
                    name      => $opts->{name},
                    title     => $opts->{title},
                    bill      => $opts->{bill} // 1,
                },
            );

            $dbw->xdo(
                update => 'projects',
                set    => { local => 1, },
                where  => { id => $opts->{id} },
            );

            # TODO: unecessary?
            if ( $dup_pinfo->{default_hub_id} ) {
                $dbw->xdo(
                    insert_into => 'func_update_project',
                    values      => {
                        id        => $opts->{id},
                        change_id => $opts->{change_id},
                        hub_id    => $dup_pinfo->{default_hub_id},
                    },
                );
            }

            my @status = $dbw->xhashrefs(
                select    => [ 'ps.status', 'ps.rank', 'p.id AS current_id' ],
                from      => 'project_status ps',
                left_join => 'projects p',
                on       => 'p.project_status_id = ps.id',
                where    => { 'ps.project_id' => $dup_pinfo->{id} },
                order_by => 'ps.rank',
            );

            my $status_id;
            foreach my $status (@status) {
                my $sid = $dbw->nextval('nodes');
                $status_id = $sid if $status->{current_id};

                $dbw->xdo(
                    insert_into => 'func_new_project_status',
                    values      => {
                        change_id  => $opts->{change_id},
                        id         => $sid,
                        project_id => $opts->{id},
                        status     => $status->{status},
                        rank       => $status->{rank},
                        bill       => $opts->{bill} // 1,
                    }
                );
            }

            $dbw->xdo(
                insert_into => 'func_update_project',
                values      => {
                    id                => $opts->{id},
                    change_id         => $opts->{change_id},
                    project_status_id => $status_id,
                },
            );

            $dbw->xdo(
                insert_into => [
                    'func_new_topic_status',
                    qw/change_id id project_id tkind status rank def
                      bill/,
                ],
                select => [
                    qv( $opts->{change_id} ), 'nextval("nodes")',
                    qv( $opts->{id} ),        'ts.tkind',
                    'ts.status',              'ts.rank',
                    'ts.def', qv( $opts->{bill} // 1 ),
                ],
                from     => 'topic_status ts',
                where    => { 'ts.project_id' => $dup_pinfo->{id} },
                order_by => [qw/ts.tkind ts.rank/]
            );

            $self->end_change(
                id => $opts->{change_id},
                action_format =>
"new project $opts->{path} (%s) --dup $dup_pinfo->{path} (%s)]",
                action_node_id_1 => $opts->{id},
                action_node_id_1 => $dup_pinfo->{id},
                message          => $opts->{message},
            );

        }
    );

    return $self->ok('NewProject');
}

sub new_project {
    my $self = shift;
    my $kind = shift || 'project';
    my $dbw  = $self->dbw;
    my $opts = $self->opts;

    $dbw->xdo(
        insert_into => 'func_new_project',
        values      => {
            change_id => $opts->{change_id},
            id        => $opts->{id},
            parent_id => $opts->{parent_id},
            name      => $opts->{name},
            title     => $opts->{title},
            bill      => $opts->{bill} // 1,
        },
    );

    $dbw->xdo(
        update => 'projects',
        set    => {
            local => 1,
        },
        where => { id => $opts->{id} },
    );

    my @status = $dbw->xhashrefs(
        select   => [ qw/status rank/, ],
        from     => 'default_status',
        where    => { kind => $kind },
        order_by => 'rank',
    );

    foreach my $status (@status) {
        my $sid = $dbw->nextval('nodes');

        $dbw->xdo(
            insert_into => 'func_new_project_status',
            values      => {
                change_id  => $opts->{change_id},
                id         => $sid,
                project_id => $opts->{id},
                status     => $status->{status},
                rank       => $status->{rank},
                bill       => $opts->{bill} // 1,
            }
        );
    }

    $dbw->xdo(
        insert_into =>
          [ 'func_update_project', 'id', 'change_id', 'project_status_id', ],
        select =>
          [ qv( $opts->{id} ), qv( $opts->{change_id} ), 'project_status.id', ],
        from       => 'default_status',
        inner_join => 'project_status',
        on         => {
            project_id              => $opts->{id},
            'default_status.status' => \'project_status.status',
        },
        where => do {

            if ( $opts->{status} ) {
                {
                    'default_status.kind'   => 'project',
                    'default_status.status' => $opts->{status},
                };
            }
            else {
                {
                    'default_status.kind' => 'project',
                    'default_status.def'  => 1,
                };
            }
        },
    );

    $dbw->xdo(
        insert_into => [
            'func_new_topic_status',
            qw/change_id id project_id tkind status rank def bill/,
        ],
        select => [
            qv( $opts->{change_id} ),
            'nextval("nodes")',
            qv( $opts->{id} ),
            'ds.kind',
            'ds.status',
            'ds.rank',
            case (
                when => 'ds.def',
                then => 1,
                else => 0,
              )->as('def'),
            qv( $opts->{bill} // 1 ),
        ],
        from     => 'default_status ds',
        where    => { 'ds.kind !' => [ 'project', 'hub' ] },
        order_by => [qw/ds.kind ds.rank/]
    );
}

sub run {
    my $self = shift;
    my $opts = $self->opts;
    my $dbw  = $self->dbw;

    $dbw->txn(
        sub {
            $self->pause_work;
            my $start = time;

            #            $self->stop_work(
            #                stop => $start,
            #                save => 1,
            #            );

            $opts->{path} ||= prompt( 'Path:', '' )
              || return $self->err( 'ProjectPathRequired',
                'project path is required' );

            my @parts = split( '/', $opts->{path} );
            $opts->{name} = pop @parts;

            my $parent = join( '/', @parts );
            my @parents = $dbw->get_projects($parent);

            if ( @parents > 1 ) {
                return $self->err( 'ParentProjectAmbiguous',
                    "parent path is ambiguous:\n    "
                      . join( "\n    ", map { $_->{path} } @parents ) );
            }
            elsif (@parents) {
                $opts->{parent_id} = $parents[0]->{id};
                @parts = split( '/', $parents[0]->{path} );
            }
            elsif (@parts) {
                return $self->err( 'HubNotFound',
                    "hub or parent project not found: " . join( '/', @parts ) );
            }

            my @x = $dbw->get_projects( $opts->{path} );
            return $self->err( 'ProjectExists',
                "project exists: $opts->{path}" )
              if @x;

            my $where;
            if ( $opts->{status} ) {
                return $self->err( 'InvalidStatus',
                    'unknown status: ' . $opts->{status} )
                  unless $dbw->xarrayref(
                    select => 'count(*)',
                    from   => 'default_status',
                    where  => {
                        kind   => 'project',
                        status => $opts->{status},
                    }
                  );
            }

            return dup($self) if $opts->{dup};

            $opts->{title} ||= prompt( 'Title:', '' )
              || return $self->err( 'ProjectTitleequired',
                'project title is required' );

            $opts->{message} ||= $self->prompt_edit( opts => $self );
            $opts->{lang} ||= 'en';
            $opts->{change_id} ||= $self->new_change;
            $opts->{id} ||= $dbw->nextval('nodes');

            $self->new_project;

            $self->save_new_work(
                bill => $opts->{bill} // 1,
                change_id => $opts->{change_id},
                node_id   => $opts->{id},
                start     => $start,
                stop      => time,
            );

            $self->end_change(
                id            => $opts->{change_id},
                message       => $opts->{message},
                action_format => "new project $opts->{path}",
            );

            $self->resume_work;
        }
    );

    return $self->ok('NewProject');
}

1;
__END__