#!/usr/bin/env perl #---AUTOPRAGMASTART--- use v5.36; use strict; use diagnostics; use English qw(-no_match_vars); use Carp qw[carp croak confess cluck longmess shortmess]; our $VERSION = 29; use autodie qw( close ); use Array::Contains; use utf8; use Encode qw(is_utf8 encode_utf8 decode_utf8); use Data::Dumper; #---AUTOPRAGMAEND--- use Net::Clacks::Client; use Time::HiRes qw(sleep); my $username = 'exampleuser'; my $password = 'unsafepassword'; my $applicationname = 'debugmonitor'; my $keepRunning = 1; $SIG{TERM} = sub{ print "SIGTERM, exiting program\n"; $keepRunning = 0; }; my $nextping = time + 10; my $nextrun = 0; # Client side caching is a whole other topic. Basically, it doesn't resend stuff when the value hasn't changed # In most cases this isn't required or can even be counter-productive. This is one of those advanced topics... my $is_caching = 0; # Let's connect my $clacks = Net::Clacks::Client->newSocket('example.sock', $username, $password, $applicationname, $is_caching) or croak("Connection to server failed"); initClacks(); while($keepRunning) { $clacks->doNetwork(); # Sync with server if($nextping < time) { $clacks->ping(); # Send a keepalive ping $nextping = time + 10; } # Iterate over all messages in our in-buffer while((my $msg = $clacks->getNext())) { if($msg->{type} eq 'disconnect') { print '+++ Disconnected by server, reason given: ', $msg->{data}, "\n"; sleep(2); # Wait a couple of seconds, should automatically reconnect on next doNetwork initClacks(); # Need to resend listen() and stuff } elsif($msg->{type} eq 'serverinfo') { print '+++ Connected to server version: ', $msg->{data}, "\n"; } elsif($msg->{type} eq 'set' && $msg->{name} eq 'FAKESENSOR::value') { print "Fake sensor reports a value of: ", $msg->{data}, "\n"; } } sleep(0.2); } $clacks->disconnect(); exit(0); sub initClacks() { # LISTEN to real-time changes. This implies the client changing this value will use setAndStore() $clacks->listen('FAKESENSOR::value'); $clacks->doNetwork(); return; }