Changeset 14291 for lang/perl/POE-Component-Server-JSONRPC

Timestamp:

06/20/08 16:31:36 (5 years ago)

Author:

nothingmuch

Message:

errors and generic handler in example

Files:

• lang/perl/POE-Component-Server-JSONRPC/trunk/ex.pl (modified) (3 diffs)

lang/perl/POE-Component-Server-JSONRPC/trunk/ex.pl

@@ -5 +5 @@
 
 use List::Util ();
+use Devel::PartialDump;
 
 POE::Session->create(
@@ -10 +11 @@
         _start => sub {
             POE::Component::Server::JSONRPC->new(
-                handler => {
-                    'echo'    => 'echo',
-                    'sum'     => 'sum',
-                    'echo_in' => 'echo_in',
-                },
+                handler => "rpc",
                 tcp => {
                     Port    => 3000,
@@ -21 +18 @@
             );
         },
-        echo_in => \&echo_in,
-        echo    => \&echo,
-        sum     => \&sum,
-        do_callback => sub { eval { $_[ARG0]->() } }
     },
+    package_states => [
+        __PACKAGE__, { map { $_ => $_ } qw(
+            rpc
+            do_callback
+            echo_in
+            echo
+            sum
+            die
+        )},
+    ],
 );
+
+sub do_callback {
+    if ( my $cb = $_[ARG0] ) {
+        $cb->();
+    }
+}
+
+sub rpc {
+    my ($kernel, $cb, $call) = @_[KERNEL, ARG0, ARG1];
+
+    my $method = $call->method;
+
+    if ( __PACKAGE__->can($method) ) {
+        # call as a state, so that delays can be set.
+        # ordinarily we could just do eval { $cb->( $self->$method ) }
+        unless ( eval { $kernel->call( $_[SESSION], $method, @_[ARG0 .. $#_] ); 1 } ) {
+            $cb->( $call->return_error($@) );
+        }
+    } else {
+        $cb->( $call->return_error( message => sprintf 'No such method "%s"', $method ) );
+    }
+}
+
+sub die {
+    my ($cb, $call) = @_[ARG0, ARG1];
+    die { message => Devel::PartialDump::dump($call->params_list) };
+}
 
 sub echo_in {