2016-03-16 23:02:51.219,pushbullet.pl,Warning: Subroutine read_from_config redefined at (eval 8900) line 63. 2016-03-16 23:02:51.220,pushbullet.pl,lines # pushbullet.pl - Konfiguration # # GA=>'1/4/20', = GA die getriggert wird # type=>'note' # title=>'' # body_on=>'' = Text wenn GA auf 1 # body_off=>'' = Text wenn GA auf 0 %push=( push =>{GA=>'1/1/5',type=>'note',title=>'Haustuer',body_on=>'AUS',body_o ff=>'EIN'}, ); 2016-03-16 23:02:51.223,pushbullet.pl,config error,0s,
[1/1/5] DPTSubId = 1.001 short = Haustür ga = 1/1/5 DPTId = 1 name = Haustür anaus DPT_SubTypeName = DPT_Switch
# s. https://knx-user-forum.de/forum/supportforen/wiregate/843200-freibier-neues-wg-plugin-pushbullet-sender-f%C3%BCr-wg
# Pushbullet Sender für WG
# In conf GA, title und body eintragen
# wenn GA=1 dann werden title und body gesendet
# by NetFritz KNX-Userforum
# Konfigurationsfile einlesen
my $conf=$plugname; $conf=~s/\.pl$/.conf/;
$conf="/etc/wiregate/plugin/generic/conf.d/$conf";
my %push=();
my $err=read_from_config();
return $err if $err;
#
# in $iso steht Datum-Zeit = 'd.m.Y H:M'
my @dta = localtime(time);
my $iso=sprintf('%02d.',$dta[3]);
$iso.=sprintf('%02d.',$dta[4]+1);
$iso.=($dta[5]+1900)." ";
$iso.=sprintf('%02d:',$dta[2]);
$iso.=sprintf('%02d',$dta[1]);
#
$plugin_info{$plugname.'_cycle'} = 3600;
# Alle GAs aus der config abonnieren
for my $r (grep ref($push{$_}), keys %push)
{
$plugin_subscribe{$push{$r}{GA}}{$plugname}=1;
plugin_log($plugname, "plugin_subscribe $push{$r}{GA}");
}
my $req = "";
my $body = "";
# BUS ueberwachen
if ($msg{'apci'} eq "A_GroupValue_Write") { # A_GroupValue_Write Telegramm eingetroffen
plugin_log($plugname, "subscribe wurde ausgefuehrt");
for my $r (grep ref($push{$_}), keys %push){ # Ueberwachte GAs durchlaufen
if ($msg{'dst'} eq $push{$r}{GA}){ # GAs vergleichen
if($msg{'value'} == 1){
$body = $push{$r}{body_on};
$plugin_info{$plugname.'_'.$r.'_alt'} = 1;
}elsif($msg{'value'} == 0){
$body = $push{$r}{body_off};
$plugin_info{$plugname.'_'.$r.'_alt'} = 0;
}
# Push senden
use LWP::UserAgent;
use HTTP::Request::Common qw(POST);
my $ua = LWP::UserAgent->new;
my $req = POST 'https://api.pushbullet.com/v2/pushes',
[
type => 'note',
title => $push{$r}{title},
body => $iso." ". $body
];
$req->authorization_basic('mein_PB_API_Key');
#return ($push{$r}{GA});
print ($ua->request($req)->as_string);
plugin_log($plugname, "$push{$r}{title} $push{$r}{body} $msg{'value'}");
}
}
}
return;
# ------------- config einlesen ----------------------
sub read_from_config
{
open CONFIG, "<$conf" || return "no config found";
my @lines = <CONFIG>;
close CONFIG;
plugin_log($plugname, "lines @lines");
eval("@lines");
return "config error" if $@;
}
# return;
# Einfaches Plugin zum debuggen aller aktiven Plugin-subscriptions
# just zur Doku
$plugin_info{$plugname.'_cycle'} = 3600;
my $ret;
for my $k ( sort keys %plugin_subscribe ) {
for my $p ( keys %{$plugin_subscribe{ $k }} ) {
$ret .= "Plugin $p subscribed to $k\n";
}
}
for my $k ( sort keys %plugin_socket_subscribe ) {
$ret .= "Plugin $plugin_socket_subscribe{$k} subscribed to socket $k\n";
}
#return; # no debug out
return $ret;
no warnings;
#return;
# Pushbullet Sender für WG
# In conf GA, title und body eintragen
# wenn GA=1 dann werden title und body gesendet
# by NetFritz KNX-Userforum
# Konfigurationsfile einlesen
my $conf=$plugname; $conf=~s/\.pl$/.conf/;
$conf="/etc/wiregate/plugin/generic/conf.d/$conf";
my %push=();
my $err=read_from_config();
return $err if $err;
#
# in $iso steht Datum-Zeit = 'd.m.Y H:M'
my @dta = localtime(time);
my $iso=sprintf('%02d.',$dta[3]);
$iso.=sprintf('%02d.',$dta[4]+1);
$iso.=($dta[5]+1900)." ";
$iso.=sprintf('%02d:',$dta[2]);
$iso.=sprintf('%02d',$dta[1]);
#
$plugin_info{$plugname.'_cycle'} = 3600;
# Alle GAs aus der config abonnieren
for my $r (grep ref($push{$_}), keys %push)
{
$plugin_subscribe{$push{$r}{GA}}{$plugname}=1;
plugin_log($plugname, "GA= $push{$r}{GA}");
#$plugin_info{$plugname.'_'.$r.'_alt'} = knx_read("$push{$r}{GA}",300,"");
}
my $req = "";
my $body = "";
# BUS ueberwachen
if ($msg{'apci'} eq "A_GroupValue_Write") { # A_GroupValue_Write Telegramm eingetroffen
plugin_log($plugname, "Telegramm test ist da");
for my $r (grep ref($push{$_}), keys %push){ # Ueberwachte GAs durchlaufen
plugin_log($plugname, "1 $push{$r}{title} $push{$r}{body} $msg{'value'}");
if ($msg{'dst'} eq $push{$r}{GA}){ # GAs vergleichen
if($msg{'value'} == 1 && $plugin_info{$plugname.'_'.$r.'_alt'} == 0 ){
#plugin_log($plugname,"PluginInfo 0= $plugin_info{$plugname.'_'.$r.'_alt'}";
$body = $push{$r}{body_on};
send_push($iso,$body,$push{$r}{title});
$plugin_info{$plugname.'_'.$r.'_alt'} = 1;
}elsif($msg{'value'} == 0 && $plugin_info{$plugname.'_'.$r.'_alt'} == 1 ){
$body = $push{$r}{body_off};
send_push($iso,$body,$push{$r}{title});
$plugin_info{$plugname.'_'.$r.'_alt'} = 0;
}
}
}
}
# Push senden
sub send_push{
my $iso1 = $_[0];
my $body1 = $_[1];
my $push1 = $_[2];
use LWP::UserAgent;
use HTTP::Request::Common qw(POST);
my $ua = LWP::UserAgent->new;
my $req = POST 'https://api.pushbullet.com/v2/pushes',
[
type => 'note',
title => $push1,
body => $iso1." ". $body1
];
$req->authorization_basic('xxxxxxxxxxxxxxxxxxxxxxxx');
#return ($push{$r}{GA});
print ($ua->request($req)->as_string);
}
return;
# ------------- config einlesen ----------------------
sub read_from_config
{
open CONFIG, "<$conf" || return "no config found";
my @lines = <CONFIG>;
close CONFIG;
eval("@lines");
return "config error" if $@;
}
# pushbullet.pl - Konfiguration
#
# GA=>'1/4/20', = GA die getriggert wird
# type=>'note'
# title=>''
# body_on=>'' = Text wenn GA auf 1
# body_off=>'' = Text wenn GA auf 0
%push=(
push =>{GA=>'1/3/74',type=>'note',title=>'WP',body_on=>'AUS',body_off=>'EIN'},
);
Kommentar