43 lines
966 B
Nix
43 lines
966 B
Nix
{ pkgs, lib, ... }:
|
|
|
|
with lib;
|
|
let
|
|
port = 3001;
|
|
runit = pkgs.writeDash "runit" ''
|
|
set -xeuf
|
|
PATH=${pkgs.mosquitto}/bin:${pkgs.coreutils}/bin
|
|
name=''${1?must provide name as first arg}
|
|
state=''${2?must provide state as second arg}
|
|
# val=''${3?must provide val as third arg}
|
|
|
|
# we ignore non-alerting events
|
|
test $state = alerting || exit 0
|
|
|
|
echo $name - $state
|
|
topic=plug
|
|
mosquitto_pub -t /bam/$topic/cmnd/POWER -m ON
|
|
sleep 5
|
|
mosquitto_pub -t /bam/$topic/cmnd/POWER -m OFF
|
|
'';
|
|
in {
|
|
services.logstash = {
|
|
package = pkgs.logstash5;
|
|
enable = true;
|
|
inputConfig = ''
|
|
http {
|
|
port => ${toString port}
|
|
host => "127.0.0.1"
|
|
}
|
|
'';
|
|
filterConfig = ''
|
|
'';
|
|
outputConfig = ''
|
|
stdout { codec => json }
|
|
exec { command => "${runit} '%{ruleName}' '%{state}'" }
|
|
'';
|
|
extraSettings = ''
|
|
path.plugins: [ "${pkgs.logstash-output-exec}" ]
|
|
'';
|
|
};
|
|
}
|