HW-3 Чат на вебсокетах!

.docker/php/Dockerfile

@@ -0,0 +1,14 @@
+FROM php:7.4-fpm
+
+WORKDIR /var/www/app
+
+RUN apt-get update \
+	&& apt-get install -y \
+		git \
+		curl \
+		libzip-dev \
+    && docker-php-ext-install -j$(nproc) \
+    	sockets \
+    && docker-php-ext-configure \
+    	sockets --enable-sockets \
+    && php -r "readfile('http://getcomposer.org/installer');" | php -- --install-dir=/usr/bin/ --filename=composer

.gitignore

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

README.md

@@ -1 +1,14 @@
-# PHP2021
+# PHP2021
+
+https://otus.ru/lessons/razrabotchik-php/?utm_source=github&utm_medium=free&utm_campaign=otus
+
+
+## HW-3
+###Запуск сервера
+![Запуск сервера](screenshots/up_server.png)
+
+###Запуск клиента
+![Запуск сервера](screenshots/up_client.png)
+
+###Чат работает
+![Запуск сервера](screenshots/chat_work.png)

app

@@ -0,0 +1,14 @@
+#!/usr/local/bin/php
+
+<?php
+require "vendor/autoload.php";
+
+use Ivanboriev\SocketChat\App;
+
+$app = new App();
+
+try {
+    $app->run($argv[1]);
+} catch (Exception $e) {
+    $app->error($e->getMessage());
+}

composer.json

@@ -0,0 +1,16 @@
+{
+  "name": "ivanboriev/socket-chat",
+  "description": "Socket chat",
+  "type": "project",
+  "autoload": {
+
+    "psr-4": {
+      "Ivanboriev\\SocketChat\\": "src/"
+    }
+  },
+  "require": {
+    "php": ">=7.4",
+    "ext-json": "*",
+    "ext-sockets": "*"
+  }
+}

docker-compose.yaml

@@ -0,0 +1,32 @@
+version: '3'
+
+services:
+  server:
+    build:
+      context: .docker/php
+      dockerfile: Dockerfile
+    image: ivanboriev/socket-chat
+    container_name: socket-server
+    volumes:
+      - .:/var/www/app
+
+    networks:
+      - chat-network
+
+
+  client:
+    build:
+      context: .docker/php
+      dockerfile: Dockerfile
+    image: ivanboriev/socket-chat
+    container_name: socket-client
+    volumes:
+      - .:/var/www/app
+
+    networks:
+      - chat-network
+
+
+networks:
+  chat-network:
+    driver: bridge

src/App.php

@@ -0,0 +1,51 @@
+<?php
+
+namespace Ivanboriev\SocketChat;
+
+use Exception;
+use Ivanboriev\SocketChat\Exceptions\UnknownCommandException;
+use Ivanboriev\SocketChat\Server\Server;
+use Ivanboriev\SocketChat\Client\Client;
+use Ivanboriev\SocketChat\Traits\HasMessage;
+
+class App
+{
+    use HasMessage;
+
+    private array $config;
+
+    public function __construct()
+    {
+        $this->config = parse_ini_file('config.ini');
+    }
+
+    /**
+     * @throws Exception
+     */
+    public function run($type): void
+    {
+        switch ($type) {
+            case 'server':
+                $this->runServer();
+                break;
+            case 'client' :
+                $this->runClient();
+                break;
+            default:
+                throw new UnknownCommandException($type . ' - неизвестная команда');
+        }
+    }
+
+
+    private function runServer()
+    {
+        (new Server)->run($this->config);
+    }
+
+
+    private function runClient()
+    {
+        (new Client)->run($this->config);
+    }
+
+}

src/Client/Client.php

@@ -0,0 +1,103 @@
+<?php
+
+namespace Ivanboriev\SocketChat\Client;
+
+use Ivanboriev\SocketChat\Exceptions\SocketBindException;
+use Ivanboriev\SocketChat\Exceptions\SocketListenException;
+use Ivanboriev\SocketChat\Exceptions\SocketReadException;
+use Ivanboriev\SocketChat\Exceptions\SocketWriteException;
+use Ivanboriev\SocketChat\Traits\HasMessage;
+
+class Client
+{
+    use HasMessage;
+
+    /** @var false|resource|\Socket */
+    private $socket;
+
+    /** @var false|resource|\Socket */
+    private $connection;
+
+    private array $config;
+
+    /**
+     * @throws SocketListenException
+     * @throws SocketBindException
+     */
+    public function run(array $config): void
+    {
+        $this->config = $config;
+
+        $this->initConnection();
+        $this->sendMessages();
+        $this->closeConnection();
+    }
+
+    /**
+     * @throws SocketBindException
+     * @throws \Exception
+     */
+    private function initConnection()
+    {
+        $this->info("Поднимаю соединение...");
+
+        $this->socket = socket_create(AF_UNIX, SOCK_STREAM, 0);
+
+        if (!socket_connect($this->socket, $this->config['SOCKET_PATH'])) {
+            throw new SocketBindException;
+        }
+
+        $this->info('Соединение установлено, введите сообщение...');
+
+    }
+
+    private function sendMessages()
+    {
+        do {
+            $this->send('Введите сообщение: ');
+
+            try {
+                $message = trim(fgets(STDIN));
+
+                $this->sendMessage($message);
+
+                $this->send($this->getMessage());
+            } catch (\Exception $e) {
+                $this->error($e->getMessage());
+            }
+
+
+        } while ($message !== $this->config['EXIT_MSG']);
+
+    }
+
+    /**
+     * @throws \Exception
+     */
+    private function sendMessage(string $message): void
+    {
+        if (socket_write($this->socket, $message, strlen($message)) === false) {
+            throw new SocketWriteException;
+        }
+    }
+
+    /**
+     * @throws \Exception
+     */
+    private function getMessage(): string
+    {
+        $message = socket_read($this->socket, 1024);
+        if ($message === false) {
+            throw new SocketReadException;
+        }
+
+        return "Ответ от сервера: " . $message;
+    }
+
+    private function closeConnection()
+    {
+        $this->info("Закрываем соединение...");
+        socket_close($this->socket);
+        $this->info("Соединение закрыто");
+    }
+}

src/Exceptions/ErrorStartingServerException.php

@@ -0,0 +1,7 @@
+<?php
+namespace Ivanboriev\SocketChat\Exceptions;
+
+class ErrorStartingServerException extends \Exception
+{
+    protected $message = "Ошибка при запуске сервера";
+}

src/Exceptions/SocketBindException.php

@@ -0,0 +1,7 @@
+<?php
+namespace Ivanboriev\SocketChat\Exceptions;
+
+class SocketBindException extends \Exception
+{
+    protected $message = "Не удалось установить соединение с сокетом";
+}

src/Exceptions/SocketListenException.php

@@ -0,0 +1,8 @@
+<?php
+namespace Ivanboriev\SocketChat\Exceptions;
+
+
+class SocketListenException extends \Exception
+{
+    protected $message = "Невозможно прослушать сокет";
+}

src/Exceptions/SocketReadException.php

@@ -0,0 +1,8 @@
+<?php
+namespace Ivanboriev\SocketChat\Exceptions;
+
+
+class SocketReadException extends \Exception
+{
+    protected $message = "Невозможно прочитать сокет";
+}

src/Exceptions/SocketWriteException.php

@@ -0,0 +1,8 @@
+<?php
+namespace Ivanboriev\SocketChat\Exceptions;
+
+
+class SocketWriteException extends \Exception
+{
+    protected $message = "Невозможно записать в сокет";
+}

src/Exceptions/UnknownCommandException.php

@@ -0,0 +1,8 @@
+<?php
+namespace Ivanboriev\SocketChat\Exceptions;
+
+
+class UnknownCommandException extends \Exception
+{
+
+}