Feature: demo 6, reverse proxy for secure web socket connection

Author: seba1rx

DEMO6/MockMsg.php

@@ -0,0 +1,65 @@
+<?php
+
+declare(strict_types=1);
+
+namespace DEMO6;
+
+class MockMsg{
+
+    private static $greetings = [
+        "Hello",
+        "How do you do",
+        "it's been a while",
+        "how're you doing",
+        "Nice to meet you",
+        "how's it going?",
+        "what's up",
+        "Hi",
+        "Good morning",
+        "Good to see you again",
+        "hahahaha",
+        "What time is it?",
+        "I'm tired!!!",
+        "what about Joe?",
+        "is anyone interested in gardening?",
+        "Nahhh",
+        "I'm off",
+        "I'm hungry, who is up for McDonalds??",
+        "lets go get some McDonalds!!!!",
+        "I've got a lot to do",
+        "hey, you again?",
+        "I thought it was just me!",
+        "hooooorayyy!!",
+        "I need to go feed my pets, bye",
+        "how many cats do you have",
+        "I don't have any cats, just dogs",
+        "but how many then",
+        "four, all small",
+        "wow, thats a lot",
+        "it gets worse and worse by the minute",
+        "are you doing something this weekend?",
+        "I want to go to the movies",
+        "I rather just stay at home",
+        "well, that escalated quickly",
+        "hola, mucho gusto",
+        "do you speak spanish?",
+        "na, just know enough to say hello hahahah",
+        "Hey I saw you the last night, you were buyng a burrito!",
+        "mmmm, last time I went out for a burrito was 2 weeks ago, so I think it wasn't me, sorry",
+        "oh",
+        "dammit, now I'm thinking about getting a burrito!",
+        "ok, lets go to that burrito joint near the train station, see you there in 15",
+        "ahhh damn, no, sorry, it will have to be in 40, I need to get the washing machine going and then I can go out",
+    ];
+
+    public static function getRandomMockGreeting(): string
+    {
+        $key = array_rand(self::$greetings);
+        return self::$greetings[$key];
+    }
+
+    public static function getGreetingsArray(): array
+    {
+        return self::$greetings;
+    }
+}

DEMO6/bin/otherInternalClient.php

@@ -0,0 +1,35 @@
+<?php
+
+use Rx\Thruway\Client;
+use DEMO6\MockMsg;
+use Thruway\Message\ResultMessage;
+
+require __DIR__ . '/../vendor/autoload.php';
+
+/**
+ * This client is intended to produce trafic by publishing random content
+ * to the "demo6" topic every 5 seconds
+ */
+
+ $theRealm = [
+    "name" => "somerealm",
+    "signature" => "letMeIn"
+];
+
+$client = new Client('ws://127.0.0.1:9090', $theRealm['name'], ['authmethods' => ['simplysimple']]);
+
+$client->onChallenge(function() use ($theRealm) {
+    return $theRealm['signature'];
+});
+
+$source = \Rx\Observable::interval(5000)->do(function () use ($client){
+    $client->publish('demo6', json_encode(MockMsg::getRandomMockGreeting()));
+});
+
+// subscribe
+$client
+    ->topic('demo6')
+    ->subscribe();
+
+// publish
+$client->publish('demo6',  $source->subscribe());

DEMO6/bin/router.php

@@ -0,0 +1,35 @@
+<?php
+
+
+require __DIR__ . "/../../vendor/autoload.php";
+
+use Thruway\Peer\Router;
+use Thruway\Transport\RatchetTransportProvider;
+
+$theRealm = [
+    "name" => "somerealm",
+    "signature" => "letMeIn"
+];
+
+$router = new Router();
+$loop = $router->getLoop();
+
+// lets use the default transport
+$transportProvider = new RatchetTransportProvider("127.0.0.1", 9090);
+
+$router->addTransportProvider($transportProvider);
+
+// lets use the demo3 auth provider client in order not to bloat the demo with duplicate files
+$realmAuthProvider = new \DEMO3\AuthProviderClient([$theRealm["name"]], $loop);
+$realmAuthProvider->setSignature($theRealm["signature"]);
+
+/** adds auth provider client in router */
+$router->addInternalClient($realmAuthProvider);
+
+/** registers the authentication module so it requires the auth provider client */
+$router->registerModule(new \Thruway\Authentication\AuthenticationManager());
+
+// we will need the loop object to create the periodic publishing to the topic "demo6"
+$router->addInternalClient(new \DEMO6\InternalClient6($theRealm["name"], $loop));
+
+$router->start();

DEMO6/internalClient6.php

@@ -0,0 +1,52 @@
+<?php
+
+namespace DEMO6;
+
+use Thruway\Logging\Logger;
+
+/**
+ * Class InternalClient6 based on Examples/MetaEvent/InternalClient.php
+ *
+ *
+*/
+class InternalClient6 extends \Thruway\Peer\Client
+{
+    /**
+     * List sessions info
+     *
+     * @var array
+     */
+    protected $_sessions = [];
+
+    /**
+     * Constructor
+     */
+    public function __construct($realm_name, \React\EventLoop\LoopInterface $loop)
+    {
+        parent::__construct($realm_name, $loop);
+    }
+
+    /**
+     * @param \Thruway\ClientSession $session
+     * @param \Thruway\Transport\TransportInterface $transport
+     */
+    public function onSessionStart($session, $transport)
+    {
+        Logger::debug($this, "--------------- Hello from InternalClient ------------");
+        Logger::debug($this, "registering getphpversion");
+
+        $session->register('getphpversion', [$this, 'getPhpVersion']);
+    }
+
+    /**
+     * Handle get PHP version
+     *
+     * @return array
+     */
+    public function getPhpVersion()
+    {
+        return [phpversion()];
+    }
+
+
+}