package Zing::Store::Hash; use 5.014; use strict; use warnings; use registry 'Zing::Types'; use routines; use Data::Object::Class; use Data::Object::ClassHas; extends 'Zing::Store'; our $VERSION = '0.27'; # VERSION our $DATA = {}; # ATTRIBUTES has data => ( is => 'ro', isa => 'HashRef', new => 1, ); fun new_data($self) { $DATA } # METHODS method drop(Str $key) { return int(!!delete $self->data->{$key}); } method keys(Str $query) { $query =~ s/\*/.*/g; return [grep /$query/, keys %{$self->data}]; } method lpull(Str $key) { my $get = shift @{$self->data->{$key}} if $self->data->{$key}; return $get ? $self->decode($get) : $get; } method lpush(Str $key, HashRef $val) { my $set = $self->encode($val); return unshift @{$self->data->{$key}}, $set; } method recv(Str $key) { my $get = $self->data->{$key}; return $get ? $self->decode($get) : $get; } method rpull(Str $key) { my $get = pop @{$self->data->{$key}} if $self->data->{$key}; return $get ? $self->decode($get) : $get; } method rpush(Str $key, HashRef $val) { my $set = $self->encode($val); return push @{$self->data->{$key}}, $set; } method send(Str $key, HashRef $val) { my $set = $self->encode($val); $self->data->{$key} = $set; return 'OK'; } method size(Str $key) { return $self->data->{$key} ? scalar(@{$self->data->{$key}}) : 0; } method slot(Str $key, Int $pos) { my $get = $self->data->{$key}->[$pos]; return $get ? $self->decode($get) : $get; } method test(Str $key) { return int exists $self->data->{$key}; } 1; =encoding utf8 =head1 NAME Zing::Store::Hash - Hash Storage =cut =head1 ABSTRACT Hash Storage Abstraction =cut =head1 SYNOPSIS use Zing::Store::Hash; use Zing::Encoder::Dump; my $hash = Zing::Store::Hash->new( encoder => Zing::Encoder::Dump->new ); # $hash->drop; =cut =head1 DESCRIPTION This package provides an in-memory (only) storage adapter for use with data persistence abstractions. =cut =head1 INHERITS This package inherits behaviors from: L =cut =head1 LIBRARIES This package uses type constraints from: L =cut =head1 METHODS This package implements the following methods: =cut =head2 decode decode(Str $data) : HashRef The decode method decodes the JSON data provided and returns the data as a hashref. =over 4 =item decode example #1 # given: synopsis $hash->decode('{"status"=>"ok"}'); =back =cut =head2 drop drop(Str $key) : Int The drop method removes (drops) the item from the datastore. =over 4 =item drop example #1 # given: synopsis $hash->drop('zing:main:global:model:temp'); =back =cut =head2 encode encode(HashRef $data) : Str The encode method encodes and returns the data provided as JSON. =over 4 =item encode example #1 # given: synopsis $hash->encode({ status => 'ok' }); =back =cut =head2 keys keys(Str @keys) : ArrayRef[Str] The keys method returns a list of keys under the namespace of the datastore or provided key. =over 4 =item keys example #1 # given: synopsis my $keys = $hash->keys('zing:main:global:model:temp'); =back =over 4 =item keys example #2 # given: synopsis $hash->send('zing:main:global:model:temp', { status => 'ok' }); my $keys = $hash->keys('zing:main:global:model:temp'); =back =cut =head2 lpull lpull(Str $key) : Maybe[HashRef] The lpull method pops data off of the top of a list in the datastore. =over 4 =item lpull example #1 # given: synopsis $hash->lpull('zing:main:global:model:items'); =back =over 4 =item lpull example #2 # given: synopsis $hash->rpush('zing:main:global:model:items', { status => 'ok' }); $hash->lpull('zing:main:global:model:items'); =back =cut =head2 lpush lpush(Str $key, HashRef $val) : Int The lpush method pushed data onto the top of a list in the datastore. =over 4 =item lpush example #1 # given: synopsis $hash->lpush('zing:main:global:model:items', { status => '1' }); =back =over 4 =item lpush example #2 # given: synopsis $hash->lpush('zing:main:global:model:items', { status => '0' }); =back =cut =head2 recv recv(Str $key) : Maybe[HashRef] The recv method fetches and returns data from the datastore by its key. =over 4 =item recv example #1 # given: synopsis $hash->recv('zing:main:global:model:temp'); =back =over 4 =item recv example #2 # given: synopsis $hash->send('zing:main:global:model:temp', { status => 'ok' }); $hash->recv('zing:main:global:model:temp'); =back =cut =head2 rpull rpull(Str $key) : Maybe[HashRef] The rpull method pops data off of the bottom of a list in the datastore. =over 4 =item rpull example #1 # given: synopsis $hash->rpull('zing:main:global:model:items'); =back =over 4 =item rpull example #2 # given: synopsis $hash->rpush('zing:main:global:model:items', { status => 1 }); $hash->rpush('zing:main:global:model:items', { status => 2 }); $hash->rpull('zing:main:global:model:items'); =back =cut =head2 rpush rpush(Str $key, HashRef $val) : Int The rpush method pushed data onto the bottom of a list in the datastore. =over 4 =item rpush example #1 # given: synopsis $hash->rpush('zing:main:global:model:items', { status => 'ok' }); =back =over 4 =item rpush example #2 # given: synopsis $hash->rpush('zing:main:global:model:items', { status => 'ok' }); $hash->rpush('zing:main:global:model:items', { status => 'ok' }); =back =cut =head2 send send(Str $key, HashRef $val) : Str The send method commits data to the datastore with its key and returns truthy. =over 4 =item send example #1 # given: synopsis $hash->send('zing:main:global:model:temp', { status => 'ok' }); =back =cut =head2 size size(Str $key) : Int The size method returns the size of a list in the datastore. =over 4 =item size example #1 # given: synopsis my $size = $hash->size('zing:main:global:model:items'); =back =over 4 =item size example #2 # given: synopsis $hash->rpush('zing:main:global:model:items', { status => 'ok' }); my $size = $hash->size('zing:main:global:model:items'); =back =cut =head2 slot slot(Str $key, Int $pos) : Maybe[HashRef] The slot method returns the data from a list in the datastore by its index. =over 4 =item slot example #1 # given: synopsis my $model = $hash->slot('zing:main:global:model:items', 0); =back =over 4 =item slot example #2 # given: synopsis $hash->rpush('zing:main:global:model:items', { status => 'ok' }); my $model = $hash->slot('zing:main:global:model:items', 0); =back =cut =head2 test test(Str $key) : Int The test method returns truthy if the specific key (or datastore) exists. =over 4 =item test example #1 # given: synopsis $hash->rpush('zing:main:global:model:items', { status => 'ok' }); $hash->test('zing:main:global:model:items'); =back =over 4 =item test example #2 # given: synopsis $hash->drop('zing:main:global:model:items'); $hash->test('zing:main:global:model:items'); =back =cut =head1 AUTHOR Al Newkirk, C =head1 LICENSE Copyright (C) 2011-2019, Al Newkirk, et al. This is free software; you can redistribute it and/or modify it under the terms of the The Apache License, Version 2.0, as elucidated in the L<"license file"|https://github.com/cpanery/zing/blob/master/LICENSE>. =head1 PROJECT L L L L L L =cut