notifier

#!/usr/bin/env php
<?php

require_once(__DIR__.'/lib/common.php');
require_once(__DIR__.'/lib/visitors.php');

// Create new notifier, defaulting to author's home lab.
$conffile = array_key_exists(1, $argv) ? $argv[1] : __DIR__.'/notifier.conf';
$conf = parse_ini_file($conffile, TRUE);
if ($conf === FALSE) {
    print("Configuration file invalid\n");
    exit(1);
}

// Load localization (premises specific handlers)
require_once(__DIR__.'/lib/localizations/'.$conf['localization'].'.php');
$notifier = new Localization();

$find_user_by_id = $db->prepare("SELECT * from user WHERE id=?");

$pipe = popen("exec journalctl -n0 -ojson -f -u visitors -u rtl_433 -u hackbus -u light_watcher", "r");
$last_press = 0;

while (true) {
    $raw = fgets($pipe);
    if ($raw === FALSE) {
        // EOF
        break;
    }
    $e = json_decode($raw);
    if ($e === NULL) {
        print("Panic: Not systemd log export format\n");
        exit(1);
    }

    // Try decoding the message as well.
    $e->json = json_decode($e->MESSAGE);
    
    switch ($e->_SYSTEMD_UNIT) {

        case 'rtl_433.service':
            // Radio controlled buttons parsed by rtl_433

            // Remove timestamps to identify duplicates
            if ($e->json !== NULL) $e->json->time = NULL;

            // Name some common RTL error cases
            if (strpos($e->MESSAGE, 'rtlsdr_demod_write_reg failed') === 0) {
                $e->json = "rtl_error";
            } else if (strpos($e->MESSAGE, 'Using device ') === 0) {
                $e->json = "rtl_ok";
            } else if ($e->json === NULL) {
                // Ignore garbage
                break;
            } else {
                if ($e->json->model === 'Generic Remote') {
                    $e->json->released = $e->json->tristate[11] === '1';
                    $e->json->chan = strpos($e->json->tristate, '0');
                    $e->json->button = strpos($e->json->tristate, '0', 4)-4;
                    $e->json->on = $e->json->tristate[11] === 'F';
                    $e->json->tristate = NULL; // Not needed anymore
                }
            }

            // If the same state comes soon enough
            if (time() < $last_press + 20 && $rtl_433_state === (array)$e->json) break;

            // Localize
            if ($notifier->radio_button($e->json)) {
                // Save last state if successful
                $rtl_433_state = (array)$e->json;
                $last_press = time();
            }
        break;

        case 'hackbus.service':
            // MODBUS controller messages.
            // Call handler if there is any payload
            if ($e->json === NULL) break;

            $notifier->hackbus($e->json->method, $e->json->params);
            break;

        case 'visitors.service':
            // Visitors via DHCP parsed by follow_dhcp.
            // Skip if not containing JSON payload
            if ($e->json === NULL) break;

            //if ($e->json->ids === []) {
                // Lab is now empty
            //    $notifier->last_leave(find_leavers($e->json->occupied));
            //}

            if ($e->json->occupied === $e->json->ts) {
                // Lab got first visitor
                $user = db_execute($find_user_by_id, [$e->json->ids[0]])->fetchArray(SQLITE3_ASSOC);
                $notifier->first_join($user);
            }
        break;

        case 'light_watcher.service':
            if ($e->json === NULL) break;

            if ($e->json === 1) {
                $notifier->first_join_light();
            }else {
                $notifier->last_leave(find_leavers($e->json->occupied));
            }

            break;
    }  
}