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

Version 2.0 Pre-Release #20

Merged
marko merged 29 commits from devel into main 2021-12-05 11:25:38 +00:00
Conversation 0 Commits 29 Files Changed 12 +143 -129
4 changed files with 143 additions and 129 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit e634cf4437 - Show all commits

3
FHEM/73_NUKIBridge.pm
View File

@ -64,8 +64,7 @@ sub Initialize {
$hash->{NotifyFn} = \&FHEM::Devices::Nuki::Bridge::Notify;
$hash->{AttrFn} = \&FHEM::Devices::Nuki::Bridge::Attr;
$hash->{AttrList} =
'disable:1 '
. 'port '
'disable:1 ' . 'port '
. 'webhookFWinstance:'
. $webhookFWinstance . ' '
. 'webhookHttpHostname '

8
controls_NukiSmart.txt
View File

@ -1,4 +1,4 @@
UPD 2021-11-27_18:02:39 9224 FHEM/73_NUKIBridge.pm
UPD 2021-11-27_18:01:59 7548 FHEM/74_NUKIDevice.pm
UPD 2021-11-27_18:08:11 40444 lib/FHEM/Devices/Nuki/Bridge.pm
UPD 2021-11-27_15:28:59 15728 lib/FHEM/Devices/Nuki/Device.pm
UPD 2021-11-27_18:39:55 9217 FHEM/73_NUKIBridge.pm
UPD 2021-11-27_18:40:10 7548 FHEM/74_NUKIDevice.pm
UPD 2021-11-27_18:39:14 40112 lib/FHEM/Devices/Nuki/Bridge.pm
UPD 2021-11-27_18:44:10 16135 lib/FHEM/Devices/Nuki/Device.pm

97
lib/FHEM/Devices/Nuki/Bridge.pm
View File

@ -145,11 +145,12 @@ sub Define {
use version 0.60; our $VERSION = FHEM::Meta::Get( $hash, 'version' );
my ( $name, undef, $host, $token ) = split( m{\s+}xms, $def );
# return ('too few parameters: define <name> NUKIBridge <HOST> <TOKEN>')
# if ( !defined($host)
# || !defined($token) );
my $port = ::AttrVal($name, 'port', 8080);
# return ('too few parameters: define <name> NUKIBridge <HOST> <TOKEN>')
# if ( !defined($host)
# || !defined($token) );
my $port = ::AttrVal( $name, 'port', 8080 );
my $infix = 'NUKIBridge';
$hash->{HOST} = $host // 'discover';
$hash->{PORT} = $port;
@ -165,11 +166,11 @@ sub Define {
$hash->{WEBHOOK_REGISTER} = "unregistered";
::readingsSingleUpdate($hash, 'state', 'Initialized', 1);
::readingsSingleUpdate( $hash, 'state', 'Initialized', 1 );
::RemoveInternalTimer($hash);
return BridgeDiscover($hash,'discover')
return BridgeDiscover( $hash, 'discover' )
if ( $hash->{HOST} eq 'discover'
&& $hash->{TOKEN} eq 'discover' );
@ -220,11 +221,11 @@ sub Attr {
if ( $attrName eq 'disable' ) {
if ( $cmd eq 'set' && $attrVal == 1 ) {
::readingsSingleUpdate($hash, 'state', 'disabled', 1);
::readingsSingleUpdate( $hash, 'state', 'disabled', 1 );
::Log3( $name, 3, "NUKIBridge ($name) - disabled" );
}
elsif ( $cmd eq 'del' ) {
::readingsSingleUpdate($hash, 'state', 'active', 1);
::readingsSingleUpdate( $hash, 'state', 'active', 1 );
::Log3( $name, 3, "NUKIBridge ($name) - enabled" );
}
}
@ -236,7 +237,8 @@ sub Attr {
}
elsif ( $cmd eq 'del' ) {
$hash->{PORT} = 8080;
::Log3( $name, 3, "NUKIBridge ($name) - set bridge port to default" );
::Log3( $name, 3,
"NUKIBridge ($name) - set bridge port to default" );
}
}
@ -244,10 +246,10 @@ sub Attr {
if ( $cmd eq 'set' ) {
::Log3( $name, 3,
"NUKIBridge ($name) - enable disabledForIntervals" );
::readingsSingleUpdate($hash, 'state', 'Unknown', 1);
::readingsSingleUpdate( $hash, 'state', 'Unknown', 1 );
}
elsif ( $cmd eq 'del' ) {
::readingsSingleUpdate($hash, 'state', 'active', 1);
::readingsSingleUpdate( $hash, 'state', 'active', 1 );
::Log3( $name, 3,
"NUKIBridge ($name) - delete disabledForIntervals" );
}
@ -395,9 +397,7 @@ sub removeExtension {
::Log3( $name, 2,
"NUKIBridge ($name) - Unregistering NUKIBridge for webhook URL $url..."
)
if ( defined($name) );
) if ( defined($name) );
delete $::data{FWEXT}{$url};
@ -656,7 +656,8 @@ sub Distribution {
my $json = shift;
my $hash = $param->{hash};
# my $doTrigger = $param->{doTrigger};
# my $doTrigger = $param->{doTrigger};
my $name = $hash->{NAME};
my $host = $hash->{HOST};
@ -779,7 +780,7 @@ sub Distribution {
::readingsEndUpdate( $hash, 1 );
::readingsSingleUpdate($hash, 'state', 'connected', 1);
::readingsSingleUpdate( $hash, 'state', 'connected', 1 );
::Log3( $name, 5, "NUKIBridge ($name) - Bridge ist online" );
if ( $param->{endpoint} eq 'callback/list' ) {
@ -1110,9 +1111,9 @@ sub getCallbackList {
if ( scalar( @{ $decode_json->{callbacks} } ) > 0 ) {
for my $cb ( @{ $decode_json->{callbacks} } ) {
$aHref =
"<a href=\""
# . $::FW_httpheader->{host}
$aHref = "<a href=\""
# . $::FW_httpheader->{host}
. "/fhem?cmd=set+"
. $name
. "+callbackRemove+"
@ -1276,28 +1277,30 @@ sub BridgeDiscover {
my $endpoint = shift;
my $bridge = shift;
my $name = $hash->{NAME};
my $url = ( $endpoint eq 'discover' && !defined($bridge)
my $url = (
$endpoint eq 'discover' && !defined($bridge)
? 'https://api.nuki.io/discover/bridges'
: 'http://' . $bridge->{'ip'} . ':' . $bridge->{'port'} . '/auth' );
my $timeout = ( $endpoint eq 'discover' && !defined($bridge)
: 'http://' . $bridge->{'ip'} . ':' . $bridge->{'port'} . '/auth'
);
my $timeout = (
$endpoint eq 'discover' && !defined($bridge)
? 5
: 35 );
: 35
);
if ( $endpoint eq 'discover' ) {
::Log3( $name, 3,
"NUKIBridge ($name) - Bridge device defined. run discover mode"
);
"NUKIBridge ($name) - Bridge device defined. run discover mode" );
::readingsSingleUpdate($hash, 'state', 'run discovery', 1);
::readingsSingleUpdate( $hash, 'state', 'run discovery', 1 );
}
elsif ( $endpoint eq 'getApiToken' ) {
::Log3( $name, 3,
"NUKIBridge ($name) - Enables the api (if not yet enabled) and get the api token."
"NUKIBridge ($name) - Enables the api (if not yet enabled) and get the api token."
);
}
::HttpUtils_NonblockingGet(
{
url => $url,
@ -1316,8 +1319,7 @@ sub BridgeDiscover {
"NUKIBridge ($name) - Send Discover request to Nuki Cloud" )
if ( $endpoint eq 'discover' );
::Log3( $name, 3,
"NUKIBridge ($name) - get API Token from the Bridge" )
::Log3( $name, 3, "NUKIBridge ($name) - get API Token from the Bridge" )
if ( $endpoint eq 'getApiToken' );
return;
@ -1331,18 +1333,17 @@ sub BridgeDiscoverRequest {
my $hash = $param->{hash};
my $name = $hash->{NAME};
if ( defined($err)
&& $err ne '' )
{
return ::Log3( $name, 3,
"NUKIBridge ($name) - Error: $err");
return ::Log3( $name, 3, "NUKIBridge ($name) - Error: $err" );
}
elsif ( exists( $param->{code})
elsif ( exists( $param->{code} )
&& $param->{code} != 200 )
{
return ::Log3( $name, 3,
"NUKIBridge ($name) - HTTP error Code present. Code: $param->{code}");
"NUKIBridge ($name) - HTTP error Code present. Code: $param->{code}"
);
}
my $decode_json;
@ -1354,22 +1355,25 @@ sub BridgeDiscoverRequest {
if ( $param->{endpoint} eq 'discover' ) {
return ::readingsSingleUpdate($hash, 'state', 'no bridges discovered', 1)
if ( scalar(@{$decode_json->{bridges}}) == 0
return ::readingsSingleUpdate( $hash, 'state', 'no bridges discovered',
1 )
if ( scalar( @{ $decode_json->{bridges} } ) == 0
&& $decode_json->{errorCode} == 0 );
return BridgeDiscover_getAPIToken($hash,$decode_json);
return BridgeDiscover_getAPIToken( $hash, $decode_json );
}
elsif ( $param->{endpoint} eq 'getApiToken' ) {
::readingsSingleUpdate($hash, 'state', 'modefined bridge device in progress', 1);
::readingsSingleUpdate( $hash, 'state',
'modefined bridge device in progress', 1 );
$decode_json->{host} = $param->{host};
$decode_json->{port} = $param->{port};
return ModefinedBridgeDevices($hash,$decode_json)
return ModefinedBridgeDevices( $hash, $decode_json )
if ( $decode_json->{success} == 1 );
return ::readingsSingleUpdate($hash, 'state', 'get api token failed', 1);
return ::readingsSingleUpdate( $hash, 'state', 'get api token failed',
1 );
}
return;
@ -1380,14 +1384,15 @@ sub BridgeDiscover_getAPIToken {
my $decode_json = shift;
my $name = $hash->{NAME};
my $pullApiKeyMessage = 'When issuing this API-call the bridge turns on its LED for 30 seconds.
my $pullApiKeyMessage =
'When issuing this API-call the bridge turns on its LED for 30 seconds.
The button of the bridge has to be pressed within this timeframe. Otherwise the bridge returns a negative success and no token.';
::readingsSingleUpdate($hash, 'state', $pullApiKeyMessage, 1);
::readingsSingleUpdate( $hash, 'state', $pullApiKeyMessage, 1 );
for ( @{$decode_json->{bridges}} ) {
for ( @{ $decode_json->{bridges} } ) {
BridgeDiscover($hash,'getApiToken',$_);
BridgeDiscover( $hash, 'getApiToken', $_ );
}
return;
@ -1398,7 +1403,6 @@ sub ModefinedBridgeDevices {
my $decode_json = shift;
my $name = $hash->{NAME};
::CommandAttr( undef, $name . ' port ' . $decode_json->{port} )
if ( $decode_json->{port} != 8080 );
::CommandDefMod( undef,
@ -1410,5 +1414,4 @@ sub ModefinedBridgeDevices {
return;
}
1;

46
lib/FHEM/Devices/Nuki/Device.pm
View File

@ -451,19 +451,18 @@ sub Parse {
##################
## Zwischenlösung so für die Umstellung, kann später gelöscht werden
# if ( ::AttrVal( $name, 'model', '' ) eq '' ) {
# ::CommandDefMod( undef,
# $name
# . ' NUKIDevice '
# . $hash->{NUKIID} . ' '
# . $decode_json->{deviceType} );
# ::CommandAttr( undef,
# $name
# . ' model '
# . $deviceTypes{ $decode_json->{deviceType} } );
# ::Log3( $name, 2, "NUKIDevice ($name) - redefined Defmod" );
# }
# if ( ::AttrVal( $name, 'model', '' ) eq '' ) {
# ::CommandDefMod( undef,
# $name
# . ' NUKIDevice '
# . $hash->{NUKIID} . ' '
# . $decode_json->{deviceType} );
# ::CommandAttr( undef,
# $name
# . ' model '
# . $deviceTypes{ $decode_json->{deviceType} } );
# ::Log3( $name, 2, "NUKIDevice ($name) - redefined Defmod" );
# }
}
else {
@ -557,11 +556,18 @@ sub WriteReadings {
&& $t ne 'deviceType'
&& $t ne 'paired'
&& $t ne 'batteryCritical'
&& $t ne 'batteryChargeState'
&& $t ne 'batteryCharging'
&& $t ne 'timestamp' );
::readingsBulkUpdate( $hash, $t,
( $v =~ m/^[0-9]$/ ? $lockStates{$v}{ $hash->{DEVICETYPEID} } : $v ) )
if ( $t eq 'state' );
::readingsBulkUpdate(
$hash, $t,
(
$v =~ m/^[0-9]$/
? $lockStates{$v}{ $hash->{DEVICETYPEID} }
: $v
)
) if ( $t eq 'state' );
::readingsBulkUpdate( $hash, $t, $modes{$v}{ $hash->{DEVICETYPEID} } )
if ( $t eq 'mode' );
@ -572,9 +578,15 @@ sub WriteReadings {
::readingsBulkUpdate( $hash, $t, ( $v == 1 ? 'true' : 'false' ) )
if ( $t eq 'paired' );
::readingsBulkUpdate( $hash, $t, ( $v == 1 ? 'true' : 'false' ) )
if ( $t eq 'batteryCharging' );
::readingsBulkUpdate( $hash, 'batteryState',
( ( $v eq 'true' or $v == 1 ) ? 'low' : 'ok' ) )
( $v == 1 ? 'low' : 'ok' ) )
if ( $t eq 'batteryCritical' );
::readingsBulkUpdate( $hash, 'batteryPercent', $v )
if ( $t eq 'batteryChargeState' );
}
::readingsEndUpdate( $hash, 1 );