From b797f187a22f38142ac3ac957f0e874ca492c2cd Mon Sep 17 00:00:00 2001
From: franck cuny <franck@lumberjaph.net>
Date: Wed, 9 Jun 2010 16:38:20 +0200
Subject: initial import

---
 lib/Net/Riak/MapReducePhase.pm | 31 +++++++++++++++++++++++++++++++
 1 file changed, 31 insertions(+)
 create mode 100644 lib/Net/Riak/MapReducePhase.pm

(limited to 'lib/Net/Riak/MapReducePhase.pm')

diff --git a/lib/Net/Riak/MapReducePhase.pm b/lib/Net/Riak/MapReducePhase.pm
new file mode 100644
index 0000000..2d66775
--- /dev/null
+++ b/lib/Net/Riak/MapReducePhase.pm
@@ -0,0 +1,31 @@
+package Net::Riak::MapReducePhase;
+
+use Moose;
+use Scalar::Util;
+use JSON;
+
+has type     => (is => 'rw', isa => 'Str',      required => 1,);
+has function => (is => 'ro', isa => 'Str',      required => 1);
+has arg      => (is => 'ro', isa => 'ArrayRef', default  => 'None');
+has language => (is => 'ro', isa => 'Str',      default  => 'javascript');
+has keep => (is => 'rw', isa => 'JSON::Boolean', default => sub {JSON::false});
+
+sub to_array {
+    my $self = shift;
+
+    my $step_def = {
+        keep     => $self->keep,
+        language => $self->language,
+        arg      => $self->arg
+    };
+
+    if ($self->function =~ m!\{!) {
+        $step_def->{source} = $self->function;
+    }else{
+        $step_def->{name} = $self->function;
+    }
+    return {$self->type => $step_def};
+}
+
+
+1;
-- 
cgit 1.4.1