fix query format

README.md

@@ -1,6 +1,6 @@
 # nex-php
 
-PHP 8 Library for Nex Protocol
+PHP 8 Library for NEX Protocol (see also [nps-php](https://github.com/YGGverse/nps-php))
 
 ## Usage
 
@@ -10,7 +10,7 @@ composer require yggverse/nex
 
 ## Client
 
-PHP interface for Nex protocol queries
+PHP interface for NEX protocol queries
 
 ``` php
 $client = new \Yggverse\Nex\Client;
@@ -41,7 +41,7 @@ var_dump(
 
 ## Server
 
-Build interactive server instance to listen Nex protocol connections!
+Build interactive server instance to listen NEX protocol connections!
 
 ``` php
 $server = new \Yggverse\Nex\Server;
@@ -73,12 +73,15 @@ $server->start(
     function (
         string $request,
         string $connect
-    ) {
+    ): ?string
+    {
         printf(
             'connection: %s request: %s',
             $connect,
             $request
         );
+
+        return null; // null|string response
     }
 );
 ```
@@ -88,3 +91,7 @@ $server->start(
 Stop server instance.
 
 Same to `Server::setLive(false)`
+
+## Integrations
+
+* [next](https://github.com/YGGverse/next) - PHP 8 Server for NEX Protocol

composer.json

@@ -1,7 +1,7 @@
 {
     "name": "yggverse/nex",
     "description": "PHP 8 Library for Nex Protocol",
-    "keywords": [ "yggverse", "nex", "nex-protocol", "client" ],
+    "keywords": [ "yggverse", "nex", "nex-protocol", "client", "server" ],
     "homepage": "https://github.com/yggverse/nex-php",
     "type": "library",
     "license": "MIT",

src/Client.php

@@ -113,7 +113,10 @@ class Client
             sprintf(
                 "%s%s\r\n",
                 $this->_path,
-                $this->_query
+                $this->_query ? sprintf(
+                    '?%s',
+                    $this->_query
+                ) : null
             )
         );
 

src/Server.php

@@ -108,14 +108,17 @@ class Server
             STREAM_SERVER_BIND | STREAM_SERVER_LISTEN
         );
 
+        if ($this->_live)
+        {
+            $this->_live = is_resource(
+                $socket
+            );
+        }
+
         do
         {
             if (!$this->_live)
             {
-                fclose(
-                    $socket
-                );
-
                 break;
             }
 
@@ -145,6 +148,14 @@ class Server
                     $request,
                     $connect
                 );
+
+                if ($response)
+                {
+                    fwrite(
+                        $incoming,
+                        $response
+                    );
+                }
             }
 
             fclose(
@@ -152,6 +163,13 @@ class Server
             );
 
         } while ($this->_live);
+
+        if (is_resource($socket))
+        {
+            fclose(
+                $socket
+            );
+        }
     }
 
     public function stop(): void