FHEM/mod-NUKI
1
0
Fork 0
Code Issues Pull Requests Releases 4 Wiki Activity

IOWrite Call rewrite for FHEM2FHEM support and more #1

Merged
marko merged 2 commits from patch-rewrite_dispatching into devel 2021-11-25 20:59:40 +00:00
Conversation 0 Commits 2 Files Changed 2 +55 -35
2 changed files with 55 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 2147564a5d - Show all commits

58
73_NUKIBridge.pm
View File

@@ -2,7 +2,7 @@
#
# Developed with Kate
#
# (c) 2016-2020 Copyright: Marko Oldenburg (leongaultier at gmail dot com)
# (c) 2016-2021 Copyright: Marko Oldenburg (fhemdevelopment at cooltux dot net)
# All rights reserved
#
# This script is free software; you can redistribute it and/or modify
@@ -370,7 +370,8 @@ sub Attr(@) {
. $hash->{WEBHOOK_URI};
Log3( $name, 3, "NUKIBridge ($name) - URL ist: $url" );
Write( $hash, 'callback/add', $url, undef, undef )
# Write( $hash, 'callback/add', $url, undef, undef )
Write( $hash, 'callback/add', '{"param":"' . $url . '}' )
if ($init_done);
$hash->{WEBHOOK_REGISTER} = 'sent';
}
@@ -444,54 +445,48 @@ sub Set($@) {
my ( $hash, $name, $cmd, @args ) = @_;
my ( $arg, @params ) = @args;
my $endpoint;
if ( lc($cmd) eq 'getdevicelist' ) {
return 'usage: getDeviceList' if ( @args != 0 );
Write( $hash, 'list', undef, undef, undef )
if ( !IsDisabled($name) );
return undef;
$endpoint = 'list';
}
elsif ( $cmd eq 'info' ) {
return 'usage: statusRequest' if ( @args != 0 );
Write( $hash, 'info', undef, undef, undef )
if ( !IsDisabled($name) );
return undef;
$endpoint = 'info';
}
elsif ( lc($cmd) eq 'fwupdate' ) {
return 'usage: fwUpdate' if ( @args != 0 );
Write( $hash, 'fwupdate', undef, undef, undef )
if ( !IsDisabled($name) );
return undef;
$endpoint = 'fwupdate';
}
elsif ( $cmd eq 'reboot' ) {
return 'usage: reboot' if ( @args != 0 );
Write( $hash, 'reboot', undef, undef, undef )
if ( !IsDisabled($name) );
return undef;
$endpoint = 'reboot';
}
elsif ( lc($cmd) eq 'clearlog' ) {
return 'usage: clearLog' if ( @args != 0 );
Write( $hash, 'clearlog', undef, undef, undef )
if ( !IsDisabled($name) );
$endpoint = 'clearlog';
}
elsif ( lc($cmd) eq 'factoryreset' ) {
return 'usage: clearLog' if ( @args != 0 );
Write( $hash, 'factoryReset', undef, undef, undef )
if ( !IsDisabled($name) );
$endpoint = 'factoryReset';
}
elsif ( lc($cmd) eq 'callbackremove' ) {
return 'usage: callbackRemove' if ( @args > 1 );
my $id = ( @args > 0 ? join( ' ', @args ) : 0 );
Write( $hash, 'callback/remove', $id, undef, undef )
# Write( $hash, 'callback/remove', $id, undef, undef )
Write( $hash, 'callback/remove', '{"param":"' . $id . '}' )
if ( !IsDisabled($name) );
return undef;
}
else {
my $list = '';
@@ -500,22 +495,26 @@ sub Set($@) {
if ( ReadingsVal( $name, 'bridgeType', 'Software' ) eq 'Hardware' );
return ( 'Unknown argument ' . $cmd . ', choose one of ' . $list );
}
Write( $hash, $endpoint, undef )
if ( !IsDisabled($name) );
}
sub Get($@) {
my ( $hash, $name, $cmd, @args ) = @_;
my ( $arg, @params ) = @args;
my $endpoint;
if ( lc($cmd) eq 'logfile' ) {
return 'usage: logFile' if ( @args != 0 );
Write( $hash, 'log', undef, undef, undef );
$endpoint = 'log';
}
elsif ( lc($cmd) eq 'callbacklist' ) {
return 'usage: callbackList' if ( @args != 0 );
Write( $hash, 'callback/list', undef, undef, undef );
$endpoint = 'callback/list';
}
else {
my $list = '';
@@ -525,6 +524,8 @@ sub Get($@) {
return 'Unknown argument ' . $cmd . ', choose one of ' . $list;
}
Write( $hash, $endpoint, undef )
}
sub GetCheckBridgeAlive($) {
@@ -539,7 +540,7 @@ sub GetCheckBridgeAlive($) {
and $hash->{helper}->{iowrite} == 0 )
{
Write( $hash, 'info', undef, undef, undef );
Write( $hash, 'info', undef);
Log3( $name, 4, "NUKIBridge ($name) - run Write" );
}
@@ -557,7 +558,7 @@ sub FirstRun($) {
my $name = $hash->{NAME};
RemoveInternalTimer($hash);
Write( $hash, 'list', undef, undef, undef )
Write( $hash, 'list', undef )
if ( !IsDisabled($name) );
InternalTimer( gettimeofday() + 5,
'NUKIBridge_GetCheckBridgeAlive', $hash );
@@ -566,7 +567,14 @@ sub FirstRun($) {
}
sub Write($@) {
my ( $hash, $endpoint, $param, $nukiId, $deviceType ) = @_;
my ( $hash, $endpoint, $json ) = @_;
my $decode_json = eval { decode_json($json) }
if ( defined($json) );
my $nukiId = $decode_json->{nukiId} // undef;
my $deviceType = $decode_json->{deviceType} // undef;
my $param = $decode_json->{param} // undef;
my $obj = {
endpoint => $endpoint,
@@ -1354,7 +1362,7 @@ sub ParseJSON($$) {
],
"release_status": "stable",
"license": "GPL_2",
"version": "v1.9.16",
"version": "v1.9.17",
"x_apiversion": "1.9",
"author": [
"Marko Oldenburg <leongaultier@gmail.com>"

32
74_NUKIDevice.pm
View File

@@ -2,7 +2,7 @@
#
# Developed with Kate
#
# (c) 2016-2020 Copyright: Marko Oldenburg (leongaultier at gmail dot com)
# (c) 2016-2021 Copyright: Marko Oldenburg (fhemdevelopment at cooltux dot net)
# All rights reserved
#
# This script is free software; you can redistribute it and/or modify
@@ -421,8 +421,11 @@ sub Set($$@) {
$hash->{helper}{lockAction} = $lockAction;
IOWrite( $hash, 'lockAction', $lockAction, $hash->{NUKIID},
$hash->{DEVICETYPE} );
# IOWrite( $hash, 'lockAction', $lockAction, $hash->{NUKIID},
# $hash->{DEVICETYPE} );
IOWrite( $hash, 'lockAction', '{"param":"' . $lockAction
. '","nukiId":' . $hash->{NUKIID} . ',"deviceType":' . $hash->{DEVICETYPE} . '}' );
return undef;
}
@@ -433,8 +436,12 @@ sub GetUpdate($) {
my $name = $hash->{NAME};
if ( !IsDisabled($name) ) {
IOWrite( $hash, 'lockState', undef, $hash->{NUKIID},
$hash->{DEVICETYPE} );
# IOWrite( $hash, 'lockState', undef, $hash->{NUKIID},
# $hash->{DEVICETYPE} );
IOWrite( $hash, 'lockState', '{"nukiId":' . $hash->{NUKIID}
. ',"deviceType":' . $hash->{DEVICETYPE} . '}' );
Log3( $name, 2, "NUKIDevice ($name) - GetUpdate Call IOWrite" );
}
@@ -497,7 +504,7 @@ sub Parse($$) {
return $hash->{NAME};
}
else {
Log3( $name, 3,
Log3( $name, 4,
"NUKIDevice ($name) - autocreate new device "
. makeDeviceName( $decode_json->{name} )
. " with nukiId $decode_json->{nukiId}, model $decode_json->{deviceType}"
@@ -531,7 +538,10 @@ sub WriteReadings($$) {
)
{
$state = $hash->{helper}{lockAction};
IOWrite( $hash, 'lockState', undef, $hash->{NUKIID} )
# IOWrite( $hash, 'lockState', undef, $hash->{NUKIID} )
IOWrite( $hash, 'lockState', '{"nukiId":' . $hash->{NUKIID}
. ',"deviceType":' . $hash->{DEVICETYPE} . '}' )
if (
ReadingsVal( $hash->{IODev}->{NAME}, 'bridgeType', 'Software' )
eq 'Software' );
@@ -545,8 +555,10 @@ sub WriteReadings($$) {
{
$state = $deviceTypes{ $hash->{DEVICETYPE} } . ' response error';
IOWrite( $hash, 'lockState', undef, $hash->{NUKIID},
$hash->{DEVICETYPE} );
# IOWrite( $hash, 'lockState', undef, $hash->{NUKIID},
# $hash->{DEVICETYPE} );
IOWrite( $hash, 'lockState', '{"nukiId":' . $hash->{NUKIID}
. ',"deviceType":' . $hash->{DEVICETYPE} . '}' );
}
$decode_json->{'state'} = $state;
@@ -744,7 +756,7 @@ sub WriteReadings($$) {
],
"release_status": "stable",
"license": "GPL_2",
"version": "v1.9.11",
"version": "v1.9.17",
"author": [
"Marko Oldenburg <leongaultier@gmail.com>"
],