package PunJab::HTTPB;use strict;use warnings;use POE;use POE::Filter::XML;use POE::Filter::XML::Node;use POE::Filter::XML::NS qw/ :JABBER :IQ /;use POE::Filter::XML::Utils;use PunJab::Util;use PunJab::Session;use PunJab::Server::HTTPB;use POSIX qw(strftime);use Digest::SHA1;use Digest::MD5 qw(md5 md5_hex md5_base64);use Data::Uniqid qw ( suniqid uniqid luniqid );my %help;sub new {    shift;    my $config = shift;    $config->{'type'} = "http_bind";          PunJab::Server::HTTPB->new($config,'http_binding','input','output');        POE::Session->create	( inline_states =>	  { _start => sub {	      my $kernel = $_[KERNEL];	      if ($config->{debug}>0) {		  &debug("HTTPB Session Started\n");	      }	      $kernel->alias_set("http_binding");	  },	    session_register => sub {                my $sid = $_[ARG0];		                $punjab_session->register($sid);                $punjab_session->logged_in($sid,1);                $punjab_session->activity($sid,time());                if ($_[HEAP]->{'CONFIG'}->{debug} > 1) {                    &debug(" HTTPB Session $sid registered");                }            },            session_unregister => sub {                my $sid = $_[ARG0];                $punjab_session->unregister($sid);                if ($_[HEAP]->{'CONFIG'}->{debug} > 1) {                    &debug(" HTTPB Session $sid unregistered");                }            },	    	    input => \&input,	    output => \&output,	    	    check_timeout => \&check_timeout,	    check_timeout_continue => \&check_timeout_continue,	},	  heap => { CONFIG => $config },	  options => { debug => $config->{'debug'}, trace => $config->{'debug'} }	  );        return undef;}sub input() {    my ($kernel,$session,$heap, $body, $event_id) =        @_[KERNEL, SESSION, HEAP, ARG0 .. ARG1];    &debug("HTTPB INPUT");    &debug($body->to_str());    }sub output(){}sub check_timeout(){    my ($kernel,$session,$heap) =        @_[KERNEL, SESSION, HEAP];    my @keys = keys %{$punjab_session->registry()};    $heap->{'session_keys'} = \@keys;    $kernel->yield('check_timeout_continue');}sub check_timeout_continue(){    my ($kernel,$session,$heap) =        @_[KERNEL, SESSION, HEAP];    my $ctime = time();    my $s = pop(@{$heap->{'session_keys'}});    if (not defined $s) {        my $count = keys %{$punjab_session->registry()};        if ($count > 0) {            $kernel->delay('check_timeout', $heap->{'CONFIG'}->{'idle_check'});        }        return;    }    if (($ctime - $punjab_session->activity($s))>=$heap->{'CONFIG'}->{'timeout'}) {        $kernel->post($s,'disconnect');        $punjab_session->unregister($s);    }    $kernel->yield('check_timeout_continue');}1;__END__