From 2147564a5dbfa937bea70d377bc4afdd377a0747 Mon Sep 17 00:00:00 2001 From: Marko Oldenburg Date: Thu, 11 Nov 2021 17:56:22 +0100 Subject: [PATCH 1/2] IOWrite Call rewrite for FHEM2FHEM support --- 73_NUKIBridge.pm | 58 +++++++++++++++++++++++++++--------------------- 74_NUKIDevice.pm | 32 +++++++++++++++++--------- 2 files changed, 55 insertions(+), 35 deletions(-) diff --git a/73_NUKIBridge.pm b/73_NUKIBridge.pm index cb3c1dc..6f7e1d7 100755 --- a/73_NUKIBridge.pm +++ b/73_NUKIBridge.pm @@ -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 " diff --git a/74_NUKIDevice.pm b/74_NUKIDevice.pm index 378274b..50678b2 100755 --- a/74_NUKIDevice.pm +++ b/74_NUKIDevice.pm @@ -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 " ], From 12944c4ae9e145a10c35c8d7517f7870f179c2a7 Mon Sep 17 00:00:00 2001 From: Marko Oldenburg Date: Mon, 22 Nov 2021 12:19:36 +0100 Subject: [PATCH 2/2] change getCallback List Fn --- 73_NUKIBridge.pm | 81 ++++++++++++++++++++++++++++++++++++++++++++---- 1 file changed, 75 insertions(+), 6 deletions(-) diff --git a/73_NUKIBridge.pm b/73_NUKIBridge.pm index 6f7e1d7..5e61f3d 100755 --- a/73_NUKIBridge.pm +++ b/73_NUKIBridge.pm @@ -371,7 +371,7 @@ sub Attr(@) { Log3( $name, 3, "NUKIBridge ($name) - URL ist: $url" ); # Write( $hash, 'callback/add', $url, undef, undef ) - Write( $hash, 'callback/add', '{"param":"' . $url . '}' ) + Write( $hash, 'callback/add', '{"param":"' . $url . '"}' ) if ($init_done); $hash->{WEBHOOK_REGISTER} = 'sent'; } @@ -483,7 +483,7 @@ sub Set($@) { my $id = ( @args > 0 ? join( ' ', @args ) : 0 ); # Write( $hash, 'callback/remove', $id, undef, undef ) - Write( $hash, 'callback/remove', '{"param":"' . $id . '}' ) + Write( $hash, 'callback/remove', '{"param":"' . $id . '"}' ) if ( !IsDisabled($name) ); return undef; @@ -918,7 +918,7 @@ sub ResponseProcessing($$$) { } } - InfoProcessing( $hash, $decode_json ) + WriteReadings( $hash, $decode_json ) if ( $endpoint eq 'info' ); } else { @@ -987,7 +987,7 @@ matching NukiId at device $name" return ( 'text/plain; charset=utf-8', 'Call failure: ' . $request ); } -sub InfoProcessing($$) { +sub WriteReadings($$) { my ( $hash, $decode_json ) = @_; my $name = $hash->{NAME}; @@ -1010,7 +1010,7 @@ sub InfoProcessing($$) { readingsBulkUpdate( $hash, 'hardwareId', $decode_json->{ids}{hardwareId} ); readingsBulkUpdate( $hash, 'serverId', $decode_json->{ids}{serverId} ); readingsBulkUpdate( $hash, 'uptime', $decode_json->{uptime} ); - readingsBulkUpdate( $hash, 'currentTime', $decode_json->{currentTime} ); + readingsBulkUpdate( $hash, 'currentGMTime', $decode_json->{currentTime} ); readingsBulkUpdate( $hash, 'serverConnected', $decode_json->{serverConnected} ); readingsEndUpdate( $hash, 1 ); @@ -1099,6 +1099,72 @@ sub getCallbackList($$) { Log3( $name, 4, "NUKIBridge ($name) - created Table with log file" ); + my $space = ' '; + my $aHref; + my $header = '' + . '
Callback List
'; + + my $ret = $header.''; + $ret .= '
'; + $ret .= ''; + $ret .= ''; + $ret .= ''; + $ret .= ''; + $ret .= ''; + + if ( scalar( @{ $decode_json->{callbacks} } ) > 0 ) { + foreach my $cb ( @{ $decode_json->{callbacks} } ) { + $aHref = + "{host} + . "/fhem?cmd=set+" + . $name + . "+callbackRemove+" + . $cb->{id} + . $::FW_CSRF + . "\">X"; + + $ret .= ''; + $ret .= ''; + $ret .= ''; + } + } + else { + $ret .= ''; + $ret .= ''; + $ret .= ''; + $ret .= ''; + } + + $ret .= '
URLRemove
' . $cb->{url} . ''.$aHref.'
nonenone
'; + + asyncOutput( $param->{cl}, $ret ) + if ( $param->{cl} and $param->{cl}{canAsyncOutput} ); + return; + } + } +} + +sub getCallbackList2($$) { + my ( $param, $json ) = @_; + + my $hash = $param->{hash}; + my $name = $hash->{NAME}; + + my $decode_json = eval { decode_json($json) }; + if ($@) { + Log3( $name, 3, "NUKIBridge ($name) - JSON error while request: $@" ); + return; + } + + Log3( $name, 4, + "NUKIBridge ($name) - Callback data are collected and processed" ); + + if ( $param->{cl} and $param->{cl}->{TYPE} eq 'FHEMWEB' ) { + if ( ref( $decode_json->{callbacks} ) eq 'ARRAY' ) { + Log3( $name, 4, + "NUKIBridge ($name) - created Table with Callback List" ); + my $j1 = '