use PharmaIntelligence\MLLP\Server;
use PharmaIntelligence\HL7\Unserializer;
use React\Socket\ConnectionInterface;

class MyServer extends Server {
    // No added logic in this example
}

$loop = React\EventLoop\Factory::create();
$socket = new React\Socket\Server($loop);
// Set up a React stream to STDOUT to log everything to the console.
$logging = new React\Stream\Stream(STDOUT, $loop);
$server = new MyServer($socket);

// Log connection info
$server->on('connection', function(ConnectionInterface $connection) use($logging) {
    $logging->write('Connection from: '.$connection->getRemoteAddress().PHP_EOL);
});

// Log error info
$server->on('error', function($errorMessage) use($logging)  {
    $logging->write('Error: '.$errorMessage.PHP_EOL);
});

// Log sent data
$server->on('send', function($data) use($logging)  {
    $logging->write('Sending: '.str_replace(chr(13), PHP_EOL, $data).PHP_EOL);
});

// Log received data
$server->on('data', function($data) use($logging)  {
    $logging->write('Received: '.str_replace(chr(13), PHP_EOL, $data).PHP_EOL);
});
$server->on('data', function ($data, ConnectionInterface $connection) use($server) {
    // $data contains a HL7 Payload
    // Parse HL7 and create an ACK message
    $ack = 'AN_ACK_STRING';
    $server->send($ack, $connection);
    $connection->end();
});
$socket->listen(23887);

$loop->run();