diff --git a/src/ClientHandler.php b/src/ClientHandler.php index b602ece..23ffc94 100644 --- a/src/ClientHandler.php +++ b/src/ClientHandler.php @@ -5,6 +5,7 @@ namespace LanguageServer; use AdvancedJsonRpc; use Sabre\Event\Promise; +use LanguageServer\ProtocolBridge\Message; class ClientHandler { @@ -41,12 +42,12 @@ class ClientHandler { $id = $this->idGenerator->generate(); return $this->protocolWriter->write( - new Protocol\Message( - (new AdvancedJsonRpc\Request($id, $method, (object)$params))->__toString() + new ProtocolBridge\Message( + new AdvancedJsonRpc\Request($id, $method, (object)$params) ) )->then(function () use ($id) { $promise = new Promise; - $listener = function (Protocol\Message $msg) use ($id, $promise, &$listener) { + $listener = function (ProtocolBridge\Message $msg) use ($id, $promise, &$listener) { if (AdvancedJsonRpc\Response::isResponse($msg->body) && $msg->body->id === $id) { // Received a response $this->protocolReader->removeListener('message', $listener); @@ -72,7 +73,7 @@ class ClientHandler public function notify(string $method, $params): Promise { return $this->protocolWriter->write( - new Protocol\Message( + new ProtocolBridge\Message( new AdvancedJsonRpc\Notification($method, (object)$params) ) ); diff --git a/src/Protocol/Message.php b/src/ProtocolBridge/Message.php similarity index 94% rename from src/Protocol/Message.php rename to src/ProtocolBridge/Message.php index 8df5d0e..dd1f3e0 100644 --- a/src/Protocol/Message.php +++ b/src/ProtocolBridge/Message.php @@ -1,9 +1,10 @@ emit('message', [MessageFactory::fromRawMessage((string)$msg)]); + $this->emit('message', [Message::parse((string)$msg)]); }); return Promise\resolve(null); } diff --git a/tests/ProtocolStreamReaderTest.php b/tests/ProtocolStreamReaderTest.php index 69eea37..e18b650 100644 --- a/tests/ProtocolStreamReaderTest.php +++ b/tests/ProtocolStreamReaderTest.php @@ -5,7 +5,7 @@ namespace LanguageServer\Tests; use PHPUnit\Framework\TestCase; use LanguageServer\{LanguageServer, ProtocolStreamReader, ProtocolStreamWriter}; -use LanguageServer\Protocol\Message; +use LanguageServer\ProtocolBridge\Message; use AdvancedJsonRpc\{Request as RequestBody, Response as ResponseBody}; use Sabre\Event\Loop; diff --git a/tests/ProtocolStreamWriterTest.php b/tests/ProtocolStreamWriterTest.php index b67bdcb..331a246 100644 --- a/tests/ProtocolStreamWriterTest.php +++ b/tests/ProtocolStreamWriterTest.php @@ -5,7 +5,7 @@ namespace LanguageServer\Tests; use PHPUnit\Framework\TestCase; use LanguageServer\ProtocolStreamWriter; -use LanguageServer\Protocol\Message; +use LanguageServer\ProtocolBridge\Message; use AdvancedJsonRpc\{Request as RequestBody}; use Sabre\Event\Loop; diff --git a/tests/Validation/ValidationTest.php b/tests/Validation/ValidationTest.php index 9057c9d..288fffc 100644 --- a/tests/Validation/ValidationTest.php +++ b/tests/Validation/ValidationTest.php @@ -13,7 +13,7 @@ use phpDocumentor\Reflection\DocBlock; use phpDocumentor\Reflection\DocBlockFactory; use PHPUnit\Framework\TestCase; use LanguageServer\ClientHandler; -use LanguageServer\Protocol\Message; +use LanguageServer\ProtocolBridge\Message; use AdvancedJsonRpc; use RecursiveDirectoryIterator; use RecursiveIteratorIterator;