added Server PING -> PONG

[PHP-P10.git] / Uplink / Uplink.class.php

diff --git a/Uplink/Uplink.class.php b/Uplink/Uplink.class.php
index d9ac2211afdaf715f3ec34ab65bda4143a6f4292..2dee4da2f213caf4d93bc98d9c50bc7f1ba2f0d6 100644 (file)
--- a/Uplink/Uplink.class.php
+++ b/Uplink/Uplink.class.php
@@ -27,6 +27,9 @@
  ************************************************************************
  * accessable methods:
  *
+ * void initialize()
+ *     has to be called after the settings have been set.
+ *
  * void loop() 
  *     loop function that should be calles as many times as possible. 
  *     It reads from the socket and BLOCKS the script execution for a 
@@ -38,7 +41,7 @@
  * void setLoopTimeout(int $timeout)
  *     sets the maximum time loop() is blocking the script execution.
  *
- * void setUplinkServer(int $numeric, String $name, String $password)
+ * void setUplinkServer(int $numeric, String $name, String $password, String $description)
  *     sets the own P10 Server information.
  *
  * void setValidateServer(String $name, String $password)
@@ -51,8 +54,9 @@ require_once("P10Formatter.class.php");
 class Uplink {
        private $client = new Client();
        private $settings = array();
+       private $server;
        
-       const FLAG_P10SESSION      = 0x0001; //connection is in P10 mode (parser relevant)
+       const FLAG_P10SESSION      = 0x0001; //connection is in P10 mode (server is connected)
        const FLAG_SECURITY_QUIT   = 0x0002; //local connection abort because of security issues
        const FLAG_NOT_CONNECTABLE = 0x0004; //remote server is not connectable
        private $flags = 0;
@@ -61,24 +65,49 @@ class Uplink {
                $this->setSettings("recv_timeout", 1000);
        }
        
+       public function initialize() {
+               if($this->server) {
+                       trigger_error("Uplink already initialized.", E_USER_ERROR);
+                       return;
+               }
+               $self_numeric = $this->getSetting("numeric");
+               $self_name = $this->getSetting("name");
+               $self_description = $this->getSetting("description");
+               if(!$self_numeric || !$self_name) {
+                       trigger_error("Server Settings missing.", E_USER_ERROR);
+                       return;
+               }
+               $this->server = new P10_Server($self_name, $self_numeric, null, time(), time(), $self_description);
+       }
+       
        public function loop() {
+               if($this->server == null) {
+                       trigger_error("Uplink not initialized.", E_USER_ERROR);
+                       return;
+               }
                if(!$this->client->connected()) {
+                       if(($this->flags & self::FLAG_P10SESSION)) {
+                               //Server got disconnected
+                               $this->server->disconnectServer(true);
+                               $this->flags &= ~self::FLAG_P10SESSION;
+                       }
                        $host = $this->getSetting("host");
                        $port = $this->getSetting("port");
                        if($host == null || $port == null) {
-                               Throw new Exception("Uplink Settings missing.");
+                               trigger_error("Uplink Settings missing.", E_USER_ERROR);
                                return;
                        }
-                       if(($flags & self::FLAG_SECURITY_QUIT) || ($flags & self::FLAG_NOT_CONNECTABLE)) {
+                       if(($this->flags & self::FLAG_SECURITY_QUIT) || ($this->flags & self::FLAG_NOT_CONNECTABLE)) {
                                sleep(1);
                        }
                        $state = $this->client->connect($host, $port, $this->getSettings("bind"), $this->getSettings("ssl"), $this->getSettings("recv_timeout"));
                        if(!$state) {
                                usleep($this->getSetting("recv_timeout") / 1000);
-                               $flags |= self::FLAG_NOT_CONNECTABLE;
+                               $this->flags |= self::FLAG_NOT_CONNECTABLE;
                                return;
                        }
                        $this->flags = 0;
+                       $this->loginServer();
                }
                //try to receive new data from the Uplink
                $lines = $this->client->recv();
@@ -99,10 +128,11 @@ class Uplink {
                $this->setSetting("recv_timeout", $timeout);
        }
        
-       public function setUplinkServer($numeric, $name, $password) {
+       public function setUplinkServer($numeric, $name, $password, $description) {
                $this->setSetting("numeric", Numerics::intToNum($numeric, 2));
                $this->setSetting("name", $name);
                $this->setSetting("password", $password);
+               $this->setSetting("description", $description);
        }
        
        public function setValidateServer($name, $password) {
@@ -122,6 +152,12 @@ class Uplink {
                }
        }
        
+       private function loginServer() {
+               $password = $this->getSetting("password");
+               $this->send("PASS", $password);
+               $this->send("SERVER", $this->server->getName(), $this->server->getStartTime(), $this->server->getLinkTime(), $this->server->getNumeric(), $this->server->getDescription());
+       }
+       
        private function parseLine($line) {
                $highExplode = explode(" :", $line, 2);
                $tokens = explode(" ", $highExplode[0]);
@@ -143,6 +179,13 @@ class Uplink {
                                $this->recv_error($from, $arguments);
                                break;
                //P10 Session
+                       case "S":
+                               $this->recv_server($from, $arguments);
+                               break;
+                       case "G":
+                               $this->recv_ping($from, $arguments);
+                               break;
+               //default
                        default:
                                //unknown cmd
                                break;
@@ -180,7 +223,32 @@ class Uplink {
        }
        
        private function recv_server($from, $args) {
-               
+               if($from == null) {
+                       //our uplink Server
+                       $their_name = $this->getSetting("their_name");
+                       if($their_name && $args[0] != $their_name) {
+                               $this->flags |= self::FLAG_SECURITY_QUIT;
+                               $this->send("ERROR", "Invalid Server name");
+                               $this->client->disconnect();
+                               return;
+                       }
+                       $new_server = new P10_Server($args[0], substr($args[5],0,2), $this->server, $args[2], $args[3], $args[7]);
+                       $this->server->add_server($new_server);
+                       $this->flags |= self::FLAG_P10SESSION;
+               } else {
+                       //another server got a new slave server ^^
+                       $server = P10_Server::getServerByNum($from);
+                       if($server == null) {
+                               trigger_error("Parent Server (".$from.") does not exist or was not found on recv_server.", E_USER_ERROR);
+                               return;
+                       }
+                       $new_server = new P10_Server($args[0], substr($args[5],0,2), $server, $args[2], $args[3], $args[7]);
+                       $server->add_server($new_server);
+               }
+       }
+       
+       private function recv_ping($from, $args) {
+               $this->send("Z", $args[0]); //simply PONG
        }
        
 }