Shell.pm

sub view {
    my $self = shift;

    my $id = $self->stash('id');

    unless ($self->tx->is_websocket) {
        my $url = $self->req->url->base->clone;
        $url->scheme($self->req->is_secure ? 'wss' : 'ws');
        $url->query->params([]);
        $url->path($self->req->url->path);

        $self->stash(websocket_url => $url->to_abs);
        return;
    }

    #my $client = $self->client;
    $self->client->async->websocket(
        "ws://localhost:1234/$id" => sub {
            my $client = shift;

            if ($client->tx->has_error) {
                $self->app->log->error("Can't connect to backend");
                $client->finish;
                $self->finish;
                return;
            }

            $client->receive_message(
                sub {
                    my ($client, $message) = @_;

                    warn "message=$message";

                    $self->send_message($message);
                }
            );

            $client->finished(
                sub {
                    my $client = shift;

                    warn qq/Backend connection is closed/;
                }
            );
        }
    )->process;

    $self->receive_message(
        sub {
            my ($self, $message) = @_;

            warn qq/Message from browser=$message/;

            #$client->send_message($message);
        }
    );

    $self->finished(
        sub {
            my $self = shift;

            #$client->finish;

            warn 'User closed websocket connection';
        }
    );

}