File Coverage

blib/lib/Hash/Storage/Driver/OneFile.pm

Criterion	Covered	Total	%
statement	15	15	100.0
branch			n/a
condition			n/a
subroutine	5	5	100.0
pod			n/a
total	20	20	100.0

package Hash::Storage::Driver::OneFile;

our $VERSION = '0.02';

use v5.10;
use strict;
use warnings;

use File::Slurp;

use base "Hash::Storage::Driver::Base";

sub init {
    my ($self) = @_;

}

sub get {
    my ( $self, $id ) = @_;
    my $hashes = $self->_load_data();
    return $hashes->{$id};
}

sub set {
    my ( $self, $id, $fields ) = @_;

    $self->do_exclusively( sub {
        my $hashes = $self->_load_data();
        @{ $hashes->{$id} }{ keys %$fields } = values %$fields;
        $self->_save_data($hashes);
    } );
}

sub del {
    my ( $self, $id ) = @_;

    $self->do_exclusively( sub {
        my $hashes = $self->_load_data();
        delete $hashes->{$id};
        $self->_save_data($hashes);
    } );
}

sub list {
    my ( $self, @query ) = @_;
    my $hashes = $self->_load_data();
    my @hashes = values %$hashes;
    return $self->do_filtering(\@hashes, \@query);
}

sub count {
    my ( $self, $filter ) = @_;
    my $hashes = $self->list(where => $filter);
    return scalar(@$hashes);
}

sub _load_data {
    my $self = shift;
    return {} unless -e $self->{file};
    my $serialized = read_file( $self->{file} );
    my $data       = $self->{serializer}->deserialize($serialized);

    return $data;
}

sub _save_data {
    my ( $self, $data ) = @_;
    my $serialized = $self->{serializer}->serialize($data);
    write_file( $self->{file}, { atomic => 1 }, $serialized );
}

1;    # End of Hash::Storage