Домашнее задание №6 - реализация чата на сокетах

chat/app.php

@@ -0,0 +1,14 @@
+<?php
+
+use Anna\Chat\App;
+
+require __DIR__ . '/vendor/autoload.php';
+
+try {
+    $app = new App();
+    foreach ($app->run() as $message) {
+        echo $message;
+    }
+} catch (Exception $e) {
+    echo $e->getMessage() . PHP_EOL;
+}

chat/composer.json

@@ -0,0 +1,19 @@
+{
+    "name": "anna/chat",
+    "type": "project",
+    "autoload": {
+        "psr-4": {
+            "Anna\\Chat\\": "src/"
+        }
+    },
+    "authors": [
+        {
+            "name": "Anton Shishak",
+            "email": "ashishak@awardwallet.com"
+        }
+    ],
+    "require": {
+      "ext-sockets": "*",
+        "ext-mbstring": "*"
+    }
+}

chat/src/App.php

@@ -0,0 +1,38 @@
+<?php
+
+namespace Anna\Chat;
+
+use Exception;
+
+class App
+{
+    private array $sockets;
+
+    public function __construct()
+    {
+        $this->sockets = [
+            'server' => new ServerSocket(),
+            'client' => new ClientSocket()
+        ];
+    }
+
+    /**
+     * @throws Exception
+     */
+    public function run(): iterable
+    {
+        if (!isset($_SERVER['argv'][1])) {
+            throw new Exception('Empty command.');
+        }
+        $socket = $_SERVER['argv'][1];
+        if (!isset($this->sockets[$socket])) {
+            throw new Exception('Unknown command.');
+        }
+        return $this->setSocket($socket)->run();
+    }
+
+    private function setSocket($socket): Socket
+    {
+        return new $this->sockets[$socket]();
+    }
+}

chat/src/ClientSocket.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace Anna\Chat;
+
+class ClientSocket extends Socket
+{
+    public function run()
+    {
+        while (true) {
+            yield 'Введите сообщение: ';
+            $message = trim(fgets(STDIN)) . PHP_EOL;
+            $this->createSocket();
+            socket_connect($this->socket, $this->host);
+            socket_write($this->socket, $message);
+
+            if (($message = socket_read($this->socket, 1024)) !== false) {
+                yield $message;
+            }
+        }
+    }
+}

chat/src/ServerSocket.php

@@ -0,0 +1,43 @@
+<?php
+
+namespace Anna\Chat;
+
+use Exception;
+
+class ServerSocket extends Socket
+{
+    public function run()
+    {
+        $this->checkExists();
+        $this->createSocket();
+        $this->socketBind();
+        socket_listen($this->socket, 3);
+
+        while (true) {
+            if (($connect = socket_accept($this->socket)) === false) {
+                continue;
+            }
+            if (($message = socket_read($connect, 1024)) !== false) {
+                yield $message;
+                socket_write($connect, 'Received ' . mb_strlen($message, '8bit') . ' bytes' . PHP_EOL);
+            }
+        }
+    }
+
+    private function checkExists()
+    {
+        if (file_exists($this->host)) {
+            unlink($this->host);
+        }
+    }
+
+    /**
+     * @throws Exception
+     */
+    protected function socketBind(): void
+    {
+        if (!socket_bind($this->socket, $this->host)) {
+            throw new Exception("Unable to bind to 'chat.sock' reason: " . socket_strerror(socket_last_error($this->socket)));
+        }
+    }
+}

chat/src/Socket.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace Anna\Chat;
+
+use Exception;
+
+abstract class Socket
+{
+    public $socket;
+    public string $host = 'chat.sock';
+
+    /**
+     * @throws Exception
+     */
+    public function createSocket()
+    {
+        $this->socket = socket_create(AF_UNIX, SOCK_STREAM, 0);
+        if ($this->socket === false) {
+            throw new Exception('Unable create socket.');
+        }
+    }
+}

docker/docker-compose.yaml

@@ -0,0 +1,32 @@
+version: '3'
+
+services:
+  server:
+    build:
+      context: ./php
+      dockerfile: Dockerfile
+    image: server
+    container_name: server
+    volumes:
+      - ./../chat:/var/www
+      - ./phpsocket:/var/run/socket
+    command: "tail -f /dev/null"
+    networks:
+      - otus-network
+
+  client:
+    build:
+      context: ./php
+      dockerfile: Dockerfile
+    image: client
+    container_name: client
+    volumes:
+      - ./../chat:/var/www
+      - ./phpsocket:/var/run/socket
+    command: "tail -f /dev/null"
+    networks:
+      - otus-network
+
+networks:
+  otus-network:
+    driver: bridge

docker/php/Dockerfile

@@ -0,0 +1,9 @@
+FROM php:8.1.22-fpm-alpine
+
+RUN docker-php-ext-install sockets
+
+COPY --from=composer/composer:latest-bin /composer /usr/bin/composer
+
+WORKDIR /var/www
+
+VOLUME /var/www