gets possible client Local Address

ch3k1 · Nov 29, 2016 · 3676292 · 3676292
1 parent f242861
commit 3676292
Show file tree

Hide file tree

Showing 3 changed files with 29 additions and 6 deletions.
diff --git a/lib/bin/server.php b/lib/bin/server.php
@@ -1,20 +1,19 @@
 <?php
+
     require dirname(__DIR__) . '/vendor/autoload.php';
-
-    $ipaddress = isset($_SERVER['SERVER_ADDR'])?$_SERVER['SERVER_ADDR']:gethostbyname(gethostname());
+    $address = new SquidApp\Request();
     $loop   = React\EventLoop\Factory::create();
     $pusher = new SquidApp\Pusher;
 
-
     // Listen for the web server to make a ZeroMQ push after an ajax request
     $context = new React\ZMQ\Context($loop);
     $pull = $context->getSocket(ZMQ::SOCKET_PULL);
     $pull->bind('tcp://127.0.0.1:5555'); // Binding to 127.0.0.1 means the only client that can connect is itself
-    $pull->on('message', array($pusher, 'onBlogEntry'));
+    $pull->on('message', array($pusher, 'onNetworkEntry'));
 
     // Set up our WebSocket server for clients wanting real-time updates
     $webSock = new React\Socket\Server($loop);
-    $webSock->listen(8080, $ipaddress); // Binding to 0.0.0.0 means remotes can connect
+    $webSock->listen(8080, $address->getClientAddress()); // Binding to 0.0.0.0 means remotes can connect
     $webServer = new Ratchet\Server\IoServer(
         new Ratchet\Http\HttpServer(
             new Ratchet\WebSocket\WsServer(

diff --git a/lib/src/SquidApp/Pusher.php b/lib/src/SquidApp/Pusher.php
@@ -11,11 +11,13 @@ public function onSubscribe(ConnectionInterface $conn, $topic) {
 
     }
 
-    public function onBlogEntry($entry) {
+    public function onNetworkEntry($entry) {
 
         $db = new Database();
 
         $entryData = json_decode($entry, true);
+
+        print_r($entryData);
 
         if (!array_key_exists($entryData['squidmagic'] , $this->subscribedTopics)) {
             return;

diff --git a/lib/src/SquidApp/Request.php b/lib/src/SquidApp/Request.php
@@ -0,0 +1,22 @@
+<?php
+
+namespace SquidApp;
+
+/**
+* Gets client Address.
+*/
+class Request
+{
+	public $address;
+
+	public function __construct($address = null)
+	{
+		$this->address = $address;
+	}
+
+	public function getClientAddress()
+	{
+	  $this->address = isset($_SERVER['SERVER_ADDR'])?$_SERVER['SERVER_ADDR']:gethostbyname(gethostname());
+      return $this->address;
+	}
+}