Merge pull request #3 from rubyqorn/dev-socket-implementation

Created socket manipulator class

Author: rubyqorn

.gitignore

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

src/Socket.php

@@ -2,28 +2,100 @@
 
 namespace WebSocket;
 
-use Websocket\Credential\ICredential;
-
 class Socket 
 {
-    protected ?ICredential $credential;
+    /**
+     * @var string 
+     */ 
+    protected string $host;
+
+    /**
+     * @var string 
+     */ 
+    protected string $port;
+
+    /**
+     * Current listening socket
+     * @var resource 
+     */ 
+    protected $socket;
+
+    /**
+     * Readed message from listening
+     * socket
+     * @var string 
+     */ 
+    protected string $content;
+
+    /**
+     * Socket constructor method
+     * @param string $host 
+     * @param string $port  
+     */ 
+    public function __construct(string $host, string $port)
+    {
+        $this->host = $host;
+        $this->port = $port;
+        $this->socket = $this->create();
+    }
 
     /**
-     * DI of SocketCredentials
-     * @param \Websocket\Credential\ICredential $credential
-     * @return void 
+     * Creates and returns a socket resource, also 
+     * referred to as an endpoint of communication 
+     * @return resource
      */ 
-    public function setCredentials(ICredential $credential)
+    public function create()
     {
-        $this->credential = $credential;
+        return socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
+    }
+
+    /**
+     * Initiates a connection on a socket
+     * @return bool 
+     */ 
+    public function connect()
+    {
+        return socket_connect(
+            $this->socket, $this->host, $this->port
+        );
+    }
+
+    /**
+     * Write to a socket specified message
+     * @param string $message 
+     * @return int  
+     */ 
+    public function write(string $message)
+    {
+        return socket_write(
+            $this->socket, $message, strlen($message)
+        );
+    }
+
+    /**
+     * Reads a maximum of length bytes from a socket
+     * @return string 
+     */ 
+    public function read()
+    {
+        $write = null;
+        $exception = null;
+
+        while(socket_select([$this->socket], $write, $exception, 0)) {
+            socket_recv(
+                $this->socket, $this->content, strlen($this->content), 0
+            );
+        }
+
+        return $this->content;
     }
 
     /**
-     * Return instance of SocketCredentials
-     * @return SocketCredentials
+     * Socket detructor method which 
+     * close current listening socket 
      */ 
-    public function getCredentials()
+    public function __destruct()
     {
-        return $this->credential;
+        socket_close($this->socket);
     }
 }

src/SocketEndpoint.php

@@ -0,0 +1,78 @@
+<?php 
+
+namespace WebSocket;
+
+use Websocket\Credential\ICredential;
+use WebSocket\SocketMessage;
+use WebSocket\Socket;
+
+class SocketEndpoint 
+{
+    protected ?ICredential $credential;
+
+    /**
+     * DI of SocketCredentials
+     * @param \Websocket\Credential\ICredential $credential
+     * @return void 
+     */ 
+    public function setCredentials(ICredential $credential)
+    {
+        $this->credential = $credential;
+    }
+
+    /**
+     * Return instance of SocketCredentials
+     * @return SocketCredentials
+     */ 
+    public function getCredentials()
+    {
+        return $this->credential;
+    }
+
+    /**
+     * Socket factory method which manipulate
+     * PHP socket API
+     * @return \WebSocket\Socket 
+     */ 
+    public function getSocket()
+    {
+        return new Socket(
+            $this->getCredentials()->getCredential('host'),
+            $this->getCredentials()->getCredential('port')
+        );
+    }
+
+    /**
+     * Write content from current listening socket
+     * @param string $message 
+     * @return int 
+     */ 
+    protected function writeToSocket(string $message)
+    {   
+        return $this->getSocket()->write($message);
+    }
+
+    /**
+     * Read content from current listening socket
+     * @return string 
+     */ 
+    protected function readFromSocket()
+    {
+        return $this->getSocket()->read();
+    }
+
+    /**
+     * Send message on listening socket and
+     * read response from socket
+     * @param string $message 
+     * @return string 
+     */ 
+    public function send(string $message)
+    {
+        if (!$this->writeToSocket($message)) {
+            return false;
+        }
+
+        return $this->readFromSocket();
+    }
+}

src/SocketMessage.php

@@ -0,0 +1,13 @@
+<?php 
+
+namespace WebSocket;
+
+class SocketMessage
+{
+    protected $message;
+
+    public function __construct(string $message)
+    {
+        $this->message = $message;
+    }
+}