[Openautomation-svn] SF.net SVN: openautomation:[692] wiregate/plugin/generic

[<ma...@us...>]

Revision: 692
          http://openautomation.svn.sourceforge.net/openautomation/?rev=692&view=rev
Author:   makki1
Date:     2012-02-09 19:27:42 +0000 (Thu, 09 Feb 2012)
Log Message:
-----------
Plugin Prowl and some enhancement on DaemonStartStop

Modified Paths:
--------------
    wiregate/plugin/generic/DaemonStartStop
    wiregate/plugin/generic/Prowl.pl

Modified: wiregate/plugin/generic/DaemonStartStop
===================================================================
--- wiregate/plugin/generic/DaemonStartStop	2012-02-08 19:13:45 UTC (rev 691)
+++ wiregate/plugin/generic/DaemonStartStop	2012-02-09 19:27:42 UTC (rev 692)
@@ -1,6 +1,8 @@
 # Plugin um daemons (Dienste) per KNX Gruppenadresse zu starten/beenden
 # pptpd in diesem Beispiel, geht natuerlich auch fuer alle anderen
 # Eigenen Aufruf-Zyklus auf taeglich setzen
+# v0.2 - auch nach reboot deaktivieren
+
 $plugin_info{$plugname.'_cycle'} = 86400;
 
 ##############################################################################
@@ -17,10 +19,12 @@
 if (%msg) {
   if ($msg{'apci'} eq "A_GroupValue_Write" and $ga eq $msg{'dst'}) {
 	if($msg{'data'}+0) {
+		$dummy = `update-rc.de $daemon defaults`;
 		$dummy = `/etc/init.d/$daemon restart`;
 		return; # "started $daemon
 	} else {
 		$dummy = `/etc/init.d/$daemon stop`;
+		$dummy = `update-rc.de $daemon remove`;
 		return; # "stopped $daemon
 	}
   }
@@ -29,4 +33,4 @@
     # subscribe GA's
       $plugin_subscribe{$ga}{$plugname} = 1;
 }
-return;
\ No newline at end of file
+return;

Modified: wiregate/plugin/generic/Prowl.pl
===================================================================
--- wiregate/plugin/generic/Prowl.pl	2012-02-08 19:13:45 UTC (rev 691)
+++ wiregate/plugin/generic/Prowl.pl	2012-02-09 19:27:42 UTC (rev 692)
@@ -1,6 +1,7 @@
 # Plugin um Nachrichten an Prowl zu senden
-# Version: 0.1 2010-10-14
-# Ben\xF6tigt einen Prowl-Account sowie API-Key
+# Version: 0.2 2012-01-09
+# Mit Wertabhaengigkeit, low/high-Filter
+# Benötigt einen Prowl-Account sowie API-Key
 
 ##################
 ### DEFINITION ###
@@ -8,19 +9,29 @@
 
 my $socknum = 8;                # Eindeutige Nummer des Sockets
 
-# Eigenen Aufruf-Zyklus setzen (Initialisierung/zyklisches pr\xFCfen)
+# Eigenen Aufruf-Zyklus setzen (Initialisierung/zyklisches prüfen)
 $plugin_info{$plugname.'_cycle'} = 300;
 
 my %options = ();
 $options{'apikey'} = "xyzxyz";
 
 
-# Zwei M\xF6glichkeiten zur Nutzung:
+# Zwei Möglichkeiten zur Nutzung:
 # VARIANTE 1: Bitwert auf GA sendet fixes Nachricht:
 my %prowl_ga; # Eintrag darf nicht auskommentiert werden, solange nachfolgend keine GA definiert erfolgt kein Versand!
 $prowl_ga{'14/5/208'} = '0;Event;Description Hallo;Application'; # Priority,Event,Description,Application - ggfs. NUR DIESE Zeile auskommentieren!
 
-# VARIANTE 2: Plugin horcht auf UDP-Port und empf\xE4ngt Format PRIO;Event;Description;Application\n
+# VARIANTE 1a: Wert im Text mit ausgeben, printf-Syntax - DPT der GA muss konfiuriert sein!
+$prowl_ga{'14/5/208'} = '0;Event;Wert %.2f;Application'; # Priority,Event,Description,Application - ggfs. NUR DIESE Zeile auskommentieren!
+$prowl_ga{'5/0/1'}[0] = '0;ausgeschaltet;Description Hallo;Buero Beleuchtung'; # Priority,Event,Description,Application - ggfs. NUR DIESE Zeile auskommentieren!
+$prowl_ga{'5/0/1'}[1] = '0;eingeschaltet;Description Hallo;Buero Beleuchtung'; # Priority,Event,Description,Application - ggfs. NUR DIESE Zeile auskommentieren!
+$prowl_ga{'4/0/0'} = '0;eingeschaltet;Description Hallo;Temperatur %.2f'; # Priority,Event,Description,Application - ggfs. NUR DIESE Zeile auskommentieren!
+my %prowl_ga_limit_high;
+my %prowl_ga_limit_low;
+$prowl_ga_limit_high{'4/0/0'} = 28;
+$prowl_ga_limit_low{'4/0/0'} = 25;
+
+# VARIANTE 2: Plugin horcht auf UDP-Port und empf�ngt Format PRIO;Event;Description;Application\n
 my $recv_ip = "0.0.0.0"; # Empfangs-IP
 my $recv_port = "50018"; # Empfangsport 
 
@@ -40,20 +51,34 @@
                               LocalAddr => $recv_ip,
                               ReuseAddr => 1
                                )
-	     or return ("open of $recv_ip : $recv_port failed: $!");
+         or return ("open of $recv_ip : $recv_port failed: $!");
     $socksel->add($socket[$socknum]); # add socket to select
     $plugin_socket_subscribe{$socket[$socknum]} = $plugname; # subscribe plugin
     # subscribe GA's
- 		while( my ($k, $v) = each(%prowl_ga) ) {
+         while( my ($k, $v) = each(%prowl_ga) ) {
       # Plugin an Gruppenadresse "anmelden"
       $plugin_subscribe{$k}{$plugname} = 1;
- 		}
+         }
     return "opened UDP-Socket $socknum";
 } 
 
 if (%msg) { # telegramm vom KNX
   if ($msg{'apci'} eq "A_GroupValue_Write" and $prowl_ga{$msg{'dst'}}) {
-        return sendProwl($prowl_ga{$msg{'dst'}});
+    if ($msg{'data'} eq "00") {
+        return sendProwl($prowl_ga{$msg{'dst'}}[0]);
+        }
+    elsif ($msg{'data'} eq "01") {
+        return sendProwl($prowl_ga{$msg{'dst'}}[1]);
+        }
+    elsif (defined $prowl_ga_limit_high{$msg{'dst'}} && $msg{'value'} > $prowl_ga_limit_high{$msg{'dst'}}) {
+        return sendProwl(sprintf($prowl_ga{$msg{'dst'}},$msg{'value'}));
+        }
+    elsif (defined $prowl_ga_limit_high{$msg{'dst'}} && $msg{'value'} < $prowl_ga_limit_low{$msg{'dst'}}) {
+        return sendProwl(sprintf($prowl_ga{$msg{'dst'}},$msg{'value'}));
+    }
+    else {
+        return sendProwl(sprintf($prowl_ga{$msg{'dst'}},$msg{'value'}));
+    }
   }
 } elsif ($fh) { # UDP-Packet
         my $buf = <$fh>;
@@ -62,10 +87,10 @@
 } else {
     # cyclic/init/change
     # subscribe GA's
- 		while( my ($k, $v) = each(%prowl_ga) ) {
+         while( my ($k, $v) = each(%prowl_ga) ) {
       # Plugin an Gruppenadresse "anmelden"
       $plugin_subscribe{$k}{$plugname} = 1;
- 		}
+         }
     return; # ("return dunno");
 }
 
@@ -84,11 +109,11 @@
   $userAgent->agent("WireGatePlugin/1.0");
   
   $requestURL = sprintf("https://prowl.weks.net/publicapi/add?apikey=%s&application=%s&event=%s&description=%s&priority=%d",
-  				$options{'apikey'},
-  				$options{'application'},
-  				$options{'event'},
-  				$options{'notification'},
-  				$options{'priority'});
+                  $options{'apikey'},
+                  $options{'application'},
+                  $options{'event'},
+                  $options{'notification'},
+                  $options{'priority'});
   
   $request = HTTP::Request->new(GET => $requestURL);
   #$request->timeout(5);
@@ -96,13 +121,12 @@
   $response = $userAgent->request($request);
   
   if ($response->is_success) {
-  	return "Notification successfully posted: $options{'priority'},$options{'event'},$options{'description'},$options{'application'}";
+      return "Notification successfully posted: $options{'priority'},$options{'event'},$options{'description'},$options{'application'}";
   } elsif ($response->code == 401) {
-  	return "Notification not posted: incorrect API key.";
+      return "Notification not posted: incorrect API key.";
   } else {
-  	return "Notification not posted: " . $response->content;
+      return "Notification not posted: " . $response->content;
   }
 
 }
 
-return;

This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.