- new directory structure

- singular exception
- starting exception deprecation

23 files changed, 715 insertions, 0 deletions

diff --git a/tests/broken.php b/tests/broken.php
new file mode 100644
index 00000000..b1a3839e
--- /dev/null
+++ b/tests/broken.php
@@ -0,0 +1,14 @@
+<?php
+/**
+ * @var Goridge\RelayInterface $relay
+ */
+
+use Spiral\Goridge;
+use Spiral\RoadRunner;
+
+$rr = new RoadRunner\Worker($relay);
+
+while ($in = $rr->receive($ctx)) {
+    echo undefined_function();
+    $rr->send((string)$in);
+}
\ No newline at end of file
diff --git a/tests/client.php b/tests/client.php
new file mode 100644
index 00000000..31caa410
--- /dev/null
+++ b/tests/client.php
@@ -0,0 +1,35 @@
+<?php
+
+use Spiral\Goridge;
+
+ini_set('display_errors', 'stderr');
+require dirname(__DIR__) . "/vendor/autoload.php";
+
+if (count($argv) < 3) {
+    die("need 2 arguments");
+}
+
+list($test, $goridge) = [$argv[1], $argv[2]];
+
+switch ($goridge) {
+    case "pipes":
+        $relay = new Goridge\StreamRelay(STDIN, STDOUT);
+        break;
+
+    case "tcp":
+        $relay = new Goridge\SocketRelay("localhost", 9007);
+        break;
+
+    case "unix":
+        $relay = new Goridge\SocketRelay(
+            "sock.unix",
+            null,
+            Goridge\SocketRelay::SOCK_UNIX
+        );
+        break;
+
+    default:
+        die("invalid protocol selection");
+}
+
+require_once sprintf("%s/%s.php", __DIR__, $test);
diff --git a/tests/delay.php b/tests/delay.php
new file mode 100644
index 00000000..bfde2fc4
--- /dev/null
+++ b/tests/delay.php
@@ -0,0 +1,18 @@
+<?php
+/**
+ * @var Goridge\RelayInterface $relay
+ */
+
+use Spiral\Goridge;
+use Spiral\RoadRunner;
+
+$rr = new RoadRunner\Worker($relay);
+
+while ($in = $rr->receive($ctx)) {
+    try {
+        usleep($in * 1000);
+        $rr->send('');
+    } catch (\Throwable $e) {
+        $rr->error((string)$e);
+    }
+}
\ No newline at end of file
diff --git a/tests/echo.php b/tests/echo.php
new file mode 100644
index 00000000..ba58ff30
--- /dev/null
+++ b/tests/echo.php
@@ -0,0 +1,17 @@
+<?php
+/**
+ * @var Goridge\RelayInterface $relay
+ */
+
+use Spiral\Goridge;
+use Spiral\RoadRunner;
+
+$rr = new RoadRunner\Worker($relay);
+
+while ($in = $rr->receive($ctx)) {
+    try {
+        $rr->send((string)$in);
+    } catch (\Throwable $e) {
+        $rr->error((string)$e);
+    }
+}
\ No newline at end of file
diff --git a/tests/error.php b/tests/error.php
new file mode 100644
index 00000000..ebd3418b
--- /dev/null
+++ b/tests/error.php
@@ -0,0 +1,13 @@
+<?php
+/**
+ * @var Goridge\RelayInterface $relay
+ */
+
+use Spiral\Goridge;
+use Spiral\RoadRunner;
+
+$rr = new RoadRunner\Worker($relay);
+
+while ($in = $rr->receive($ctx)) {
+    $rr->error((string)$in);
+}
\ No newline at end of file
diff --git a/tests/failboot.php b/tests/failboot.php
new file mode 100644
index 00000000..fa8b96f6
--- /dev/null
+++ b/tests/failboot.php
@@ -0,0 +1,3 @@
+<?php
+ini_set('display_errors', 'stderr');
+throw new Error("failboot error");
\ No newline at end of file
diff --git a/tests/head.php b/tests/head.php
new file mode 100644
index 00000000..4f4e4061
--- /dev/null
+++ b/tests/head.php
@@ -0,0 +1,17 @@
+<?php
+/**
+ * @var Goridge\RelayInterface $relay
+ */
+
+use Spiral\Goridge;
+use Spiral\RoadRunner;
+
+$rr = new RoadRunner\Worker($relay);
+
+while ($in = $rr->receive($ctx)) {
+    try {
+        $rr->send("", (string)$ctx);
+    } catch (\Throwable $e) {
+        $rr->error((string)$e);
+    }
+}
\ No newline at end of file
diff --git a/tests/http/client.php b/tests/http/client.php
new file mode 100644
index 00000000..166acfb6
--- /dev/null
+++ b/tests/http/client.php
@@ -0,0 +1,45 @@
+<?php
+
+use Spiral\Goridge;
+use Spiral\RoadRunner;
+
+ini_set('display_errors', 'stderr');
+require dirname(__DIR__) . "/../vendor/autoload.php";
+
+if (count($argv) < 3) {
+    die("need 2 arguments");
+}
+
+list($test, $goridge) = [$argv[1], $argv[2]];
+
+switch ($goridge) {
+    case "pipes":
+        $relay = new Goridge\StreamRelay(STDIN, STDOUT);
+        break;
+
+    case "tcp":
+        $relay = new Goridge\SocketRelay("localhost", 9007);
+        break;
+
+    case "unix":
+        $relay = new Goridge\SocketRelay(
+            "sock.unix",
+            null,
+            Goridge\SocketRelay::SOCK_UNIX
+        );
+        break;
+
+    default:
+        die("invalid protocol selection");
+}
+
+$psr7 = new RoadRunner\PSR7Client(new RoadRunner\Worker($relay));
+require_once sprintf("%s/%s.php", __DIR__, $test);
+
+while ($req = $psr7->acceptRequest()) {
+    try {
+        $psr7->respond(handleRequest($req, new \Zend\Diactoros\Response()));
+    } catch (\Throwable $e) {
+        $psr7->getWorker()->error((string)$e);
+    }
+}
diff --git a/tests/http/cookie.php b/tests/http/cookie.php
new file mode 100644
index 00000000..196ceee2
--- /dev/null
+++ b/tests/http/cookie.php
@@ -0,0 +1,334 @@
+<?php
+
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\ServerRequestInterface;
+
+function handleRequest(ServerRequestInterface $req, ResponseInterface $resp): ResponseInterface
+{
+    $resp->getBody()->write(strtoupper($req->getCookieParams()['input']));
+
+    return $resp->withAddedHeader(
+        "Set-Cookie",
+        (new Cookie('output', 'cookie-output'))->createHeader()
+    );
+}
+
+final class Cookie
+{
+    /**
+     * The name of the cookie.
+     *
+     * @var string
+     */
+    private $name = '';
+    /**
+     * The value of the cookie. This value is stored on the clients computer; do not store sensitive
+     * information.
+     *
+     * @var string|null
+     */
+    private $value = null;
+    /**
+     * Cookie lifetime. This value specified in seconds and declares period of time in which cookie
+     * will expire relatively to current time() value.
+     *
+     * @var int|null
+     */
+    private $lifetime = null;
+    /**
+     * The path on the server in which the cookie will be available on.
+     *
+     * If set to '/', the cookie will be available within the entire domain. If set to '/foo/',
+     * the cookie will only be available within the /foo/ directory and all sub-directories such as
+     * /foo/bar/ of domain. The default value is the current directory that the cookie is being set
+     * in.
+     *
+     * @var string|null
+     */
+    private $path = null;
+    /**
+     * The domain that the cookie is available. To make the cookie available on all subdomains of
+     * example.com then you'd set it to '.example.com'. The . is not required but makes it
+     * compatible with more browsers. Setting it to www.example.com will make the cookie only
+     * available in the www subdomain. Refer to tail matching in the spec for details.
+     *
+     * @var string|null
+     */
+    private $domain = null;
+    /**
+     * Indicates that the cookie should only be transmitted over a secure HTTPS connection from the
+     * client. When set to true, the cookie will only be set if a secure connection exists.
+     * On the server-side, it's on the programmer to send this kind of cookie only on secure
+     * connection
+     * (e.g. with respect to $_SERVER["HTTPS"]).
+     *
+     * @var bool|null
+     */
+    private $secure = null;
+    /**
+     * When true the cookie will be made accessible only through the HTTP protocol. This means that
+     * the cookie won't be accessible by scripting languages, such as JavaScript. This setting can
+     * effectively help to reduce identity theft through XSS attacks (although it is not supported
+     * by all browsers).
+     *
+     * @var bool
+     */
+    private $httpOnly = true;
+
+    /**
+     * New Cookie instance, cookies used to schedule cookie set while dispatching Response.
+     *
+     * @link http://php.net/manual/en/function.setcookie.php
+     *
+     * @param string $name     The name of the cookie.
+     * @param string $value    The value of the cookie. This value is stored on the clients
+     *                         computer; do not store sensitive information.
+     * @param int    $lifetime Cookie lifetime. This value specified in seconds and declares period
+     *                         of time in which cookie will expire relatively to current time()
+     *                         value.
+     * @param string $path     The path on the server in which the cookie will be available on.
+     *                         If set to '/', the cookie will be available within the entire
+     *                         domain.
+     *                         If set to '/foo/', the cookie will only be available within the
+     *                         /foo/
+     *                         directory and all sub-directories such as /foo/bar/ of domain. The
+     *                         default value is the current directory that the cookie is being set
+     *                         in.
+     * @param string $domain   The domain that the cookie is available. To make the cookie
+     *                         available
+     *                         on all subdomains of example.com then you'd set it to
+     *                         '.example.com'.
+     *                         The . is not required but makes it compatible with more browsers.
+     *                         Setting it to www.example.com will make the cookie only available in
+     *                         the www subdomain. Refer to tail matching in the spec for details.
+     * @param bool   $secure   Indicates that the cookie should only be transmitted over a secure
+     *                         HTTPS connection from the client. When set to true, the cookie will
+     *                         only be set if a secure connection exists. On the server-side, it's
+     *                         on the programmer to send this kind of cookie only on secure
+     *                         connection (e.g. with respect to $_SERVER["HTTPS"]).
+     * @param bool   $httpOnly When true the cookie will be made accessible only through the HTTP
+     *                         protocol. This means that the cookie won't be accessible by
+     *                         scripting
+     *                         languages, such as JavaScript. This setting can effectively help to
+     *                         reduce identity theft through XSS attacks (although it is not
+     *                         supported by all browsers).
+     */
+    public function __construct(
+        string $name,
+        string $value = null,
+        int $lifetime = null,
+        string $path = null,
+        string $domain = null,
+        bool $secure = false,
+        bool $httpOnly = true
+    ) {
+        $this->name = $name;
+        $this->value = $value;
+        $this->lifetime = $lifetime;
+        $this->path = $path;
+        $this->domain = $domain;
+        $this->secure = $secure;
+        $this->httpOnly = $httpOnly;
+    }
+
+    /**
+     * The name of the cookie.
+     *
+     * @return string
+     */
+    public function getName(): string
+    {
+        return $this->name;
+    }
+
+    /**
+     * The value of the cookie. This value is stored on the clients computer; do not store sensitive
+     * information.
+     *
+     * @return string|null
+     */
+    public function getValue()
+    {
+        return $this->value;
+    }
+
+    /**
+     * The time the cookie expires. This is a Unix timestamp so is in number of seconds since the
+     * epoch. In other words, you'll most likely set this with the time function plus the number of
+     * seconds before you want it to expire. Or you might use mktime.
+     *
+     * Will return null if lifetime is not specified.
+     *
+     * @return int|null
+     */
+    public function getExpires()
+    {
+        if ($this->lifetime === null) {
+            return null;
+        }
+
+        return time() + $this->lifetime;
+    }
+
+    /**
+     * The path on the server in which the cookie will be available on.
+     *
+     * If set to '/', the cookie will be available within the entire domain. If set to '/foo/',
+     * the cookie will only be available within the /foo/ directory and all sub-directories such as
+     * /foo/bar/ of domain. The default value is the current directory that the cookie is being set
+     * in.
+     *
+     * @return string|null
+     */
+    public function getPath()
+    {
+        return $this->path;
+    }
+
+    /**
+     * The domain that the cookie is available. To make the cookie available on all subdomains of
+     * example.com then you'd set it to '.example.com'. The . is not required but makes it
+     * compatible with more browsers. Setting it to www.example.com will make the cookie only
+     * available in the www subdomain. Refer to tail matching in the spec for details.
+     *
+     * @return string|null
+     */
+    public function getDomain()
+    {
+        return $this->domain;
+    }
+
+    /**
+     * Indicates that the cookie should only be transmitted over a secure HTTPS connection from the
+     * client. When set to true, the cookie will only be set if a secure connection exists.
+     * On the server-side, it's on the programmer to send this kind of cookie only on secure
+     * connection
+     * (e.g. with respect to $_SERVER["HTTPS"]).
+     *
+     * @return bool
+     */
+    public function isSecure(): bool
+    {
+        return $this->secure;
+    }
+
+    /**
+     * When true the cookie will be made accessible only through the HTTP protocol. This means that
+     * the cookie won't be accessible by scripting languages, such as JavaScript. This setting can
+     * effectively help to reduce identity theft through XSS attacks (although it is not supported
+     * by all browsers).
+     *
+     * @return bool
+     */
+    public function isHttpOnly(): bool
+    {
+        return $this->httpOnly;
+    }
+
+    /**
+     * Get new cookie with altered value. Original cookie object should not be changed.
+     *
+     * @param string $value
+     *
+     * @return Cookie
+     */
+    public function withValue(string $value): self
+    {
+        $cookie = clone $this;
+        $cookie->value = $value;
+
+        return $cookie;
+    }
+
+    /**
+     * Convert cookie instance to string.
+     *
+     * @link http://www.w3.org/Protocols/rfc2109/rfc2109
+     * @return string
+     */
+    public function createHeader(): string
+    {
+        $header = [
+            rawurlencode($this->name) . '=' . rawurlencode($this->value)
+        ];
+        if ($this->lifetime !== null) {
+            $header[] = 'Expires=' . gmdate(\DateTime::COOKIE, $this->getExpires());
+            $header[] = 'Max-Age=' . $this->lifetime;
+        }
+        if (!empty($this->path)) {
+            $header[] = 'Path=' . $this->path;
+        }
+        if (!empty($this->domain)) {
+            $header[] = 'Domain=' . $this->domain;
+        }
+        if ($this->secure) {
+            $header[] = 'Secure';
+        }
+        if ($this->httpOnly) {
+            $header[] = 'HttpOnly';
+        }
+
+        return join('; ', $header);
+    }
+
+    /**
+     * New Cookie instance, cookies used to schedule cookie set while dispatching Response.
+     * Static constructor.
+     *
+     * @link http://php.net/manual/en/function.setcookie.php
+     *
+     * @param string $name     The name of the cookie.
+     * @param string $value    The value of the cookie. This value is stored on the clients
+     *                         computer; do not store sensitive information.
+     * @param int    $lifetime Cookie lifetime. This value specified in seconds and declares period
+     *                         of time in which cookie will expire relatively to current time()
+     *                         value.
+     * @param string $path     The path on the server in which the cookie will be available on.
+     *                         If set to '/', the cookie will be available within the entire
+     *                         domain.
+     *                         If set to '/foo/', the cookie will only be available within the
+     *                         /foo/
+     *                         directory and all sub-directories such as /foo/bar/ of domain. The
+     *                         default value is the current directory that the cookie is being set
+     *                         in.
+     * @param string $domain   The domain that the cookie is available. To make the cookie
+     *                         available
+     *                         on all subdomains of example.com then you'd set it to
+     *                         '.example.com'.
+     *                         The . is not required but makes it compatible with more browsers.
+     *                         Setting it to www.example.com will make the cookie only available in
+     *                         the www subdomain. Refer to tail matching in the spec for details.
+     * @param bool   $secure   Indicates that the cookie should only be transmitted over a secure
+     *                         HTTPS connection from the client. When set to true, the cookie will
+     *                         only be set if a secure connection exists. On the server-side, it's
+     *                         on the programmer to send this kind of cookie only on secure
+     *                         connection (e.g. with respect to $_SERVER["HTTPS"]).
+     * @param bool   $httpOnly When true the cookie will be made accessible only through the HTTP
+     *                         protocol. This means that the cookie won't be accessible by
+     *                         scripting
+     *                         languages, such as JavaScript. This setting can effectively help to
+     *                         reduce identity theft through XSS attacks (although it is not
+     *                         supported by all browsers).
+     *
+     * @return Cookie
+     */
+    public static function create(
+        string $name,
+        string $value = null,
+        int $lifetime = null,
+        string $path = null,
+        string $domain = null,
+        bool $secure = false,
+        bool $httpOnly = true
+    ): self {
+        return new self($name, $value, $lifetime, $path, $domain, $secure, $httpOnly);
+    }
+
+    /**
+     * @return string
+     */
+    public function __toString(): string
+    {
+        return $this->createHeader();
+    }
+}
\ No newline at end of file
diff --git a/tests/http/data.php b/tests/http/data.php
new file mode 100644
index 00000000..c5e0bab0
--- /dev/null
+++ b/tests/http/data.php
@@ -0,0 +1,18 @@
+<?php
+
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\ServerRequestInterface;
+
+function handleRequest(ServerRequestInterface $req, ResponseInterface $resp): ResponseInterface
+{
+
+    $data = $req->getParsedBody();
+
+    ksort($data);
+    ksort($data['arr']);
+    ksort($data['arr']['x']['y']);
+
+    $resp->getBody()->write(json_encode($data));
+
+    return $resp;
+}
\ No newline at end of file
diff --git a/tests/http/echo.php b/tests/http/echo.php
new file mode 100644
index 00000000..7004ada0
--- /dev/null
+++ b/tests/http/echo.php
@@ -0,0 +1,10 @@
+<?php
+
+use \Psr\Http\Message\ServerRequestInterface;
+use \Psr\Http\Message\ResponseInterface;
+
+function handleRequest(ServerRequestInterface $req, ResponseInterface $resp): ResponseInterface
+{
+    $resp->getBody()->write(strtoupper($req->getQueryParams()['hello']));
+    return $resp->withStatus(201);
+}
\ No newline at end of file
diff --git a/tests/http/echoerr.php b/tests/http/echoerr.php
new file mode 100644
index 00000000..da2ff4d8
--- /dev/null
+++ b/tests/http/echoerr.php
@@ -0,0 +1,12 @@
+<?php
+
+use \Psr\Http\Message\ServerRequestInterface;
+use \Psr\Http\Message\ResponseInterface;
+
+function handleRequest(ServerRequestInterface $req, ResponseInterface $resp): ResponseInterface
+{
+    error_log(strtoupper($req->getQueryParams()['hello']));
+
+    $resp->getBody()->write(strtoupper($req->getQueryParams()['hello']));
+    return $resp->withStatus(201);
+}
\ No newline at end of file
diff --git a/tests/http/env.php b/tests/http/env.php
new file mode 100644
index 00000000..1e29926f
--- /dev/null
+++ b/tests/http/env.php
@@ -0,0 +1,10 @@
+<?php
+
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\ServerRequestInterface;
+
+function handleRequest(ServerRequestInterface $req, ResponseInterface $resp): ResponseInterface
+{
+    $resp->getBody()->write($_SERVER['ENV_KEY']);
+    return $resp;
+}
\ No newline at end of file
diff --git a/tests/http/error.php b/tests/http/error.php
new file mode 100644
index 00000000..6df0d4b5
--- /dev/null
+++ b/tests/http/error.php
@@ -0,0 +1,9 @@
+<?php
+
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\ServerRequestInterface;
+
+function handleRequest(ServerRequestInterface $req, ResponseInterface $resp): ResponseInterface
+{
+    throw new Error("error");
+}
\ No newline at end of file
diff --git a/tests/http/error2.php b/tests/http/error2.php
new file mode 100644
index 00000000..617b5a3f
--- /dev/null
+++ b/tests/http/error2.php
@@ -0,0 +1,9 @@
+<?php
+
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\ServerRequestInterface;
+
+function handleRequest(ServerRequestInterface $req, ResponseInterface $resp): ResponseInterface
+{
+    exit();
+}
\ No newline at end of file
diff --git a/tests/http/header.php b/tests/http/header.php
new file mode 100644
index 00000000..e5b295b6
--- /dev/null
+++ b/tests/http/header.php
@@ -0,0 +1,11 @@
+<?php
+
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\ServerRequestInterface;
+
+function handleRequest(ServerRequestInterface $req, ResponseInterface $resp): ResponseInterface
+{
+    $resp->getBody()->write(strtoupper($req->getHeaderLine('input')));
+
+    return $resp->withAddedHeader("Header", $req->getQueryParams()['hello']);
+}
\ No newline at end of file
diff --git a/tests/http/payload.php b/tests/http/payload.php
new file mode 100644
index 00000000..a16984c5
--- /dev/null
+++ b/tests/http/payload.php
@@ -0,0 +1,13 @@
+<?php
+
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\ServerRequestInterface;
+
+function handleRequest(ServerRequestInterface $req, ResponseInterface $resp): ResponseInterface
+{
+    // we expect json body
+    $p = json_decode($req->getBody(), true);
+    $resp->getBody()->write(json_encode(array_flip($p)));
+
+    return $resp;
+}
\ No newline at end of file
diff --git a/tests/http/pid.php b/tests/http/pid.php
new file mode 100644
index 00000000..1cc322bf
--- /dev/null
+++ b/tests/http/pid.php
@@ -0,0 +1,11 @@
+<?php
+
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\ServerRequestInterface;
+
+function handleRequest(ServerRequestInterface $req, ResponseInterface $resp): ResponseInterface
+{
+    $resp->getBody()->write(getmypid());
+
+    return $resp;
+}
\ No newline at end of file
diff --git a/tests/http/upload.php b/tests/http/upload.php
new file mode 100644
index 00000000..2f7c0b64
--- /dev/null
+++ b/tests/http/upload.php
@@ -0,0 +1,35 @@
+<?php
+
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\ServerRequestInterface;
+
+function handleRequest(ServerRequestInterface $req, ResponseInterface $resp): ResponseInterface
+{
+    $files = $req->getUploadedFiles();
+    array_walk_recursive($files, function (&$v) {
+        /**
+         * @var \Psr\Http\Message\UploadedFileInterface $v
+         */
+
+        if ($v->getError()) {
+            $v = [
+                'name'  => $v->getClientFilename(),
+                'size'  => $v->getSize(),
+                'mime'  => $v->getClientMediaType(),
+                'error' => $v->getError(),
+            ];
+        } else {
+            $v = [
+                'name'  => $v->getClientFilename(),
+                'size'  => $v->getSize(),
+                'mime'  => $v->getClientMediaType(),
+                'error' => $v->getError(),
+                'md5'   => md5($v->getStream()->__toString()),
+            ];
+        }
+    });
+
+    $resp->getBody()->write(json_encode($files, JSON_UNESCAPED_SLASHES));
+
+    return $resp;
+}
\ No newline at end of file
diff --git a/tests/pid.php b/tests/pid.php
new file mode 100644
index 00000000..a8cfa229
--- /dev/null
+++ b/tests/pid.php
@@ -0,0 +1,17 @@
+<?php
+/**
+ * @var Goridge\RelayInterface $relay
+ */
+
+use Spiral\Goridge;
+use Spiral\RoadRunner;
+
+$rr = new RoadRunner\Worker($relay);
+
+while ($in = $rr->receive($ctx)) {
+    try {
+        $rr->send((string)getmypid());
+    } catch (\Throwable $e) {
+        $rr->error((string)$e);
+    }
+}
\ No newline at end of file
diff --git a/tests/sample.txt b/tests/sample.txt
new file mode 100644
index 00000000..eed7e79a
--- /dev/null
+++ b/tests/sample.txt
@@ -0,0 +1 @@
+sample
\ No newline at end of file
diff --git a/tests/slow-client.php b/tests/slow-client.php
new file mode 100644
index 00000000..2722868c
--- /dev/null
+++ b/tests/slow-client.php
@@ -0,0 +1,38 @@
+<?php
+
+use Spiral\Goridge;
+
+ini_set('display_errors', 'stderr');
+require dirname(__DIR__) . "/../vendor/autoload.php";
+
+if (count($argv) < 3) {
+    die("need 2 arguments");
+}
+
+list($test, $goridge, $bootDelay, $shutdownDelay) = [$argv[1], $argv[2], $argv[3], $argv[4]];
+
+switch ($goridge) {
+    case "pipes":
+        $relay = new Goridge\StreamRelay(STDIN, STDOUT);
+        break;
+
+    case "tcp":
+        $relay = new Goridge\SocketRelay("localhost", 9007);
+        break;
+
+    case "unix":
+        $relay = new Goridge\SocketRelay(
+            "sock.unix",
+            null,
+            Goridge\SocketRelay::SOCK_UNIX
+        );
+
+        break;
+
+    default:
+        die("invalid protocol selection");
+}
+
+usleep($bootDelay * 1000);
+require_once sprintf("%s/%s.php", __DIR__, $test);
+usleep($shutdownDelay * 1000);
\ No newline at end of file
diff --git a/tests/stop.php b/tests/stop.php
new file mode 100644
index 00000000..caa485d6
--- /dev/null
+++ b/tests/stop.php
@@ -0,0 +1,25 @@
+<?php
+/**
+ * @var Goridge\RelayInterface $relay
+ */
+
+use Spiral\Goridge;
+use Spiral\RoadRunner;
+
+$rr = new RoadRunner\Worker($relay);
+
+$used = false;
+while ($in = $rr->receive($ctx)) {
+    try {
+        if ($used) {
+            // kill on second attempt
+            $rr->stop();
+            continue;
+        }
+
+        $used = true;
+        $rr->send((string)getmypid());
+    } catch (\Throwable $e) {
+        $rr->error((string)$e);
+    }
+}
\ No newline at end of file