|
|
@ -80,12 +80,14 @@ $stdin_behaviour = function ($data) use (&$conn, $loop, &$buffer, &$connector, & |
|
|
|
if(!empty($xml) && $conn) { |
|
|
|
$conn->write(trim($xml)); |
|
|
|
//$conn->send(trim($xml));
|
|
|
|
#fwrite(STDERR, colorize(trim($xml), 'yellow')." : ".colorize('sent to XMPP', 'green')."\n");
|
|
|
|
fwrite(STDERR, colorize(trim($xml), 'yellow')." : ".colorize('sent to XMPP', 'green')."\n"); |
|
|
|
} |
|
|
|
} |
|
|
|
} else { |
|
|
|
$buffer .= $data; |
|
|
|
} |
|
|
|
|
|
|
|
$loop->tick(); |
|
|
|
}; |
|
|
|
|
|
|
|
$xmpp_behaviour = function (React\Stream\Stream $stream) use (&$conn, $loop, &$stdin, $stdin_behaviour, $parser) { |
|
|
@ -115,8 +117,8 @@ $xmpp_behaviour = function (React\Stream\Stream $stream) use (&$conn, $loop, &$s |
|
|
|
$restart = true; |
|
|
|
} |
|
|
|
|
|
|
|
#fwrite(STDERR, colorize($message, 'yellow')." : ".colorize('received', 'green')."\n");
|
|
|
|
#fwrite(STDERR, colorize(getenv('sid'), 'yellow')." widgets : ".\sizeToCleanSize(memory_get_usage())."\n");
|
|
|
|
fwrite(STDERR, colorize($message, 'yellow')." : ".colorize('received', 'green')."\n"); |
|
|
|
fwrite(STDERR, colorize(getenv('sid'), 'yellow')." widgets : ".\sizeToCleanSize(memory_get_usage())."\n"); |
|
|
|
|
|
|
|
\Moxl\API::clear(); |
|
|
|
\RPC::clear(); |
|
|
@ -147,7 +149,7 @@ $xmpp_behaviour = function (React\Stream\Stream $stream) use (&$conn, $loop, &$s |
|
|
|
if(!empty($xml)) { |
|
|
|
$conn->write(trim($xml)); |
|
|
|
//$conn->send(trim($xml));
|
|
|
|
#fwrite(STDERR, colorize(trim($xml), 'yellow')." : ".colorize('sent to XMPP', 'green')."\n");
|
|
|
|
fwrite(STDERR, colorize(trim($xml), 'yellow')." : ".colorize('sent to XMPP', 'green')."\n"); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|