Initial Commit

Author: ahmard

.gitignore

@@ -0,0 +1,4 @@
+/.idea
+/vendor
+
+/composer.lock

README.md

@@ -0,0 +1 @@
+# PHP RTC Contracts

composer.json

@@ -0,0 +1,24 @@
+{
+    "name": "phprtc/contracts",
+    "description": "PHP RTC Contracts",
+    "type": "project",
+    "license": "MIT",
+    "autoload": {
+        "psr-4": {
+            "RTC\\Contracts\\": "src/"
+        }
+    },
+    "authors": [
+        {
+            "name": "Ahmard",
+            "email": "[email protected]"
+        }
+    ],
+    "require": {
+        "php": ">=8.1",
+        "guzzlehttp/psr7": "^2.0"
+    },
+    "require-dev": {
+        "swoole/ide-helper": "^4.7"
+    }
+}

src/Http/HttpHandlerInterface.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace RTC\Contracts\Http;
+
+use QuickRoute\Router\Collector;
+
+interface HttpHandlerInterface
+{
+    public function handle(RequestInterface $request): void;
+
+    public function setRouteCollector(Collector $collector): static;
+
+    public function hasRouteCollector(): bool;
+
+    public function getRouteCollector(): Collector;
+}

src/Http/MiddlewareInterface.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace RTC\Contracts\Http;
+
+interface MiddlewareInterface
+{
+    public function handle(RequestInterface $request): void;
+}

src/Http/RequestInterface.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace RTC\Contracts\Http;
+
+use QuickRoute\Router\DispatchResult;
+
+interface RequestInterface extends \Psr\Http\Message\RequestInterface
+{
+    public function initMiddleware(MiddlewareInterface ...$middlewares): void;
+
+    public function getResponse(): ResponseInterface;
+
+    public function getMiddleware(): RequestMiddlewareInterface;
+
+    public function getRouteDispatchResult(): DispatchResult;
+}

src/Http/RequestMiddlewareInterface.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace RTC\Contracts\Http;
+
+use SplQueue;
+
+interface RequestMiddlewareInterface
+{
+    public function __construct(RequestInterface $request, array $middlewares);
+
+    public function push(MiddlewareInterface $middleware): void;
+
+    public function next(): void;
+
+    public function getCurrent(): MiddlewareInterface;
+
+    public function getQueue(): SplQueue;
+}

src/Http/ResponseInterface.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace RTC\Contracts\Http;
+
+use Swoole\Http\Response as Http1Response;
+use Swoole\Http2\Response as Http2Response;
+
+interface ResponseInterface
+{
+    public function __construct(RequestInterface $request, Http1Response|Http2Response $response);
+
+    public function json(array|object $data, int $status = 200, array $headers = []): void;
+
+    public function html(string $code, int $status = 200, array $headers = []): void;
+
+    public function plain(string $string, int $status = 200, array $headers = []): void;
+
+    public function redirect(string $url, array $headers = []): void;
+}

src/Websocket/ConnectionInterface.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace RTC\Contracts\Websocket;
+
+interface ConnectionInterface
+{
+    /**
+     * Send message to this connection
+     *
+     * @param string $command
+     * @param mixed $data
+     * @return void
+     */
+    public function send(string $command, mixed $data): void;
+
+    /**
+     * Close this connection
+     *
+     * @return void
+     */
+    public function close(): void;
+
+    /**
+     * Gets the connection unique identifier
+     *
+     * @return int
+     */
+    public function getIdentifier(): int;
+}

src/Websocket/FrameInterface.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace RTC\Contracts\Websocket;
+
+use Swoole\WebSocket\Frame;
+
+interface FrameInterface
+{
+    /**
+     * Returns Swoole frame object
+     *
+     * @return Frame
+     */
+    public function getFrame(): Frame;
+
+    /**
+     * Returns json-decoded message array
+     *
+     * @return array
+     */
+    public function getMessage(): array;
+}

src/Websocket/WebsocketHandlerInterface.php

@@ -0,0 +1,11 @@
+<?php
+
+namespace RTC\Contracts\Websocket;
+
+use Swoole\Http\Server;
+use Swoole\WebSocket\Frame;
+
+interface WebsocketHandlerInterface
+{
+    public function handle(ConnectionInterface $connection, FrameInterface $frame): void;
+}