--- deliantra/server/ext/tcp.ext	2007/11/24 05:57:09	1.9
+++ deliantra/server/ext/tcp.ext	2012/11/05 23:23:04	1.23
@@ -1,33 +1,79 @@
-#! perl
+#! perl # mandatory
 
 # this listens for new tcp connections and hands them over to the server core
-# wether this being an extension introduces or reduces stability problems
+# whether this being an extension introduces or reduces stability problems
 # is unknown as of today.
 
 use Socket;
-use IO::Socket::INET;
+use AnyEvent::Socket;
 
-our $LISTEN = new IO::Socket::INET
-   LocalPort => cf::settings->csport,
-   Listen    => 1,
-   Blocking  => 0,
-   ReuseAddr => 1;
-
-if (!$LISTEN) {
-   # extension yes, completely stupid, not yet
-   warn "unable to establish listen socket, exiting.\n";
-   exit (2);
+CONF BIND_ADDRESSES = [[undef, 13327]];
+
+our $MAX_DETECT = 16; # how many bytes to raed to identify the protocol
+
+our @LISTENERS;
+
+sub flash_policy_server {
+   my ($fh) = @_;
+
+   # socket policy file, just write answer and hope the kernel accepts it in one go
+   syswrite $fh, <<EOF . "\x00"
+<?xml version="1.0"?>
+<!DOCTYPE cross-domain-policy SYSTEM "http://www.adobe.com/xml/dtds/cross-domain-policy.dtd">
+<cross-domain-policy>
+    <allow-access-from domain="*" to-ports="*"/>
+</cross-domain-policy>
+EOF
 }
 
-our $LISTENER = EV::io $LISTEN, EV::READ, sub {
-   my ($fh, $peername) = $LISTEN->accept
-      or return;
+for (@$BIND_ADDRESSES) {
+   my ($host, $port) = @$_;
+   cf::info "listening on ", (format_hostport $host, $port), "\n";
+
+   push @LISTENERS, tcp_server $host, $port, sub {
+      my ($fh, $host, $port) = @_
+         or return;
+
+      my $lhost = AnyEvent::Socket::format_address
+                     +(AnyEvent::Socket::unpack_sockaddr getsockname $fh)[1];
+
+      my $id = format_hostport $host, $port;
+
+      cf::info "$id: new connection\n"
+         if $lhost ne $host; # do not log connections from the host, e.g. for watchdogs
 
-   my $fd   = fileno $fh;
-   my $host = inet_ntoa +(sockaddr_in $peername)[1];
+      my $buf;
+      my $w; $w = AE::io $fh, 0, sub {
+         my $len = sysread $fh, $buf, 512, length $buf;
 
-   warn "new connection from $host\n";
+         if ($len) {
+            if ($buf =~ /^..version /s) { # deliantra protocol
+               undef $w;
 
-   cf::client::create $fd, $host;
-};
+               my $ns = cf::client::create fileno $fh, $host;
+               $ns->inbuf_append ($buf);
+
+            } elsif ($buf =~ /^GET / && defined &ext::http::server) { # http or websocket
+               undef $w;
+
+               &ext::http::server ($id, $fh, $buf);
+
+            } elsif ($buf =~ /^<policy-file-request\/>\x00/) {
+               undef $w;
+
+               flash_policy_server $fh;
+
+            } elsif (length $buf >= $MAX_DETECT) { # unable to detect protocol
+               undef $w;
+
+               cf::info "$id: protocol detection error\n";
+            }
+         } else {
+            undef $w;
+
+            cf::info "$id: read error during protocol detection\n";
+         }
+      };
+   };
+}