From Code to Community: Sponsoring The Perl and Raku Conference 2025 Learn more

MCMIC / POE-Component-Server-JSONRPC-0.04 / lib / POE / Component / Server / JSONRPC / Http.pm 

            

              
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

              
##############################
#  This code is part of FusionDirectory (http://www.fusiondirectory.org/)
#  Copyright (C) 2011  FusionDirectory
#
#  This program is free software; you can redistribute it and/or modify
#  it under the terms of the GNU General Public License as published by
#  the Free Software Foundation; either version 2 of the License, or
#  (at your option) any later version.
#
#  This program is distributed in the hope that it will be useful,
#  but WITHOUT ANY WARRANTY; without even the implied warranty of
#  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
#  GNU General Public License for more details.
#
#  You should have received a copy of the GNU General Public License
#  along with this program; if not, write to the Free Software
#  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
##############################
package POE::Component::Server::JSONRPC::Http;
use strict;
use warnings;
use POE::Component::Server::JSONRPC; # for old Perl 5.005
use base qw(POE::Component::Server::JSONRPC);
our $VERSION = '0.02';
use POE qw/
    Component::Server::SimpleHTTP
    Filter::Line
    /;
use JSON::Any;
use Data::Dumper;
=head1 NAME
POE::Component::Server::JSONRPC::Http - POE http based JSON-RPC server
=head2 new
    constructor
=cut
sub new {
    my $class = shift;
    return $class->SUPER::new(@_);
}
=head2 poe_init_server
    Init HTTP Server.
=cut
sub poe_init_server {
    my ($self, $kernel, $session, $heap) = @_[OBJECT, KERNEL, SESSION, HEAP];
     
    $kernel->alias_set( 'JSONRPCHTTP' );
     
    $self->{http} = POE::Component::Server::SimpleHTTP->new(
        'ALIAS'         =>      'HTTPD',
        'PORT'          =>      $self->{Port},
        $self->{Address}     ? ('ADDRESS'     => $self->{Address} )     : (),
        $self->{Hostname}    ? ('HOSTNAME'    => $self->{Hostname} )    : (),
        'HANDLERS'      =>      [
                {
                        'DIR'           =>      '.*',
                        'SESSION'       =>      'JSONRPCHTTP',
                        'EVENT'         =>      'input_handler',
                },
        ],
    );
}
=head2 poe_send
    Send HTTP response
=cut
sub poe_send {
    my ($kernel,$response, $content) = @_[KERNEL,ARG0..$#_];
     
    #HTTP
    $response->code( 200 );
    $response->content( $content );
     
    $kernel->post( 'HTTPD', 'DONE', $response );
}
1;