zm_alarm_handling.pl

#!/usr/bin/perl -w


#---------------- Configurations ------------------------------------------------------------------------------------
use constant OPENHAB_URL => "http://openhab2:8080";		#Base URL of Openhab
use constant MONITOR_RELOAD_INTERVAL => 300;			#Time in second for reload Monitor from ZM
use constant SLEEP_DELAY=>2;							#Time in second for checking loop
use constant ALARM_COUNT => 3;							#Number of alarm event to raise action to OpenHab
#---------------- End of Configurations ------------------------------------------------------------------------------

use strict;
use ZoneMinder;
use warnings;
use DBI;

$| = 1;

$SIG{INT}  = \&signal_handler;
$SIG{TERM} = \&signal_handler;

my %monitors;
my $dbh = zmDbConnect();								#ZM function to create DB object
my $monitor_reload_time = 0;
my $apns_feedback_time = 0;
my $proxy_reach_time=0;
my $wss;
my @events=();
my @active_connections=();
my $alarm_header="";
my $alarm_mid="";
my $alarmEventId = 1;           # tags the event id along with the alarm - useful for correlation
my @camstatus = ("NONE","NONE","NONE","NONE","NONE","NONE","OFF","OFF","OFF","OFF","OFF","OFF"); #Array with alarm status
my @firstrun = (0,0,0,0,0,0,0,0,0,0,0,0);
my @alarmcount = (0,0,0,0,0,0,0,0,0,0,0,0);

Info( "ALL - Alarm Monitor Handling module starting" );

while( 1 )
{
	my $eventFound = 0;
	#Every MONITOR_RELOAD_INTERVAL reload monitor from database
    if ( (time() - $monitor_reload_time) > MONITOR_RELOAD_INTERVAL )
        {
        Info ("ALL - Reloading Monitors...\n");
        foreach my $monitor (values(%monitors))
        {
            zmMemInvalidate( $monitor );
        }
        loadMonitors();
		Info ("ALL - Firstrun status= @firstrun\n");
		Info ("ALL - Alarm Status= @camstatus\n");
    }

    @events = ();
    $alarm_header = "";
    $alarm_mid="";
    foreach my $monitor ( values(%monitors) )
    {
        next if ( !zmMemVerify( $monitor ) );
		
		my ( $state, $last_event )
            = zmMemRead( $monitor,
                 [ "shared_data:state",
                   "shared_data:last_event"
                 ]
			);
		
		#Decodifica Stati
		#STATE_IDLE     => 0;
		#STATE_PREALARM => 1;
		#STATE_ALARM    => 2;
		#STATE_ALERT    => 3;
		#STATE_TAPE     => 4;
		
		#If an alarm status is detected
        if ($state == STATE_ALARM || $state == STATE_ALERT)
        {
			#Info ("Alarm Detected on cam=".$monitor->{Name});
			my $count = @alarmcount[$monitor->{Id}]; 	#Retrieve count from array
			$count = $count+1;							#Increase count of one
			@alarmcount[$monitor->{Id}] = $count;		#Update the array
			Info ($monitor->{Name}." - Alarm Detected");
			if ($count >= ALARM_COUNT) {
				if (@camstatus[$monitor->{Id}] ne decodeState($state))	#If CAM status is not equal to previus status
				{
					&sendtoOH($monitor->{Id},$state,$monitor->{Name});								#Send notification ro OpenHab
					@camstatus[$monitor->{Id}] = decodeState($state);				#Update the array with last status
					Info ($monitor->{Name}." - Global Alarm Count= @alarmcount\n");		#Log alarmcount
				}
			}
		}
		
		#If an alarm is rearmed
		if ($state == STATE_IDLE || $state == STATE_TAPE)
        {
			my $count = @alarmcount[$monitor->{Id}];
			if (@camstatus[$monitor->{Id}] ne decodeState($state))
			{
				@alarmcount[$monitor->{Id}] = 0;						#reset alarmcount array
				if ($count >= ALARM_COUNT) {							#if alarm count greater the threashold, send the notification to OH
					&sendtoOH($monitor->{Id},$state,$monitor->{Name});	#send off command to OH
				}
				@camstatus[$monitor->{Id}] = decodeState($state);		#Update the array with last status
				Info ($monitor->{Name}." - Alarm Rearmed");
				Info ($monitor->{Name}." - Global Alarm Count= @alarmcount\n");
			}
		}
    }
    sleep( SLEEP_DELAY );
}

#This sub decode numeric state of ZM in OH state for the Alarm's Switch
sub decodeState
{
	use Switch;
	my ($stato) = @_;
	my $oh_state = "NONE";
	
	switch ($stato) {
		case 2		{ $oh_state = "ON"; }
		case 3		{ $oh_state = "ON"; }
		case 4		{ $oh_state = "OFF"; }
		case 0		{ $oh_state = "OFF"; }
		else		{ $oh_state = "NONE"; }
	}
	return ($oh_state);
}

#Compose the command for OH
sub sendtoOH
{
	my ($monid, $stato,$monname) = @_;
	my $oh_state = decodeState($stato);
	
	if ($oh_state ne "NONE")
	{
		use REST::Client;
		my $host = OPENHAB_URL;
		my $client = REST::Client->new(host => $host);
		my $url = "/rest/items/CAM_ID".$monid."_ALARM/state";	#Composing Item Name into REST URL
		Info($monname." - Send Command: ".OPENHAB_URL.$url." ".$oh_state);
		#Write stuff to HTTP with REST Client
		$client->PUT($url, $oh_state);
		Info($monname." - Client Result: ".$client);
	}
}

# Refreshes list of monitors from DB
sub loadMonitors
{
    Info( "ALL - Loading monitors\n" );
    $monitor_reload_time = time();

    my %new_monitors = ();

    my $sql = "SELECT * FROM Monitors
               WHERE find_in_set( Function, 'Modect,Mocord,Nodect' )".
               ( $Config{ZM_SERVER_ID} ? 'AND ServerId=?' : '' );
    Debug ("SQL to be executed is :$sql");
     my $sth = $dbh->prepare_cached( $sql )
        or Fatal( "Can't prepare '$sql': ".$dbh->errstr() );
    my $res = $sth->execute( $Config{ZM_SERVER_ID} ? $Config{ZM_SERVER_ID} : () )
        or Fatal( "Can't execute: ".$sth->errstr() );
    while( my $monitor = $sth->fetchrow_hashref() )
    {
        next if ( !zmMemVerify( $monitor ) ); # Check shared memory ok

        if ( defined($monitors{$monitor->{Id}}->{LastState}) )
        {
            $monitor->{LastState} = $monitors{$monitor->{Id}}->{LastState};
        }
        else
        {
            $monitor->{LastState} = zmGetMonitorState( $monitor );
        }
        if ( defined($monitors{$monitor->{Id}}->{LastEvent}) )
        {
            $monitor->{LastEvent} = $monitors{$monitor->{Id}}->{LastEvent};
        }
        else
        {
            $monitor->{LastEvent} = zmGetLastEvent( $monitor );
        }
        $new_monitors{$monitor->{Id}} = $monitor;
		
		#For each monitor check if is first run and if yes, send OFF to OpenHab
		if (@firstrun[$monitor->{Id}] == 0)
		{
			Info ($monitor->{Name}." - First Run - Sendig OFF to cam ID".$monitor->{Id});
			&sendtoOH($monitor->{Id},0,,$monitor->{Name});
			@firstrun[$monitor->{Id}] = 1;			
		}
    }
    %monitors = %new_monitors;
}

sub signal_handler {
	Info( "ALL - ZM Alarm Monitor Handling module stopping" );
	exit 0
}