Implemented socket endpoint and siblings server and client classes

Author: example

.gitignore

@@ -0,0 +1,61 @@
+<?php
+
+namespace WebSocket;
+
+class Client extends SocketEndpoint implements ISocketImplementer
+{
+    /**
+     * Create socket using connectToSocket
+     * method
+     * @var resource
+     */ 
+    private $createdSocket;
+
+    /**
+     * Create connection for server socket
+     * @return resource|\WebSocket\SocketError 
+     */ 
+    public function create()
+    {
+        $this->createdSocket = $this->connectToSocket();
+
+        if (!$this->createdSocket) {
+            return new SocketError('Can\'t create and connect to socket');
+        }
+
+        return $this->createdSocket;
+    }
+
+    /**
+     * Read message from created server socket
+     * @return \WebSocket\SocketError|WebSocket\SocketMessage 
+     */ 
+    public function read()
+    {
+        $responseFromSocket = new SocketMessage(
+            $this->readFromSocket($this->createdSocket)
+        );
+
+        if (!$responseFromSocket->getSocketResponse()) {
+            return new SocketError('Can\'t read from server socket');
+        }
+
+        return $responseFromSocket;
+    }
+
+    /**
+     * Write message to created server socket
+     * @param string $message
+     * @return int|\WebSocket\SocketError 
+     */ 
+    public function write(string $message)
+    {
+        $writtenSocket = $this->write($message);
+
+        if (!$writtenSocket) {
+            return new SocketError('Can\'t write to server socket');
+        }
+
+        return $writtenSocket;
+    }
+}

README.md

@@ -0,0 +1,22 @@
+<?php 
+
+namespace WebSocket;
+
+interface ISocketImplementer
+{
+    /**
+     * Initiate socket connection 
+     */ 
+    public function create();
+
+    /**
+     * Read message from initiated socket 
+     */ 
+    public function read();
+
+    /**
+     * Write message to initiated socket 
+     * @param string $message 
+     */ 
+    public function write(string $message);
+}

composer.json

@@ -0,0 +1,61 @@
+<?php 
+
+namespace WebSocket;
+
+class Server extends SocketEndpoint implements ISocketImplementer
+{
+    /**
+     * Socket resource created using 
+     * acceptSocketConnection method
+     * @var resource 
+     */ 
+    protected $createdSocket;
+
+    /**
+     * Accept client socket connection
+     * @return resource|\WebSocket\SocketError 
+     */ 
+    public function create()
+    {
+        $this->createdSocket = $this->acceptConnectionOnSocket();
+
+        if (!$this->createdSocket) {
+            return new SocketError('Can\'t accepted connected socket');
+        }
+
+        return $this->createdSocket;
+    }
+
+    /**
+     * Read message from accepted client socket 
+     * @return \WebSocket\SocketError|\WebSocket\SocketMessage 
+     */ 
+    public function read()
+    {
+        $socketResponse = new SocketMessage(
+            $this->readFromSocket($this->createdSocket)
+        );
+
+        if (!$socketResponse->getSocketResponse()) {
+            return new SocketError('Can\'t read message from client socket');
+        }
+
+        return $socketResponse;
+    }
+
+    /**
+     * Write message to client accepted socket 
+     * @param string $message 
+     * @return int|\WebSocket\SocketError 
+     */ 
+    public function write(string $message)
+    {
+        $writtenMessage = $this->writeToSocket($this->createdSocket, $message);
+
+        if (!$writtenMessage) {
+            return new SocketError('Can\'t write to accepted client socket');
+        }
+
+        return $writtenMessage;
+    }
+}

phpunit.xml

@@ -100,15 +100,28 @@ public function acceptSocketConnection()
         return $acceptedSocket;
     }
 
+    /**
+     * Return resource of type Socket
+     * which was created right now. Can get
+     * access by connect method 
+     * @return resource 
+     */ 
+    public function getConnectedSocket()
+    {
+        return $this->socket;
+    }
+
     /**
      * Initiates a connection on a socket
-     * @return bool 
+     * @return \WebSocket\Socket 
      */ 
     public function connect()
     {
-        return socket_connect(
+        socket_connect(
             $this->socket, $this->host, $this->port
         );
+
+        return $this;
     }
 
     /**

src/Client.php

@@ -33,7 +33,7 @@ public function getCredentials()
      * PHP socket API
      * @return \WebSocket\Socket 
      */ 
-    public function getSocket()
+    protected function getSocket()
     {
         return new Socket(
             $this->getCredentials()->getCredential('host'),
@@ -46,7 +46,7 @@ public function getSocket()
      * Usually use when wanted to create server socket 
      * @return resource|bool
      */ 
-    public function acceptConnectionOnSocket()
+    protected function acceptConnectionOnSocket()
     {
         return $this->getSocket()->acceptSocketConnection();
     }
@@ -56,9 +56,9 @@ public function acceptConnectionOnSocket()
      * when wanted to create client socket
      * @return resource|bool
      */ 
-    public function connectToSocket()
+    protected function connectToSocket()
     {
-        return $this->getSocket()->connect();
+        return $this->getSocket()->connect()->getConnectedSocket();
     }
 
     /**

src/ISocketImplementer.php

@@ -0,0 +1,31 @@
+<?php 
+
+namespace WebSocket;
+
+class SocketError
+{
+    /**
+     * Socket error message
+     * @var string 
+     */ 
+    private string $errorMessage;
+
+    /**
+     * Initiate constructor method of SocketError
+     * @var string $error 
+     * @return void
+     */ 
+    public function __construct(string $error)
+    {
+        $this->errorMessage = $error;
+    }
+
+    /**
+     * Return setted socket error
+     * @return string 
+     */ 
+    public function getSocketError()
+    {
+        return $this->errorMessage;
+    }
+}