mirror of
https://github.com/fhem/fhem-mirror.git
synced 2025-03-10 09:16:53 +00:00
HMCCU: CCU RPC server
git-svn-id: https://svn.fhem.de/fhem/trunk@10012 2b470e98-0d58-463d-a4d8-8e2adae1ed80
This commit is contained in:
fhemzap
parent
b57d96e7c3
commit
862b2ba5c0
294
fhem/contrib/HMCCU/ccurpcd.pl
Executable file
294
fhem/contrib/HMCCU/ccurpcd.pl
Executable file
@ -0,0 +1,294 @@
|
||||
#!/usr/bin/perl
|
||||
|
||||
#########################################################
|
||||
# ccurpcd.pl
|
||||
#
|
||||
# Version 1.0
|
||||
#
|
||||
# RPC server for Homematic CCU.
|
||||
#
|
||||
# (C) 2015 by zap
|
||||
#--------------------------------------------------------
|
||||
# Usage:
|
||||
#
|
||||
# ccurpcd.pl Hostname Port QueueFile LogFile
|
||||
#--------------------------------------------------------
|
||||
# Queue file entries:
|
||||
#
|
||||
# ND|Address|Type
|
||||
# UD|Address|Hint
|
||||
# DD|Address
|
||||
# EV|Address|Attribute|Value
|
||||
# EX|SHUTDOWN|0
|
||||
#########################################################
|
||||
|
||||
use strict;
|
||||
use warnings;
|
||||
use File::Queue;
|
||||
use RPC::XML::Server;
|
||||
use RPC::XML::Client;
|
||||
use XML::Simple qw(:strict);
|
||||
use IO::Socket::INET;
|
||||
|
||||
|
||||
# Global variables
|
||||
my $client;
|
||||
my $server;
|
||||
my $queue;
|
||||
my $logfile;
|
||||
my $shutdown = 0;
|
||||
my %devnames;
|
||||
|
||||
|
||||
#####################################
|
||||
# Write logfile entry
|
||||
#####################################
|
||||
|
||||
sub Log ($)
|
||||
{
|
||||
my @messages = @_;
|
||||
my ($sec, $min, $hour, $mday, $mon, $year, $wday, $yday, $isdst) = localtime ();
|
||||
|
||||
if (open (LOGFILE, '>>', $logfile)) {
|
||||
printf LOGFILE "%02d.%02d.%04d %02d:%02d:%02d ",
|
||||
$mday,$mon+1,$year+1900,$hour,$min,$sec;
|
||||
foreach my $token (@messages) {
|
||||
print LOGFILE $token;
|
||||
}
|
||||
print LOGFILE "\n";
|
||||
close LOGFILE;
|
||||
}
|
||||
}
|
||||
|
||||
#####################################
|
||||
# Write queue entry
|
||||
#####################################
|
||||
|
||||
sub WriteQueue ($)
|
||||
{
|
||||
my ($message) = @_;
|
||||
|
||||
$queue->enq ($message);
|
||||
|
||||
return 1;
|
||||
}
|
||||
|
||||
#####################################
|
||||
# Shutdown RPC connection
|
||||
#####################################
|
||||
|
||||
sub CCURPC_Shutdown ($)
|
||||
{
|
||||
my ($callbackurl) = @_;
|
||||
|
||||
if ($callbackurl && $shutdown == 0) {
|
||||
Log ("Shutdown RPC server");
|
||||
WriteQueue ("EX|SHUTDOWN|0");
|
||||
$client->send_request("init", $callbackurl);
|
||||
$shutdown = 1;
|
||||
}
|
||||
|
||||
return undef;
|
||||
}
|
||||
|
||||
#####################################
|
||||
# Initialize RPC connection
|
||||
#####################################
|
||||
|
||||
sub CCURPC_Initialize ($$)
|
||||
{
|
||||
my ($serveraddr, $serverport) = @_;
|
||||
my $callbackport = 5400+$serverport;
|
||||
|
||||
# Detect local IP
|
||||
my $socket = IO::Socket::INET->new (PeerAddr => $serveraddr, PeerPort => $serverport);
|
||||
if (!$socket) {
|
||||
Log "Can't connect to CCU";
|
||||
return undef;
|
||||
}
|
||||
my $localaddr = $socket->sockhost ();
|
||||
close ($socket);
|
||||
|
||||
$client = RPC::XML::Client->new ("http://$serveraddr:$serverport/");
|
||||
$server = RPC::XML::Server->new (port=>$callbackport);
|
||||
if (!ref($server))
|
||||
{
|
||||
Log "Can't create RPC callback server on port $callbackport. Port in use?";
|
||||
return undef;
|
||||
}
|
||||
else {
|
||||
Log "callback server created";
|
||||
}
|
||||
|
||||
# Callback for events
|
||||
Log "Adding callback for events";
|
||||
$server->add_method (
|
||||
{ name=>"event",
|
||||
signature=> ["string string string string int","string string string string double","string string string string boolean","string string string string i4"],
|
||||
code=>\&CCURPC_EventCB
|
||||
}
|
||||
);
|
||||
|
||||
# Callback for new devices
|
||||
Log "Adding callback for new devices";
|
||||
$server->add_method (
|
||||
{ name=>"newDevices",
|
||||
signature=>["string string array"],
|
||||
code=>\&CCURPC_NewDevicesCB
|
||||
}
|
||||
);
|
||||
|
||||
# Callback for deleted devices
|
||||
Log "Adding callback for deleted devices";
|
||||
$server->add_method (
|
||||
{ name=>"deleteDevices",
|
||||
signature=>["string string array"],
|
||||
code=>\&CCURPC_DeleteDevicesCB
|
||||
}
|
||||
);
|
||||
|
||||
# Callback for modified devices
|
||||
Log "Adding callback for modified devices";
|
||||
$server->add_method (
|
||||
{ name=>"updateDevice",
|
||||
signature=>["string string string int"],
|
||||
code=>\&CCURPC_UpdateDeviceCB
|
||||
}
|
||||
);
|
||||
|
||||
# Dummy implementation, always return an empty array
|
||||
$server->add_method (
|
||||
{ name=>"listDevices",
|
||||
signature=>["array string"],
|
||||
code=>\&CCURPC_ListDevicesCB
|
||||
}
|
||||
);
|
||||
|
||||
# $CCURPC_SERVERSOCKET = $server->{__daemon};
|
||||
# $CCURPC_FD = $CCURPC_SERVERSOCKET->fileno();
|
||||
my $ccurpcport = $server->{__daemon}->sockport();
|
||||
|
||||
# Register callback
|
||||
my $callbackurl = "http://".$localaddr.":".$ccurpcport."/fh";
|
||||
Log "Registering callback";
|
||||
|
||||
$client->send_request ("init",$callbackurl,"CB1");
|
||||
Log "RPC callback with URL ".$callbackurl." initialized";
|
||||
|
||||
return $callbackurl;
|
||||
}
|
||||
|
||||
#####################################
|
||||
# Callback for new devices
|
||||
#####################################
|
||||
|
||||
sub CCURPC_NewDevicesCB ($$$)
|
||||
{
|
||||
my ($server, $cb, $a) = @_;
|
||||
|
||||
Log "NewDevice: received ".scalar(@$a)." device specifications";
|
||||
|
||||
# for my $dev (@$a) {
|
||||
# my $dn = (defined ($devnames{$dev->{ADDRESS}})) ? $devnames{$dev->{ADDRESS}} : "??";
|
||||
# WriteQueue ("ND|".$dev->{ADDRESS}."|".$dev->{TYPE});
|
||||
# }
|
||||
|
||||
# return RPC::XML::array->new();
|
||||
return;
|
||||
}
|
||||
|
||||
#####################################
|
||||
# Callback for deleted devices
|
||||
#####################################
|
||||
|
||||
sub CCURPC_DeleteDevicesCB ($$$)
|
||||
{
|
||||
my ($server, $cb, $a) = @_;
|
||||
|
||||
Log "DeleteDevice: received ".scalar(@$a)." device addresses";
|
||||
|
||||
for my $dev (@$a) {
|
||||
WriteQueue ("DD|".$dev);
|
||||
}
|
||||
}
|
||||
|
||||
#####################################
|
||||
# Callback for modified devices
|
||||
#####################################
|
||||
|
||||
sub CCURPC_UpdateDeviceCB ($$$$)
|
||||
{
|
||||
my ($server, $cb, $devid, $hint) = @_;
|
||||
|
||||
WriteQueue ("UD|".$devid."|".$hint);
|
||||
|
||||
return;
|
||||
}
|
||||
|
||||
#####################################
|
||||
# Callback for handling CCU events
|
||||
#####################################
|
||||
|
||||
sub CCURPC_EventCB ($$$$$)
|
||||
{
|
||||
my ($server,$cb,$devid,$attr,$val)=@_;
|
||||
|
||||
WriteQueue ("EV|".$devid."|".$attr."|".$val);
|
||||
|
||||
# Never remove this statement!
|
||||
return;
|
||||
}
|
||||
|
||||
#####################################
|
||||
# Callback for list devices
|
||||
#####################################
|
||||
|
||||
sub CCURPC_ListDevicesCB ()
|
||||
{
|
||||
Log "ListDevices";
|
||||
|
||||
return RPC::XML::array->new();
|
||||
}
|
||||
|
||||
#####################################
|
||||
# MAIN
|
||||
#####################################
|
||||
|
||||
# Process command line arguments
|
||||
if ($#ARGV+1 != 4) {
|
||||
die "Usage: ccurpc.pl CCU-Host Port QueueFile LogFile\n";
|
||||
}
|
||||
|
||||
my $ccuhost = $ARGV[0];
|
||||
my $ccuport = $ARGV[1];
|
||||
my $queuefile = $ARGV[2];
|
||||
$logfile = $ARGV[3];
|
||||
|
||||
# Create or open queue
|
||||
Log "Creating file queue";
|
||||
$queue = new File::Queue (File => $queuefile, Mode => 0666);
|
||||
if (!defined ($queue)) {
|
||||
Log "Error: Can't create queue";
|
||||
die "Error: Can't create queue\n";
|
||||
}
|
||||
else {
|
||||
$queue->reset ();
|
||||
while ($queue->deq ()) { }
|
||||
}
|
||||
|
||||
# Initialize RPC server
|
||||
Log "Initializing RPC server";
|
||||
my $callbackurl = CCURPC_Initialize ($ccuhost, $ccuport);
|
||||
if (!defined ($callbackurl)) {
|
||||
Log "Error: Can't initialize RPC server";
|
||||
die "Error: Can't initialize RPC server\n";
|
||||
}
|
||||
|
||||
# Server loop is interruptable bei SIGNINT
|
||||
Log "Entering server loop. Use kill -SIGINT $$ to terminate program";
|
||||
$server->server_loop;
|
||||
|
||||
# Shutdown RPC server
|
||||
CCURPC_Shutdown ($callbackurl);
|
||||
Log "RPC server terminated";
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user