{ 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 { imports = [ ./ota.nix ]; 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}" ] ''; }; }