gistfile1.perl

my $bus = AnyMQ->new;
builder {
    enable "Static", path => sub { s!^/static/!! }, root => 'static';
    enable "Hippie",
        root => '/_hippie',
        handler => sub {
            my $env = shift;
            my $room = $env->{'hippie.args'};
            my $topic = $bus->topic($room);

            if ($env->{PATH_INFO} eq '/message') {
                my $msg = $env->{'hippie.message'};
                $msg->{time} = time;
                $msg->{address} = $env->{HTTP_REMOTE};
                $topic->publish($msg);
            }
            else {
                my $h = $env->{'hippie.handle'}
                    or return [ '400', [ 'Content-Type' => 'text/plain' ], [ "" ] ];

                if ($env->{PATH_INFO} eq '/init') {
                    my $sub = $bus->new_listener($h->id);
                    $sub->subscribe( $topic );
                    $sub->poll(sub { $h->send_msg($_[0]) });
                }
                elsif ($env->{PATH_INFO} eq '/error') {
                    warn "==> disconnecting $env->{'hippie.handle'}";
                }
                else {
                    die "unknown hippie message";
                }
            }
            return [ '200', [ 'Content-Type' => 'text/plain' ], [ "" ] ]
        };

    $app;
};