Migrate to Ratchet Pawl instead of Textalk websocket client.

composer.json

@@ -45,7 +45,7 @@
     "sciactive/hookphp": "^2.0",
     "cboden/ratchet": "0.4.*",
     "zendframework/zend-log": "2.*",
-    "textalk/websocket": "1.2.*"
+    "ratchet/pawl": "^0.3.4"
   },
   "require-dev": {
     "squizlabs/php_codesniffer": "3.*"

src/HookMethods.php

@@ -1,7 +1,6 @@
 <?php namespace Nymph\PubSub;
 
 use SciActive\Hook;
-use WebSocket\Client as TextalkWebSocketClient;
 
 class HookMethods {
   public static function setup() {
@@ -181,8 +180,12 @@ function (&$return, $name, &$object, &$function, &$data) {
 
   public static function sendMessage($message) {
     foreach (Server::$config['entries'] as $host) {
-      $client = new TextalkWebSocketClient($host);
-      $client->send($message);
+      \Ratchet\Client\connect($host)->then(function($conn) use ($message) {
+        $conn->send($message);
+        $conn->close();
+      }, function ($e) {
+        error_log("Could not connect to PubSub: {$e->getMessage()}");
+      });
     }
   }
 }

src/MessageHandler.php

@@ -2,7 +2,6 @@
 
 use Ratchet\MessageComponentInterface;
 use Ratchet\ConnectionInterface;
-use WebSocket\Client as TextalkWebSocketClient;
 
 /**
  * Handle subscriptions and publications.
@@ -634,8 +633,12 @@ private function relay($message) {
     }
 
     foreach (Server::$config['relays'] as $host) {
-      $client = new TextalkWebSocketClient($host);
-      $client->send($message);
+      \Ratchet\Client\connect($host)->then(function($conn) use ($message) {
+        $conn->send($message);
+        $conn->close();
+      }, function ($e) {
+        $this->logger->error("Could not connect to PubSub relay: {$e->getMessage()}");
+      });
     }
   }