Re^5: Mojolicious Websocket example

I am able to send it once, but how to put it into the loop? How to check the DB every seconds or every few seconds and send that data via WS?

copy/paste the example I linked ?:)

oh right, its full of stuff

copy/paste the example you already had in the beginning?

Yeah, that sounds good, copy/paste the example you already had in Mojolicious Websocket example, the one trippledubs said worked

Also see localtime/gmtime

Comment on Re^5: Mojolicious Websocket example

Replies are listed 'Best First'.
Re^6: Mojolicious Websocket example by rkrasowski (Sexton) on Jun 22, 2015 at 01:39 UTC
OK, I am learning that stuff. Here is a solution for my problem. Script runs every second and sends data ( current time in this example) via websocket. Here is the code: #!/usr/bin/env perl use warnings; use strict; use Mojolicious::Lite; get '/' => 'index'; websocket '/echo' => sub { my $c = shift; $c->app->log->debug('WebSocket opened'); $c->inactivity_timeout(300); my $id = Mojo::IOLoop->recurring(1 => sub { my $msg1 = `date`; $c->send($msg1); }); $c->on(finish => sub { my ($c, $code, $reason) = @_; $c->on(finish => sub { Mojo::IOLoop->remove($id) }); $c->app->log->debug("WebSocket closed with status $code"); }); }; app->start; __DATA__ @@ index.html.ep <!DOCTYPE html> <html> <head><title>Test</title></head> <body> <script> var ws = new WebSocket('<%= url_for('echo')->to_abs %>'); ws.onmessage = function(event) { document.getElementById("dateTime").innerHTML = event.data; }; </script> <h1 id="dateTime"></h1> </body> </html> [download] Thanks for help. Robert	[reply] [d/l]

Replies are listed 'Best First'.

Re^6: Mojolicious Websocket example
by rkrasowski (Sexton) on Jun 22, 2015 at 01:39 UTC

OK, I am learning that stuff. Here is a solution for my problem. Script runs every second and sends data ( current time in this example) via websocket.

Here is the code:

#!/usr/bin/env perl
use warnings;
use strict;
use Mojolicious::Lite;

get '/' => 'index';

websocket '/echo' => sub {
  my $c = shift;
  $c->app->log->debug('WebSocket opened');

  $c->inactivity_timeout(300);

  my $id = Mojo::IOLoop->recurring(1 => sub {

  my $msg1 = `date`;
  $c->send($msg1);

 });

   $c->on(finish => sub {
    my ($c, $code, $reason) = @_;
    $c->on(finish => sub { Mojo::IOLoop->remove($id) });

    $c->app->log->debug("WebSocket closed with status $code");

  });
};
app->start;

__DATA__

@@ index.html.ep
<!DOCTYPE html>
<html>
  <head><title>Test</title></head>
  <body>
    <script>
      var ws = new WebSocket('<%= url_for('echo')->to_abs %>');
      ws.onmessage = function(event) {
        document.getElementById("dateTime").innerHTML = event.data;
      };
    </script>

<h1 id="dateTime"></h1>
  </body>
</html>
[download]

Thanks for help.

Robert

[reply]
[d/l]