1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
package Catmandu::Addable;
=head1 NAME
Catmandu::Addable - Base class for all Catmandu modules need to implement add
=head1 SYNOPSIS
package My::Adder;
use Moo;
use Data::Dumper;
with 'Catmandu::Addable';
sub add {
my ($self,$object) = @_;
print "So you want to add:\n";
print Dumper($object);
1;
}
sub commit {
my $self = shift;
print "And now you are done?\n";
}
package main;
my $adder = My::Adder->new(fix => ['upcase(foo)']);
# prints foo => BAR
$adder->add({ foo => 'bar' });
# prints:
# foo => BAR
# foo => BAR
$adder->add_many([ { foo => 'bar' } , { foo => 'bar' }]);
# prints a commit statement
$adder->commit;
=head1 METHODS
=head2 add($hash)
Receives a Perl hash and should return true or false.
=head2 commit
This method is usually called at the end of many add or add_many operations.
=head1 INHERIT
If you provide an 'add' method, then automatically your package gets a add_many method, plus
a fix attribute which transforms all Perl hashes provided to the add method.
=head1 SEE ALSO
L<Catmandu::Fixable>, L<Catmandu::Exporter> , L<Catmandu::Store>
=cut
use namespace::clean;
use Catmandu::Sane;
use Catmandu::Util qw(:is :check);
use Moo::Role;
with 'Catmandu::Fixable';
requires 'add';
around add => sub {
my ($orig, $self, $data) = @_;
$data = $self->_fixer->fix($data) if $self->_fixer;
$orig->($self, $data);
$data;
};
sub add_many {
my ($self, $many) = @_;
if (is_hash_ref($many)) {
$self->add($many);
return 1;
}
if (is_array_ref($many)) {
$self->add($_) for @$many;
return scalar @$many;
}
if (is_invocant($many)) {
$many = check_able($many, 'generator')->generator;
}
check_code_ref($many);
my $data;
my $n = 0;
while (defined($data = $many->())) {
$self->add($data);
$n++;
}
$n;
}
sub commit {}
1;
|
