Opening a webserver on 6001 for healthchecks

[rennokki]

Running websockets on production without healthchecks is awful. AWS Elastic Beanstalk lets me use 6001 as HTTP port (it an ALB, so it supports Websockets) and it works, but my healthchecks fail because the port 6001 is not a webserver and i literally can't do anything.

Is there any way of implementing a healthcheck function on this package?

[francislavoie]

#150 You can make a custom route to act like a health check endpoint.

[rennokki]

After a long while, I came back using Websockets. If anyone wonders how I added a healthcheck on a 6001 route, here it is:

<?php

namespace App\WebSocketHandlers;

use Exception;
use GuzzleHttp\Psr7\Response;
use Psr\Http\Message\RequestInterface;
use Ratchet\ConnectionInterface;
use Ratchet\Http\HttpServerInterface;

class HealthSocketHandler implements HttpServerInterface
{
    public function onMessage(ConnectionInterface $from, $msg)
    {
        //
    }

    public function onOpen(ConnectionInterface $connection, RequestInterface $request = null)
    {
        $response = new Response(200, [
            'Content-Type' => 'application/json',
        ], json_encode([
            'ok' => true,
        ]));

        $connection->send(\GuzzleHttp\Psr7\str($response));

        $connection->close();
    }

    public function onClose(ConnectionInterface $connection)
    {
        //
    }

    public function onError(ConnectionInterface $connection, Exception $exception)
    {
        if (! $exception instanceof HttpException) {
            return;
        }

        $response = new Response($exception->getStatusCode(), [
            'Content-Type' => 'application/json',
        ], json_encode([
            'error' => $exception->getMessage(),
        ]));

        $connection->send(\GuzzleHttp\Psr7\str($response));

        $connection->close();
    }
}

In AppServiceProvider.php:

use BeyondCode\LaravelWebSockets\Facades\WebSocketsRouter;

public function boot()
{
    WebSocketsRouter::get('/health', HealthSocketHandler::class);
}

Opening up http://localhost:6001/health will show this with 200 OK as status:

{
    "ok": true
}

[BasvanH]

If you are using Guzzle >7.2.0 then \GuzzleHttp\Psr7\str is depricated so you need to add:

use GuzzleHttp\Psr7\Message;

And replace 2x:

$connection->send(\GuzzleHttp\Psr7\str($response));

With:

$connection->send(Message::toString($response));

[leksanboy]

Hello guys @rennokki and @francislavoie, i don't know if you can solve this maybe similar case.

The thing is practically the same as @rennokki but with little difference, I want to create a single file when you have 2 classes, one for health check and another one for chat messaging.

So what I do is creating a docker image exposing port 9000 (ws://localhost:9000/chat) but also I need a health check with http://localhost:9000/health.

<?php
require '/vendor/autoload.php';

    use Exception;
    use GuzzleHttp\Psr7\Response;
    use Psr\Http\Message\RequestInterface;
    use Ratchet\ConnectionInterface;
    use Ratchet\Http\HttpServerInterface;

    class HealthSocketHandler implements HttpServerInterface
    {
        public function onMessage(ConnectionInterface $from, $msg)
        {
            //
        }
    
        public function onOpen(ConnectionInterface $connection, RequestInterface $request = null)
        {
            $response = new Response(200, [
                'Content-Type' => 'application/json',
            ], json_encode([
                'ok' => true,
            ]));
    
            $connection->send(\GuzzleHttp\Psr7\str($response));
    
            $connection->close();
        }
    
        public function onClose(ConnectionInterface $connection)
        {
            //
        }
    
        public function onError(ConnectionInterface $connection, Exception $exception)
        {
            if (! $exception instanceof HttpException) {
                return;
            }
    
            $response = new Response($exception->getStatusCode(), [
                'Content-Type' => 'application/json',
            ], json_encode([
                'error' => $exception->getMessage(),
            ]));
    
            $connection->send(\GuzzleHttp\Psr7\str($response));
    
            $connection->close();
        }
    }

    class Chat implements MessageComponentInterface {...}

    $loop = LoopFactory::create();
    $app = new Ratchet\App("localhost", 9000, '0.0.0.0', $loop);
    $app->route('/health', new HealthSocketHandler, array('*')); // health check | return 200 code
    $app->route('/chat', new Chat, array('*'));
    
    $app->run();

[leksanboy]

#1060 copy issue