WebApp consuming MQTT messages and providing data via HTTP

mojo_and_mqtt.pl

#!/usr/bin/env perl

# ./mojo_and_mqtt.pl daemon

use Mojolicious::Lite;
use EV;
use AnyEvent;
use AnyEvent::MQTT;

my $mqtt = AnyEvent::MQTT->new;
my $mq_stats = {};

# subscribe to the mosquitto metadata and update a hash when we receive messages
my $cv = $mqtt->subscribe(topic => '$SYS/#',
                          callback => sub {
                            my ($topic, $message) = @_;
                            $mq_stats->{$topic} = $message;
                          });
my $qos = $cv->recv; # subscribed, negotiated QoS == $qos

get '/' => sub {
  my $c = shift;
  my $out = join ("\n", map { sprintf("%-20s => %-s", $_, $mq_stats->{$_}) } sort keys %$mq_stats);
  $c->render(text => $out);
};

app->start;