#!/usr/bin/env perl
use Mojo::Base -strict, -signatures;
use Mojo::UserAgent;
use Mojo::IOLoop;
use Data::Dump qw/dd pp/;

# To connect to mux.pl: perl cli.pl ws://localhost:3001
my $ADDR = @ARGV ? $ARGV[0] : 'ws://localhost:3000';

say "Opening WebSocket...";
my $ua = Mojo::UserAgent->new;
$ua->inactivity_timeout(10); # must be more than mux's timeout
$ua->websocket($ADDR => sub ($ua, $tx) {
	die 'WebSocket handshake failed!'.pp($tx)
		unless $tx->is_websocket;
	my $timer_id = Mojo::IOLoop->recurring( 30 => sub {
		say "Sending heartbeat";
		$tx->send('HEARTBEAT');
	} );
	$tx->on(finish => sub ($tx, $code, $reason=undef) {
		say "WebSocket closed ".pp($code, $reason);
		Mojo::IOLoop->remove($timer_id);
	});
	$tx->on(message => sub ($tx, $msg) {
		say "RX: ".pp($msg);
	});
	$tx->send('RUN');
});

Mojo::IOLoop->start unless Mojo::IOLoop->is_running;