#!/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 $cycletime = 5;
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::cycletime') {
            $cycletime = 0 + $msg->{data};
            print "Cycle time has changed to $cycletime seconds\n";
        }
    }

    if($nextrun < time) {
        # Do a cycle
        $nextrun = time + $cycletime;
        my $newval = int(rand(1000));

        print "New sensor value: $newval\n";
        $clacks->setAndStore('FAKESENSOR::value', $newval); # broadcast new value and also store it
        $clacks->increment('FAKESENSOR::count', 1); # Increment the sensor reading count by 1 (stepsize is an optional argument). Autovivifies the value if not defined
        $clacks->doNetwork();
    }

    sleep(0.2);
}
$clacks->disconnect();
exit(0);

sub initClacks() {
    # We use the key/value store for long-term storage...
    my $ct = $clacks->retrieve('FAKESENSOR::cycletime');
    if(!defined($ct)) {
        # Fallback to default of 5 seconds
        print "Storing default cycletime in clacks\n";
        $clacks->store('FAKESENSOR::cycletime', $cycletime);
    } else {
        $cycletime = 0 + $ct;
        print "Got a preset cycletime of $cycletime seconds\n";
    }

    # ...but LISTEN to real-time changes. This implies the client changing this value will use setAndStore()
    $clacks->listen('FAKESENSOR::cycletime');

    $clacks->doNetwork();
    return;
}