Akolosova/hw6

.gitignore

@@ -0,0 +1 @@
+.idea/

README.md

@@ -1,3 +1,42 @@
 # PHP_2023
 
-https://otus.ru/lessons/razrabotchik-php/?utm_source=github&utm_medium=free&utm_campaign=otus
+###Описание/Пошаговая инструкция выполнения домашнего задания:
+
+Консольный чат на сокетах
+Создать логику, размещаемую в двух php-контейнерах (server и client), объединённых общим volume.
+Скрипты запускаются в режиме прослушивания STDIN и обмениваются друг с другом вводимыми сообщениями через unix-сокеты.
+
+- сервер поднимается всегда первым
+- клиент ожидает ввод из STDIN и отправляет сообщения серверу
+- сервер выводит полученное сообщение в STDOUT и отправляет клиенту подтверждение (например, "Received 24 bytes")
+- клиент выводит полученное подтверждение в STDOUT и начинает новую итерацию цикла
+
+###Критерии оценки:
+1. Конструкции @ и die неприемлемы. Вместо них используйте исключения
+2. Принимается только Unix-сокет
+3. Код здесь и далее мы пишем с применением ООП
+4. Код здесь и далее должен быть конфигурируем через файлы настроек типа config.ini
+5. Обратите внимание на паттерн FrontController (он же - единая точка доступа). Все приложения, которые Вы создаёте здесь и далее должны вызываться через один файл, в котором есть ТОЛЬКО
+6. Точка входа - app.php
+7. Сервер и клиент запускаются командами
+php app.php server
+php app.php client
+В app.php только строки
+require_once('/path/to/composer/autoload.php');
+try {
+$app = new App();
+$app->run();
+}
+catch(Exception $e){
+}
+8. Логика чтения конфигураций и работы с сокетами - только в классах.
+
+
+
+Порядок действий для запуска app
+
+1. docker-compose up --build -d
+2. docker-compose run server composer install
+3. docker-compose run server php app.php server
+4. docker-compose run server php app.php client
+5. exit

app/.gitignore

@@ -0,0 +1,2 @@
+.env
+.idea/

app/docker-compose.yaml

@@ -0,0 +1,33 @@
+version: "3"
+
+services:
+  server:
+    build:
+      context: ./fpm
+      dockerfile: Dockerfile
+    image: hw6/server
+    container_name: server
+    volumes:
+      - ./www:/var/www
+      - ./socket:/var/www/application.local/socket/
+    networks:
+      - app-network
+
+  client:
+    build:
+      context: ./fpm
+      dockerfile: Dockerfile
+    image: hw6/client
+    container_name: client
+    volumes:
+      - ./www:/var/www
+      - ./socket:/var/www/application.local/socket/
+    networks:
+      - app-network
+
+networks:
+  app-network:
+    driver: bridge
+
+volumes:
+  socket:

app/fpm/Dockerfile

@@ -0,0 +1,10 @@
+FROM php:8.2-fpm
+
+RUN apt-get update  \
+    && apt-get install -y \
+    && docker-php-ext-install sockets \
+    && curl -sS https://getcomposer.org/installer | php -- --install-dir=/usr/local/bin --filename=composer
+
+WORKDIR /var/www/application.local
+
+CMD ["php-fpm"]

app/www/.gitignore

@@ -0,0 +1,2 @@
+.idea/
+/vendor

app/www/application.local/app.php

@@ -0,0 +1,14 @@
+<?php
+
+declare(strict_types=1);
+
+use App\App;
+
+require __DIR__ . "/../vendor/autoload.php";
+
+try {
+    $app = new App($argv, $argc);
+    $app->run();
+} catch (Exception $e) {
+    echo $e->getMessage();
+}

app/www/application.local/config/config.ini

@@ -0,0 +1,2 @@
+[socket]
+file = /var/www/application.local/socket/socket_hw6.sock

app/www/application.local/src/App.php

@@ -0,0 +1,45 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App;
+
+use InvalidArgumentException;
+
+class App
+{
+    private string $mode;
+    private Socket $socket;
+
+    public function __construct($argv, $argc)
+    {
+        if ($argc < 2) {
+            throw new InvalidArgumentException('Usage: php app.php server|client');
+        }
+
+        $this->mode = $argv[1] ?? '';
+
+        if (!in_array($this->mode, ['server', 'client'])) {
+            throw new InvalidArgumentException('Invalid mode. Use "server" or "client".');
+        }
+    }
+
+    public function run()
+    {
+        $config = parse_ini_file('config/config.ini', true);
+        $file = $config['socket']['file'];
+
+        $this->socket = new Socket($file);
+
+        switch ($this->mode) {
+            case 'server':
+                $server = new Server($this->socket);
+                $server->start();
+                break;
+            case 'client':
+                $client = new Client($this->socket);
+                $client->start();
+                break;
+        }
+    }
+}

app/www/application.local/src/Client.php

@@ -0,0 +1,36 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App;
+
+class Client
+{
+    protected Socket $socket;
+
+    public function __construct(Socket $socket)
+    {
+        $this->socket = $socket;
+    }
+
+    public function start()
+    {
+        $this->socket->connect();
+
+        echo "To exit, type 'exit'\n";
+
+        while (true) {
+            $message = readline("Enter message: ");
+            $this->socket->write($message);
+
+            if ($message === 'exit') {
+                $this->socket->write($message);
+                $this->socket->close();
+                break;
+            }
+
+            $confirmation = $this->socket->read();
+            echo "Server confirmation: {$confirmation}\n";
+        }
+    }
+}

app/www/application.local/src/Server.php

@@ -0,0 +1,35 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App;
+
+class Server
+{
+    protected Socket $socket;
+    private $isRunning = true;
+
+    public function __construct(Socket $socket)
+    {
+        $this->socket = $socket;
+    }
+
+    public function start()
+    {
+        $this->socket->bind();
+        $this->socket->listen();
+        $this->socket->accept();
+
+        while ($this->isRunning) {
+            $message = $this->socket->receive();
+
+            if ($message === 'exit') {
+                $this->isRunning = false;
+                $this->socket->close();
+            } else {
+                echo "Received: {$message}\n";
+                $this->socket->write("Received " . strlen($message) . " bytes");
+            }
+        }
+    }
+}

app/www/application.local/src/Socket.php

@@ -0,0 +1,74 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App;
+
+class Socket
+{
+    protected \Socket $socket;
+    private string $path;
+    const BACKLOG_SIZE = 5;
+    const MAX_SIZE_MESSAGE = 2048;
+
+    public function __construct($path)
+    {
+        $this->socket = socket_create(AF_UNIX, SOCK_STREAM, 0);
+        $this->path = $path;
+    }
+
+    public function read()
+    {
+        $result = socket_read($this->socket, 2048);
+
+        if ($result === false) {
+            $error = socket_last_error();
+            echo "Socket read error: " . socket_strerror($error);
+            $this->close();
+        }
+        return $result;
+    }
+
+    public function write($data)
+    {
+        socket_write($this->socket, $data, strlen($data));
+    }
+
+    public function listen()
+    {
+        socket_listen($this->socket, self::BACKLOG_SIZE);
+    }
+
+    public function accept()
+    {
+        $_socket = socket_accept($this->socket);
+
+        if ($_socket === false) {
+            $error = socket_last_error();
+            throw new \RuntimeException("Socket accept error: " . socket_strerror($error));
+        }
+
+        $this->socket = $_socket;
+    }
+
+    public function connect()
+    {
+        socket_connect($this->socket, $this->path);
+    }
+
+    public function bind()
+    {
+        socket_bind($this->socket, $this->path);
+    }
+
+    public function close()
+    {
+        socket_close($this->socket);
+    }
+
+    public function receive(): string
+    {
+        socket_recv($this->socket, $message, self::MAX_SIZE_MESSAGE, 0);
+        return $message ?? '';
+    }
+}

app/www/composer.json

@@ -0,0 +1,19 @@
+{
+    "name": "alisa/hw6",
+    "type": "project",
+    "autoload": {
+        "psr-4": {
+            "App\\": "application.local/src/"
+        }
+    },
+    "authors": [
+        {
+            "name": "Alisa",
+            "email": "[email protected]"
+        }
+    ],
+    "require": {
+        "ext-sockets": "*",
+        "ext-readline": "*"
+    }
+}