File Coverage

blib/lib/WebService/Amazon/DynamoDB/Server/Table.pm

Criterion	Covered	Total	%
statement	41	49	83.6
branch	0	2	0.0
condition	2	10	20.0
subroutine	14	18	77.7
pod	7	9	77.7
total	64	88	72.7

package WebService::Amazon::DynamoDB::Server::Table;
$WebService::Amazon::DynamoDB::Server::Table::VERSION = '0.001';
use strict;
use warnings;

use Future;
use Future::Utils qw(repeat);

use WebService::Amazon::DynamoDB::Server::Item;
use Mixin::Event::Dispatch::Bus;

use constant DYNAMODB_INDEX_OVERHEAD => 100;

=head2 new

=cut

sub new { my $class = shift; bless {@_}, $class }

=head2 bus

The event bus used by this instance.

=cut

sub bus { shift->{bus} //= Mixin::Event::Dispatch::Bus->new }

=head2 name

=cut

sub name { shift->{TableName} // die 'invalid table - no name' }

sub state { shift->{TableStatus} }

=head2 item_by_id

=cut

sub item_by_id {
	my ($self, @id) = @_;
	my $k = $self->key_for_id(@id) // return Future->fail('bad key');
	exists $self->{items}{$k} or return Future->fail('item not found');
	Future->done($self->{items}{$k});
}

=head2 key_for_id

=cut

sub key_for_id {
	my ($self, @id) = @_;
	join "\0", map Encode::encode("UTF-8", $_), @id;
}

=head2 bytes_used

=cut

sub bytes_used {
	my ($self) = @_;
	$self->{bytes_used} //= do {
		my $total = 0;
		(repeat {
			shift->bytes_used->on_done(sub {
				$total += DYNAMODB_INDEX_OVERHEAD + shift
			})
		} foreach => [ @{$self->{items}} ],
		  otherwise => sub { Future->done($total) })
	}
}

=head2 validate_id_for_item_data

=cut

sub validate_id_for_item_data {
	my ($self, $data) = @_;
	my @id_fields = map $_->{AttributeName}, @{$self->{KeySchema}};
	return Future->fail(
		ValidationException =>
	) for grep !exists $data->{$_}, @id_fields;

	my ($id) = join "\0", map values %{$data->{$_}}, @id_fields;
	Future->done($id);
}

sub item_from_data {
	my ($self, $data) = @_;
	WebService::Amazon::DynamoDB::Server::Item->new(
		attributes => $data
	);
}

1;

__END__