Link two websockets together using Pawl

gistfile1.php

<?php
require __DIR__ . '/vendor/autoload.php';

define('DOCUMENT_ROOT', dirname(__FILE__));
require_once(DOCUMENT_ROOT.'/bootstrap.php');

$bootstrap = new Bootstrap();
$booted = $bootstrap->boot();

set_time_limit(200);

$polling = true;

$loop = React\EventLoop\Factory::create();

$dnsResolverFactory = new React\Dns\Resolver\Factory();
$dns = $dnsResolverFactory->createCached('8.8.8.8', $loop);

$connector = new Ratchet\Client\Factory($loop);
/*
$connector_xmpp = new React\SocketClient\Connector($loop, $dns);
$secure_connector_xmpp = new React\SocketClient\SecureConnector($connector_xmpp, $loop);
* $secure_connector_xmpp->create('movim.eu', 5222)*/

React\Promise\all([$connector('ws://127.0.0.1:8080'), $connector('ws://movim.eu:5290/', ['xmpp'])])->then(function($conns) use ($loop) {
    list($conn1, $conn2) = $conns;

    $logger = new \Zend\Log\Logger();
    $writer = new \Zend\Log\Writer\Syslog(array('application' => 'movim_daemon'));
    $logger->addWriter($writer);

    $conn1->on('message', function($msg) use ($conn1, $logger, $conn2) {
        if($msg != '') {
            $rpc = new RPC();
            $rpc->handle_json($msg);
            $logger->notice("LOOP : Got message {$msg}");


            $xml = \Moxl\API::commit();
            \Moxl\API::clear();

            if(!empty($xml)) {
                $logger->notice("LOOP : Send to XMPP {$xml}");
            
                $conn2->send(trim($xml));
            }

            $obj = new \StdClass;
            $obj->func = 'message';
            $obj->body = RPC::commit();
            RPC::clear();

            if(!empty($obj->body)) {
                $conn1->send(json_encode($obj));
            }
        }
    });
    
    $conn2->on('message', function($msg) use ($conn1, $logger) {
        $logger->notice("XMPP : Got message from XMPP {$msg}");

        /*$obj = new \StdClass;
        $obj->func = 'message';
        $obj->body = $msg;
        
        $conn1->send(json_encode($obj));*/

        \Moxl\Xec\Handler::handleStanza($msg);
    });
    
    $conn2->on('error', function($msg) use ($logger) {
        $logger->notice("XMPP : Got error {$msg}");
    });
    
    $conn2->on('close', function($msg) use ($logger, $loop) {
        $loop->stop();
    });

    $obj = new \StdClass;
    $obj->func = 'register_linker';
    $obj->sid  = getenv('sid');

    $conn1->send(json_encode($obj));

}, function($e) {
    $logger = new \Zend\Log\Logger();
    $writer = new \Zend\Log\Writer\Syslog(array('application' => 'movim_daemon'));
    $logger->addWriter($writer);
    
    $logger->notice("LOOP : Error {$e->getMessage()}");
});

$loop->run();

Suggestions:

• Only create one factory
• Use Promise::all to call handlers only after both connections are established

    $connector = new Ratchet\Client\Factory($loop);
    React\Promise\all([$connector('ws://127.0.0.1:8080'), $connector('ws://movim.eu:5290')])->then(function($conns) {
        list($conn1, $conn2) = $conns;
    }, function() {
        // error handler
    });