package AniDB::Datastore;
use 5.024;
use experimental 'signatures';
use Moo;
use Path::Tiny;
use AniDB::Hashing;
use namespace::clean;

has database => ( is => 'ro', required => 1 );
has dbh => ( is => 'ro', lazy => 1 );

sub _build_dbh($self) {
    require DBI;
    return DBI->connect(
        'dbi:SQLite:dbname='.$self->database,
        '', '',
        {
            AutoCommit => 1,
            RaiseError => 1,
            PrintError => 0,
        },
    );
}

sub update($self,$path) {
    my $stat = $path->stat;

    return 0 unless $self->_has_changed($path,$stat);
    my $hash = AniDB::Hashing::hash_fd($path->openr_raw);
    $self->_update_path_info(
        $path => {
            size => $stat->size,
            mtime => $stat->mtime,
            hash => $hash,
        },
    );
    return 1;
}

sub _has_changed($self,$path,$stat) {
    my $path_info = $self->path_info_for($path);
    return (
        $path_info->{size} == $stat->size
            && $path_info->{mtime} == $stat->mtime
        );
}

sub rename($self,$path,$new_path) {
    $self->dbh->do(
        q{UPDATE path_info SET name=? WHERE name=?},
        $path->stringify,$new_path->stringify,
    );
}

sub full_info_for($self,$path) {
    my $path_info = $self->path_info_for($path);
    my $episode_info = $self->episode_info_for(
        $path_info,
    );
    my $anime_info = $self->anime_info_for(
        $episode_info,
    );
    return {
        path => $path_info,
        episode => $episode_info,
        anime => $anime_info,
    };
}

sub path_info_for($self,$path) {
    my $ret = $self->dbh->selectall_arrayref(
        qr{SELECT * FROM path_info WHERE name=?},
        { Slice => {} },
        $path->stringify,
    );
    return $ret->[0];
}

sub episode_info_for($self,$args) {
    my $ret = $self->dbh->selectall_arrayref(
        qr{SELECT * FROM episode_info WHERE hash=? AND size=?},
        { Slice => {} },
        @{$args}{qw(hash size)},
    );
    return $ret->[0];
}

sub anime_info_for($self,$args) {
    my $ret = $self->dbh->selectall_arrayref(
        qr{SELECT * FROM anime_info WHERE aid=?},
        { Slice => {} },
        @{$args}{qw(aid)},
    );
    return $ret->[0];
}

1;