Deleted send method from SocketEndpoint. Added bind, listen and accept methods for socket server creation

Author: example

.gitignore

@@ -1,3 +1,3 @@
 /vendor/
 /.vscode/
-composer.lock.json
+composer.lock

src/Socket.php

@@ -25,7 +25,7 @@ class Socket
      * socket
      * @var string 
      */ 
-    protected string $content;
+    protected string $content = '';
 
     /**
      * Socket constructor method
@@ -49,6 +49,57 @@ public function create()
         return socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
     }
 
+    /**
+     * Binds a name to a socket
+     * @return bool 
+     */ 
+    public function bind()
+    {
+        return socket_bind($this->socket, $this->host, $this->port);
+    }
+
+    /**
+     * Listens for a connection on a socket
+     * @return bool 
+     */ 
+    public function listen()
+    {
+        return socket_listen($this->socket, 1);
+    }
+
+    /**
+     * Accept a connection on a socket 
+     * @return resource  
+     */ 
+    public function accept()
+    {
+        return socket_accept($this->socket);
+    }
+
+    /**
+     * Bind, listen and return accepted socket
+     * connection 
+     * @return resource  
+     */ 
+    public function acceptSocketConnection()
+    {
+        if (!$this->bind()) {
+            return false;
+        }
+
+        if (!$this->listen()) {
+            return false;
+        }
+        
+        $acceptedSocket = $this->accept();
+
+        if (!$acceptedSocket) {
+            return false;
+        }
+
+        return $acceptedSocket;
+    }
+
     /**
      * Initiates a connection on a socket
      * @return bool 
@@ -61,30 +112,26 @@ public function connect()
     }
 
     /**
-     * Write to a socket specified message
+     * Write to a socket specified messages
      * @param string $message 
      * @return int  
      */ 
-    public function write(string $message)
+    public function write($socket, string $message)
     {
         return socket_write(
-            $this->socket, $message, strlen($message)
+            $socket, $message, strlen($message)
         );
     }
 
     /**
      * Reads a maximum of length bytes from a socket
+     * @param resource $socket
      * @return string 
      */ 
-    public function read()
+    public function read($socket)
     {
-        $write = null;
-        $exception = null;
-
-        while(socket_select([$this->socket], $write, $exception, 0)) {
-            socket_recv(
-                $this->socket, $this->content, strlen($this->content), 0
-            );
+        while(socket_recv($socket, $buffer, 2048, 0)) {
+            $this->content .= $buffer;
         }
 
         return $this->content;

src/SocketEndpoint.php

@@ -3,7 +3,6 @@
 namespace WebSocket;
 
 use Websocket\Credential\ICredential;
-use WebSocket\SocketMessage;
 use WebSocket\Socket;
 
 class SocketEndpoint 
@@ -43,36 +42,43 @@ public function getSocket()
     }
 
     /**
-     * Write content from current listening socket
-     * @param string $message 
-     * @return int 
+     * Bind, listen and accept connection on socket.
+     * Usually use when wanted to create server socket 
+     * @return resource|bool
      */ 
-    protected function writeToSocket(string $message)
-    {   
-        return $this->getSocket()->write($message);
+    public function acceptConnectionOnSocket()
+    {
+        return $this->getSocket()->acceptSocketConnection();
     }
 
     /**
-     * Read content from current listening socket
-     * @return string 
+     * Connect to created to socket. Usually use
+     * when wanted to create client socket
+     * @return resource|bool
      */ 
-    protected function readFromSocket()
+    public function connectToSocket()
     {
-        return $this->getSocket()->read();
+        return $this->getSocket()->connect();
     }
 
     /**
-     * Send message on listening socket and
-     * read response from socket
+     * Write content from current listening socket
+     * @param resource $socket 
      * @param string $message 
-     * @return string 
+     * @return int
      */ 
-    public function send(string $message)
-    {
-        if (!$this->writeToSocket($message)) {
-            return false;
-        }
+    protected function writeToSocket($socket, string $message)
+    {   
+        return $this->getSocket()->write($socket, $message);
+    }
 
-        return $this->readFromSocket();
+    /**
+     * Read content from current listening socket
+     * @param resource $socket
+     * @return string
+     */ 
+    protected function readFromSocket($socket)
+    {
+        return $this->getSocket()->read($socket);
     }
 }