Compare commits
71 Commits
Author | SHA1 | Date | |
---|---|---|---|
1498f73b10 | |||
8ae1510a71 | |||
b211fe2b56 | |||
85c7b3fa0a | |||
65df7eb47b | |||
13e7e24911 | |||
b61458a45e | |||
673445e339 | |||
157e9fc58c | |||
f3f2688292 | |||
5d245d5a3d | |||
ddbe145179 | |||
bd06f26248 | |||
8e470ccbb6 | |||
7c01c1c790 | |||
7b30b50cf1 | |||
32eec48ce6 | |||
5545ac1370 | |||
d186f3e6c8 | |||
eec264b014 | |||
ef1aabfcb0 | |||
c3882d4af3 | |||
43b4c15a9d | |||
908fe4fc24 | |||
b423fc73fc | |||
9abd0a9173 | |||
2af38efe42 | |||
8ddb1a8233 | |||
23be875b9f | |||
5294e3fea5 | |||
12c4a0d5ba | |||
a856bb574a | |||
4e52ea8215 | |||
70c54892d8 | |||
b49d7f643b | |||
cf93bbdba6 | |||
9d3ddb088b | |||
48e526a627 | |||
113dec6551 | |||
71ef5799c2 | |||
49ef217d12 | |||
65f031e1c2 | |||
10718f1355 | |||
b0638c525e | |||
0adf1d8a3b | |||
a0d8125d32 | |||
b6866dd44a | |||
6f0aee2a69 | |||
acb482e37f | |||
0ec53ea1b3 | |||
08bb518e9a | |||
33eb0ed012 | |||
70af6fd6a3 | |||
44a251f7f7 | |||
0aa3e543a8 | |||
97b8a6edab | |||
a7d374596d | |||
cf0772f6ae | |||
fe23d695e4 | |||
9a6241b608 | |||
065eebb858 | |||
1f3465a12d | |||
e3674c401d | |||
1dde30c52c | |||
5fb14e80a8 | |||
c9f212a641 | |||
9e20c40b37 | |||
e9d37309b4 | |||
613e14b4f9 | |||
6e5f2d98b3 | |||
249f996db7 |
@ -1,8 +1,8 @@
|
|||||||
###############################################################################
|
###############################################################################
|
||||||
#
|
#
|
||||||
# Developed with Kate
|
# Developed with VSCodium and richterger perl plugin.
|
||||||
#
|
#
|
||||||
# (c) 2017-2021 Copyright: Marko Oldenburg (fhemdevelopment at cooltux dot net)
|
# (c) 2017-2022 Copyright: Marko Oldenburg (fhemdevelopment at cooltux dot net)
|
||||||
# All rights reserved
|
# All rights reserved
|
||||||
#
|
#
|
||||||
# Special thanks goes to comitters:
|
# Special thanks goes to comitters:
|
||||||
@ -57,7 +57,6 @@
|
|||||||
package FHEM::GardenaSmartBridge;
|
package FHEM::GardenaSmartBridge;
|
||||||
use GPUtils qw(GP_Import GP_Export);
|
use GPUtils qw(GP_Import GP_Export);
|
||||||
|
|
||||||
|
|
||||||
use strict;
|
use strict;
|
||||||
use warnings;
|
use warnings;
|
||||||
use POSIX;
|
use POSIX;
|
||||||
@ -66,11 +65,12 @@ use FHEM::Meta;
|
|||||||
use HttpUtils;
|
use HttpUtils;
|
||||||
|
|
||||||
my $missingModul = '';
|
my $missingModul = '';
|
||||||
eval "use Encode qw(encode encode_utf8 decode_utf8);1"
|
eval { use Encode qw /encode_utf8 decode_utf8/; 1 }
|
||||||
or $missingModul .= "Encode ";
|
or $missingModul .= "Encode ";
|
||||||
|
|
||||||
# eval "use JSON;1" || $missingModul .= 'JSON ';
|
# eval "use JSON;1" || $missingModul .= 'JSON ';
|
||||||
eval "use IO::Socket::SSL;1" or $missingModul .= 'IO::Socket::SSL ';
|
eval { use IO::Socket::SSL; 1 }
|
||||||
|
or $missingModul .= 'IO::Socket::SSL ';
|
||||||
|
|
||||||
# try to use JSON::MaybeXS wrapper
|
# try to use JSON::MaybeXS wrapper
|
||||||
# for chance of better performance + open code
|
# for chance of better performance + open code
|
||||||
@ -78,15 +78,11 @@ eval {
|
|||||||
require JSON::MaybeXS;
|
require JSON::MaybeXS;
|
||||||
import JSON::MaybeXS qw( decode_json encode_json );
|
import JSON::MaybeXS qw( decode_json encode_json );
|
||||||
1;
|
1;
|
||||||
};
|
} or do {
|
||||||
|
|
||||||
if ($@) {
|
|
||||||
$@ = undef;
|
|
||||||
|
|
||||||
# try to use JSON wrapper
|
# try to use JSON wrapper
|
||||||
# for chance of better performance
|
# for chance of better performance
|
||||||
eval {
|
eval {
|
||||||
|
|
||||||
# JSON preference order
|
# JSON preference order
|
||||||
local $ENV{PERL_JSON_BACKEND} =
|
local $ENV{PERL_JSON_BACKEND} =
|
||||||
'Cpanel::JSON::XS,JSON::XS,JSON::PP,JSON::backportPP'
|
'Cpanel::JSON::XS,JSON::XS,JSON::PP,JSON::backportPP'
|
||||||
@ -95,10 +91,7 @@ if ($@) {
|
|||||||
require JSON;
|
require JSON;
|
||||||
import JSON qw( decode_json encode_json );
|
import JSON qw( decode_json encode_json );
|
||||||
1;
|
1;
|
||||||
};
|
} or do {
|
||||||
|
|
||||||
if ($@) {
|
|
||||||
$@ = undef;
|
|
||||||
|
|
||||||
# In rare cases, Cpanel::JSON::XS may
|
# In rare cases, Cpanel::JSON::XS may
|
||||||
# be installed but JSON|JSON::MaybeXS not ...
|
# be installed but JSON|JSON::MaybeXS not ...
|
||||||
@ -106,10 +99,7 @@ if ($@) {
|
|||||||
require Cpanel::JSON::XS;
|
require Cpanel::JSON::XS;
|
||||||
import Cpanel::JSON::XS qw(decode_json encode_json);
|
import Cpanel::JSON::XS qw(decode_json encode_json);
|
||||||
1;
|
1;
|
||||||
};
|
} or do {
|
||||||
|
|
||||||
if ($@) {
|
|
||||||
$@ = undef;
|
|
||||||
|
|
||||||
# In rare cases, JSON::XS may
|
# In rare cases, JSON::XS may
|
||||||
# be installed but JSON not ...
|
# be installed but JSON not ...
|
||||||
@ -117,10 +107,7 @@ if ($@) {
|
|||||||
require JSON::XS;
|
require JSON::XS;
|
||||||
import JSON::XS qw(decode_json encode_json);
|
import JSON::XS qw(decode_json encode_json);
|
||||||
1;
|
1;
|
||||||
};
|
} or do {
|
||||||
|
|
||||||
if ($@) {
|
|
||||||
$@ = undef;
|
|
||||||
|
|
||||||
# Fallback to built-in JSON which SHOULD
|
# Fallback to built-in JSON which SHOULD
|
||||||
# be available since 5.014 ...
|
# be available since 5.014 ...
|
||||||
@ -128,20 +115,17 @@ if ($@) {
|
|||||||
require JSON::PP;
|
require JSON::PP;
|
||||||
import JSON::PP qw(decode_json encode_json);
|
import JSON::PP qw(decode_json encode_json);
|
||||||
1;
|
1;
|
||||||
};
|
} or do {
|
||||||
|
|
||||||
if ($@) {
|
|
||||||
$@ = undef;
|
|
||||||
|
|
||||||
# Fallback to JSON::backportPP in really rare cases
|
# Fallback to JSON::backportPP in really rare cases
|
||||||
require JSON::backportPP;
|
require JSON::backportPP;
|
||||||
import JSON::backportPP qw(decode_json encode_json);
|
import JSON::backportPP qw(decode_json encode_json);
|
||||||
1;
|
1;
|
||||||
}
|
};
|
||||||
}
|
};
|
||||||
}
|
};
|
||||||
}
|
};
|
||||||
}
|
};
|
||||||
|
|
||||||
## Import der FHEM Funktionen
|
## Import der FHEM Funktionen
|
||||||
#-- Run before package compilation
|
#-- Run before package compilation
|
||||||
@ -205,6 +189,7 @@ sub Initialize {
|
|||||||
$hash->{AttrFn} = \&Attr;
|
$hash->{AttrFn} = \&Attr;
|
||||||
$hash->{AttrList} =
|
$hash->{AttrList} =
|
||||||
'debugJSON:0,1 '
|
'debugJSON:0,1 '
|
||||||
|
. 'debugDEVICE:0,1 '
|
||||||
. 'disable:1 '
|
. 'disable:1 '
|
||||||
. 'interval '
|
. 'interval '
|
||||||
. 'disabledForIntervals '
|
. 'disabledForIntervals '
|
||||||
@ -234,9 +219,7 @@ sub Define {
|
|||||||
my $name = shift @$aArg;
|
my $name = shift @$aArg;
|
||||||
$hash->{BRIDGE} = 1;
|
$hash->{BRIDGE} = 1;
|
||||||
$hash->{URL} =
|
$hash->{URL} =
|
||||||
AttrVal( $name, 'gardenaBaseURL',
|
AttrVal( $name, 'gardenaBaseURL', 'https://smart.gardena.com' ) . '/v1';
|
||||||
'https://smart.gardena.com' )
|
|
||||||
. '/v1';
|
|
||||||
$hash->{VERSION} = version->parse($VERSION)->normal;
|
$hash->{VERSION} = version->parse($VERSION)->normal;
|
||||||
$hash->{INTERVAL} = 60;
|
$hash->{INTERVAL} = 60;
|
||||||
$hash->{NOTIFYDEV} = "global,$name";
|
$hash->{NOTIFYDEV} = "global,$name";
|
||||||
@ -258,7 +241,7 @@ sub Undef {
|
|||||||
my $hash = shift;
|
my $hash = shift;
|
||||||
my $name = shift;
|
my $name = shift;
|
||||||
|
|
||||||
RemoveInternalTimer($hash);
|
RemoveInternalTimer( $hash, "FHEM::GardenaSmartBridge::getDevices" );
|
||||||
delete $modules{GardenaSmartBridge}{defptr}{BRIDGE}
|
delete $modules{GardenaSmartBridge}{defptr}{BRIDGE}
|
||||||
if ( defined( $modules{GardenaSmartBridge}{defptr}{BRIDGE} ) );
|
if ( defined( $modules{GardenaSmartBridge}{defptr}{BRIDGE} ) );
|
||||||
|
|
||||||
@ -279,7 +262,8 @@ sub Attr {
|
|||||||
|
|
||||||
if ( $attrName eq 'disable' ) {
|
if ( $attrName eq 'disable' ) {
|
||||||
if ( $cmd eq 'set' && $attrVal eq '1' ) {
|
if ( $cmd eq 'set' && $attrVal eq '1' ) {
|
||||||
RemoveInternalTimer($hash);
|
RemoveInternalTimer( $hash,
|
||||||
|
"FHEM::GardenaSmartBridge::getDevices" );
|
||||||
readingsSingleUpdate( $hash, 'state', 'inactive', 1 );
|
readingsSingleUpdate( $hash, 'state', 'inactive', 1 );
|
||||||
Log3 $name, 3, "GardenaSmartBridge ($name) - disabled";
|
Log3 $name, 3, "GardenaSmartBridge ($name) - disabled";
|
||||||
}
|
}
|
||||||
@ -304,13 +288,15 @@ sub Attr {
|
|||||||
if ( $cmd eq 'set' ) {
|
if ( $cmd eq 'set' ) {
|
||||||
return 'Interval must be greater than 0'
|
return 'Interval must be greater than 0'
|
||||||
if ( $attrVal == 0 );
|
if ( $attrVal == 0 );
|
||||||
RemoveInternalTimer($hash);
|
RemoveInternalTimer( $hash,
|
||||||
|
"FHEM::GardenaSmartBridge::getDevices" );
|
||||||
$hash->{INTERVAL} = $attrVal;
|
$hash->{INTERVAL} = $attrVal;
|
||||||
Log3 $name, 3,
|
Log3 $name, 3,
|
||||||
"GardenaSmartBridge ($name) - set interval: $attrVal";
|
"GardenaSmartBridge ($name) - set interval: $attrVal";
|
||||||
}
|
}
|
||||||
elsif ( $cmd eq 'del' ) {
|
elsif ( $cmd eq 'del' ) {
|
||||||
RemoveInternalTimer($hash);
|
RemoveInternalTimer( $hash,
|
||||||
|
"FHEM::GardenaSmartBridge::getDevices" );
|
||||||
$hash->{INTERVAL} = 60;
|
$hash->{INTERVAL} = 60;
|
||||||
Log3 $name, 3,
|
Log3 $name, 3,
|
||||||
"GardenaSmartBridge ($name) - delete User interval and set default: 60";
|
"GardenaSmartBridge ($name) - delete User interval and set default: 60";
|
||||||
@ -352,25 +338,21 @@ sub Notify {
|
|||||||
@{$events} or grep /^DEFINED.$name$/,
|
@{$events} or grep /^DEFINED.$name$/,
|
||||||
@{$events} or grep /^MODIFIED.$name$/,
|
@{$events} or grep /^MODIFIED.$name$/,
|
||||||
@{$events} or grep /^ATTR.$name.gardenaAccountEmail.+/,
|
@{$events} or grep /^ATTR.$name.gardenaAccountEmail.+/,
|
||||||
|
@{$events} or grep /^DELETEATTR.$name.disable$/,
|
||||||
@{$events}
|
@{$events}
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
|
|
||||||
|| (
|
|| ( $devtype eq 'GardenaSmartBridge'
|
||||||
$devtype eq 'GardenaSmartBridge'
|
&& ( grep /^gardenaAccountPassword.+/, @{$events} ) )
|
||||||
&& (
|
&& $init_done
|
||||||
grep /^gardenaAccountPassword.+/,
|
|
||||||
@{$events}
|
|
||||||
)
|
|
||||||
)
|
|
||||||
);
|
);
|
||||||
|
|
||||||
getDevices($hash)
|
getDevices($hash)
|
||||||
if (
|
if (
|
||||||
$devtype eq 'Global'
|
$devtype eq 'Global'
|
||||||
&& (
|
&& (
|
||||||
grep /^DELETEATTR.$name.disable$/,
|
grep /^ATTR.$name.disable.0$/,
|
||||||
@{$events} or grep /^ATTR.$name.disable.0$/,
|
|
||||||
@{$events} or grep /^DELETEATTR.$name.interval$/,
|
@{$events} or grep /^DELETEATTR.$name.interval$/,
|
||||||
@{$events} or grep /^ATTR.$name.interval.[0-9]+/,
|
@{$events} or grep /^ATTR.$name.interval.[0-9]+/,
|
||||||
@{$events}
|
@{$events}
|
||||||
@ -387,7 +369,6 @@ sub Notify {
|
|||||||
)
|
)
|
||||||
)
|
)
|
||||||
{
|
{
|
||||||
|
|
||||||
InternalTimer( gettimeofday() + $hash->{INTERVAL},
|
InternalTimer( gettimeofday() + $hash->{INTERVAL},
|
||||||
"FHEM::GardenaSmartBridge::getDevices", $hash );
|
"FHEM::GardenaSmartBridge::getDevices", $hash );
|
||||||
Log3 $name, 4,
|
Log3 $name, 4,
|
||||||
@ -396,6 +377,7 @@ sub Notify {
|
|||||||
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
sub Get {
|
sub Get {
|
||||||
my $hash = shift // return;
|
my $hash = shift // return;
|
||||||
my $aArg = shift // return;
|
my $aArg = shift // return;
|
||||||
@ -408,12 +390,13 @@ sub Get {
|
|||||||
my $device = shift @$aArg;
|
my $device = shift @$aArg;
|
||||||
$hash->{helper}{debug_device} = $device;
|
$hash->{helper}{debug_device} = $device;
|
||||||
Write( $hash, undef, undef, undef, undef );
|
Write( $hash, undef, undef, undef, undef );
|
||||||
return undef;
|
return;
|
||||||
} else {
|
}
|
||||||
|
else {
|
||||||
my $list = "";
|
my $list = "";
|
||||||
$list .= " debug_devices_list:"
|
$list .=
|
||||||
.join( ',', @{ $hash->{helper}{deviceList} })
|
" debug_devices_list:" . join( ',', @{ $hash->{helper}{deviceList} } )
|
||||||
if ( AttrVal( $name, "debugJSON", "none") ne "none"
|
if ( AttrVal( $name, "debugDEVICE", "none" ) ne "none"
|
||||||
&& exists( $hash->{helper}{deviceList} ) );
|
&& exists( $hash->{helper}{deviceList} ) );
|
||||||
return "Unknown argument $cmd,choose one of $list";
|
return "Unknown argument $cmd,choose one of $list";
|
||||||
}
|
}
|
||||||
@ -424,7 +407,8 @@ sub Set {
|
|||||||
my $aArg = shift // return;
|
my $aArg = shift // return;
|
||||||
|
|
||||||
my $name = shift @$aArg // return;
|
my $name = shift @$aArg // return;
|
||||||
my $cmd = shift @$aArg // return qq{"set $name" needs at least one argument};
|
my $cmd = shift @$aArg
|
||||||
|
// return qq{"set $name" needs at least one argument};
|
||||||
|
|
||||||
# Das Argument für das Passwort, also das Passwort an sich darf keine = enthalten!!!
|
# Das Argument für das Passwort, also das Passwort an sich darf keine = enthalten!!!
|
||||||
|
|
||||||
@ -475,12 +459,14 @@ sub Write {
|
|||||||
my ( $session_id, $header, $uri, $method );
|
my ( $session_id, $header, $uri, $method );
|
||||||
|
|
||||||
( $payload, $session_id, $header, $uri, $method, $deviceId, $service_id ) =
|
( $payload, $session_id, $header, $uri, $method, $deviceId, $service_id ) =
|
||||||
createHttpValueStrings( $hash, $payload, $deviceId, $abilities, $service_id );
|
createHttpValueStrings( $hash, $payload, $deviceId, $abilities,
|
||||||
|
$service_id );
|
||||||
|
|
||||||
HttpUtils_NonblockingGet(
|
HttpUtils_NonblockingGet(
|
||||||
{
|
{
|
||||||
url => $hash->{URL} . $uri,
|
url => $hash->{URL} . $uri,
|
||||||
timeout => 15,
|
timeout => 15,
|
||||||
|
incrementalTimeout => 1,
|
||||||
hash => $hash,
|
hash => $hash,
|
||||||
device_id => $deviceId,
|
device_id => $deviceId,
|
||||||
data => $payload,
|
data => $payload,
|
||||||
@ -518,7 +504,7 @@ sub ErrorHandling {
|
|||||||
|
|
||||||
Log3 $name, 4, "GardenaSmartBridge ($name) - Request: $data";
|
Log3 $name, 4, "GardenaSmartBridge ($name) - Request: $data";
|
||||||
|
|
||||||
my $decode_json = eval { decode_json($data) };
|
my $decode_json = eval { decode_json($data) } if ( length($data) > 0 );
|
||||||
if ($@) {
|
if ($@) {
|
||||||
Log3 $name, 3, "GardenaSmartBridge ($name) - JSON error while request";
|
Log3 $name, 3, "GardenaSmartBridge ($name) - JSON error while request";
|
||||||
}
|
}
|
||||||
@ -698,6 +684,11 @@ sub ErrorHandling {
|
|||||||
. $param->{code};
|
. $param->{code};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if ( !defined( $hash->{helper}{session_id} ) ) {
|
||||||
|
readingsSingleUpdate( $hash, 'token', 'none', 1 );
|
||||||
|
InternalTimer( gettimeofday() + 5,
|
||||||
|
"FHEM::GardenaSmartBridge::getToken", $hash );
|
||||||
|
}
|
||||||
readingsEndUpdate( $dhash, 1 );
|
readingsEndUpdate( $dhash, 1 );
|
||||||
|
|
||||||
Log3 $dname, 5,
|
Log3 $dname, 5,
|
||||||
@ -710,14 +701,31 @@ sub ErrorHandling {
|
|||||||
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
if (defined($hash->{helper}{debug_device})){
|
elsif ( defined( $decode_json->{message} )
|
||||||
Log3 $name, 5, "GardenaSmartBridge DEBUG Device";
|
&& $decode_json->{message} eq 'Unauthorized' )
|
||||||
|
{
|
||||||
|
Log3 $name, 3,
|
||||||
|
"GardenaSmartBridge ($name) - Unauthorized -> fetch new token ";
|
||||||
|
|
||||||
|
getToken($hash);
|
||||||
|
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
if ( defined( $hash->{helper}{debug_device} )
|
||||||
|
&& $hash->{helper}{debug_device} ne 'none' )
|
||||||
|
{
|
||||||
|
Log3 $name, 4, "GardenaSmartBridge DEBUG Device";
|
||||||
|
delete $hash->{helper}{debug_device};
|
||||||
|
|
||||||
my @device_spec = ( "name", "id", "category" );
|
my @device_spec = ( "name", "id", "category" );
|
||||||
my $devJson = $decode_json->{devices};
|
my $devJson = $decode_json->{devices};
|
||||||
my $output = '.:{ DEBUG OUTPUT for ' . $devJson->{name} . ' }:. \n';
|
my $output = '.:{ DEBUG OUTPUT for ' . $devJson->{name} . ' }:. \n';
|
||||||
|
|
||||||
for my $spec (@device_spec) {
|
for my $spec (@device_spec) {
|
||||||
$output .= "$spec : $devJson->{$spec} \n";
|
$output .= "$spec : $devJson->{$spec} \n";
|
||||||
}
|
}
|
||||||
|
|
||||||
#settings
|
#settings
|
||||||
$output .= '\n=== Settings \n';
|
$output .= '\n=== Settings \n';
|
||||||
my $i = 0;
|
my $i = 0;
|
||||||
@ -725,14 +733,35 @@ sub ErrorHandling {
|
|||||||
$output .= "[" . $i++ . "]id: $dev_settings->{id} \n";
|
$output .= "[" . $i++ . "]id: $dev_settings->{id} \n";
|
||||||
$output .= "name: $dev_settings->{name} ";
|
$output .= "name: $dev_settings->{name} ";
|
||||||
if ( ref( $dev_settings->{value} ) eq 'ARRAY'
|
if ( ref( $dev_settings->{value} ) eq 'ARRAY'
|
||||||
|| ref ($dev_settings->{value}) eq 'HASH'){
|
|| ref( $dev_settings->{value} ) eq 'HASH' )
|
||||||
|
{
|
||||||
$output .= 'N/A \n';
|
$output .= 'N/A \n';
|
||||||
} else {
|
}
|
||||||
|
else {
|
||||||
$output .= "value: $dev_settings->{value} \n";
|
$output .= "value: $dev_settings->{value} \n";
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
$output .= '\n=== Abilities \n';
|
||||||
|
$i = 0;
|
||||||
|
|
||||||
|
for my $dev_settings ( @{ $devJson->{abilities} } ) {
|
||||||
|
$output .= "[" . $i++ . "]id: $dev_settings->{id} \n";
|
||||||
|
$output .= "name: $dev_settings->{name} ";
|
||||||
|
|
||||||
|
if ( ref( $dev_settings->{value} ) eq 'ARRAY'
|
||||||
|
|| ref( $dev_settings->{value} ) eq 'HASH' )
|
||||||
|
{
|
||||||
|
$output .= 'N/A \n';
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
$output .= "value: $dev_settings->{value} \n";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
$hash->{helper}{debug_device_output} = $output;
|
$hash->{helper}{debug_device_output} = $output;
|
||||||
asyncOutput( $param->{cl}, $hash->{helper}{debug_device_output} );
|
asyncOutput( $param->{cl}, $hash->{helper}{debug_device_output} );
|
||||||
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
readingsSingleUpdate( $hash, 'state', 'Connected', 1 )
|
readingsSingleUpdate( $hash, 'state', 'Connected', 1 )
|
||||||
@ -762,15 +791,21 @@ sub ResponseProcessing {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
# print Dumper $decode_json;
|
if ( defined( $decode_json->{data} )
|
||||||
|
&& $decode_json->{data}
|
||||||
if ( defined( $decode_json->{data} ) && $decode_json->{data}
|
|
||||||
&& ref( $decode_json->{data} ) eq 'HASH'
|
&& ref( $decode_json->{data} ) eq 'HASH'
|
||||||
&& !defined( $hash->{helper}->{user_id})) {
|
&& !defined( $hash->{helper}->{user_id} ) )
|
||||||
|
{
|
||||||
|
|
||||||
$hash->{helper}{session_id} = $decode_json->{data}{id};
|
$hash->{helper}{session_id} = $decode_json->{data}{id};
|
||||||
$hash->{helper}{user_id} = $decode_json->{data}{attributes}->{user_id};
|
$hash->{helper}{user_id} = $decode_json->{data}{attributes}->{user_id};
|
||||||
$hash->{helper}{refresh_token} = $decode_json->{data}{attributes}->{refresh_token};
|
$hash->{helper}{refresh_token} =
|
||||||
|
$decode_json->{data}{attributes}->{refresh_token};
|
||||||
|
$hash->{helper}{token_expired} =
|
||||||
|
gettimeofday() + $decode_json->{data}{attributes}->{expires_in};
|
||||||
|
|
||||||
|
InternalTimer( $hash->{helper}{token_expired},
|
||||||
|
"FHEM::GardenaSmartBridge::getToken", $hash );
|
||||||
|
|
||||||
Write( $hash, undef, undef, undef );
|
Write( $hash, undef, undef, undef );
|
||||||
Log3 $name, 3, "GardenaSmartBridge ($name) - fetch locations id";
|
Log3 $name, 3, "GardenaSmartBridge ($name) - fetch locations id";
|
||||||
@ -802,27 +837,63 @@ sub ResponseProcessing {
|
|||||||
&& ref( $decode_json->{devices} ) eq 'ARRAY'
|
&& ref( $decode_json->{devices} ) eq 'ARRAY'
|
||||||
&& scalar( @{ $decode_json->{devices} } ) > 0 )
|
&& scalar( @{ $decode_json->{devices} } ) > 0 )
|
||||||
{
|
{
|
||||||
|
|
||||||
my @buffer = split( '"devices":\[', $json );
|
my @buffer = split( '"devices":\[', $json );
|
||||||
|
|
||||||
my ( $json, $tail ) = ParseJSON( $hash, $buffer[1] );
|
require SubProcess;
|
||||||
|
|
||||||
while ($json) {
|
my $subprocess =
|
||||||
|
SubProcess->new( { onRun => \&ResponseSubprocessing } );
|
||||||
|
$subprocess->{buffer} = $buffer[1];
|
||||||
|
|
||||||
Log3 $name, 5,
|
my $pid = $subprocess->run();
|
||||||
"GardenaSmartBridge ($name) - Decoding JSON message. Length: "
|
|
||||||
. length($json)
|
|
||||||
. " Content: "
|
|
||||||
. $json;
|
|
||||||
Log3 $name, 5,
|
|
||||||
"GardenaSmartBridge ($name) - Vor Sub: Laenge JSON: "
|
|
||||||
. length($json)
|
|
||||||
. " Content: "
|
|
||||||
. $json
|
|
||||||
. " Tail: "
|
|
||||||
. $tail;
|
|
||||||
|
|
||||||
if ( defined($tail) and $tail ) {
|
if ( !defined($pid) ) {
|
||||||
|
Log3( $name, 1,
|
||||||
|
qq{GardenaSmartBridge ($name) - Cannot execute parse json asynchronously}
|
||||||
|
);
|
||||||
|
|
||||||
|
CleanSubprocess($hash);
|
||||||
|
readingsSingleUpdate( $hash, 'state',
|
||||||
|
'Cannot execute parse json asynchronously', 1 );
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
Log3( $name, 4,
|
||||||
|
qq{GardenaSmartBridge ($name) - execute parse json asynchronously (PID="$pid")}
|
||||||
|
);
|
||||||
|
|
||||||
|
$hash->{".fhem"}{subprocess} = $subprocess;
|
||||||
|
|
||||||
|
InternalTimer( gettimeofday() + 1,
|
||||||
|
"FHEM::GardenaSmartBridge::PollChild", $hash );
|
||||||
|
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
Log3 $name, 3, "GardenaSmartBridge ($name) - no Match for processing data";
|
||||||
|
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
sub ResponseProcessingFinalFromSubProcessing {
|
||||||
|
my $hash = shift;
|
||||||
|
my $response = shift;
|
||||||
|
|
||||||
|
my $name = $hash->{NAME};
|
||||||
|
|
||||||
|
my @response = split '\|,', $response;
|
||||||
|
|
||||||
|
Log3( $name, 4,
|
||||||
|
qq{GardenaSmartBridge ($name) - got result from asynchronous parsing} );
|
||||||
|
|
||||||
|
my $decode_json;
|
||||||
|
|
||||||
|
Log3( $name, 4, qq{GardenaSmartBridge ($name) - asynchronous finished.} );
|
||||||
|
|
||||||
|
if ( scalar(@response) > 0 ) {
|
||||||
|
for my $json (@response) {
|
||||||
|
|
||||||
|
#################
|
||||||
$decode_json = eval { decode_json($json) };
|
$decode_json = eval { decode_json($json) };
|
||||||
if ($@) {
|
if ($@) {
|
||||||
Log3 $name, 5,
|
Log3 $name, 5,
|
||||||
@ -835,32 +906,117 @@ sub ResponseProcessing {
|
|||||||
if ( defined( $decode_json->{category} )
|
if ( defined( $decode_json->{category} )
|
||||||
&& $decode_json->{category} eq 'gateway' );
|
&& $decode_json->{category} eq 'gateway' );
|
||||||
}
|
}
|
||||||
|
|
||||||
( $json, $tail ) = ParseJSON( $hash, $tail );
|
|
||||||
|
|
||||||
Log3 $name, 5,
|
|
||||||
"GardenaSmartBridge ($name) - Nach Sub: Laenge JSON: "
|
|
||||||
. length($json)
|
|
||||||
. " Content: "
|
|
||||||
. $json
|
|
||||||
. " Tail: "
|
|
||||||
. $tail;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
Log3 $name, 3, "GardenaSmartBridge ($name) - no Match for processing data";
|
sub PollChild {
|
||||||
|
my $hash = shift;
|
||||||
|
|
||||||
|
my $name = $hash->{NAME};
|
||||||
|
|
||||||
|
if ( defined( $hash->{".fhem"}{subprocess} ) ) {
|
||||||
|
my $subprocess = $hash->{".fhem"}{subprocess};
|
||||||
|
my $response = $subprocess->readFromChild();
|
||||||
|
|
||||||
|
if ( defined($response) ) {
|
||||||
|
ResponseProcessingFinalFromSubProcessing( $hash, $response );
|
||||||
|
$subprocess->wait();
|
||||||
|
CleanSubprocess($hash);
|
||||||
|
}
|
||||||
|
|
||||||
|
Log3( $name, 4,
|
||||||
|
qq{GardenaSmartBridge ($name) - still waiting ($subprocess->{lasterror}).}
|
||||||
|
);
|
||||||
|
|
||||||
|
InternalTimer( gettimeofday() + 1,
|
||||||
|
"FHEM::GardenaSmartBridge::PollChild", $hash );
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
# ResponseSubprocessin muss in eine async ausgelagert werden
|
||||||
|
######################################
|
||||||
|
# Begin Childprozess
|
||||||
|
######################################
|
||||||
|
sub ResponseSubprocessing {
|
||||||
|
my $subprocess = shift;
|
||||||
|
my $buffer = $subprocess->{buffer};
|
||||||
|
my @response = ();
|
||||||
|
|
||||||
|
my ( $json, $tail ) = ParseJSON($buffer);
|
||||||
|
|
||||||
|
while ($json) {
|
||||||
|
if ( defined($tail) and $tail ) {
|
||||||
|
push @response, $json;
|
||||||
|
}
|
||||||
|
|
||||||
|
( $json, $tail ) = ParseJSON($tail);
|
||||||
|
}
|
||||||
|
|
||||||
|
$subprocess->writeToParent( join '|', @response );
|
||||||
|
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
sub ParseJSON {
|
||||||
|
my $buffer = shift;
|
||||||
|
|
||||||
|
my $open = 0;
|
||||||
|
my $close = 0;
|
||||||
|
my $msg = '';
|
||||||
|
my $tail = '';
|
||||||
|
|
||||||
|
if ($buffer) {
|
||||||
|
for my $c ( split //, $buffer ) {
|
||||||
|
if ( $open == $close && $open > 0 ) {
|
||||||
|
$tail .= $c;
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
|
||||||
|
if ( $c eq '{' ) {
|
||||||
|
|
||||||
|
$open++;
|
||||||
|
|
||||||
|
}
|
||||||
|
elsif ( $c eq '}' ) {
|
||||||
|
|
||||||
|
$close++;
|
||||||
|
}
|
||||||
|
|
||||||
|
$msg .= $c;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if ( $open != $close ) {
|
||||||
|
|
||||||
|
$tail = $msg;
|
||||||
|
$msg = '';
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return ( $msg, $tail );
|
||||||
|
}
|
||||||
|
######################################
|
||||||
|
# End Childprozess
|
||||||
|
######################################
|
||||||
|
|
||||||
|
sub CleanSubprocess {
|
||||||
|
my $hash = shift;
|
||||||
|
|
||||||
|
my $name = $hash->{NAME};
|
||||||
|
|
||||||
|
delete( $hash->{".fhem"}{subprocess} );
|
||||||
|
Log3( $name, 4, qq{GardenaSmartBridge ($name) - clean Subprocess} );
|
||||||
|
}
|
||||||
|
|
||||||
sub WriteReadings {
|
sub WriteReadings {
|
||||||
my $hash = shift;
|
my $hash = shift;
|
||||||
my $decode_json = shift;
|
my $decode_json = shift;
|
||||||
|
|
||||||
# print Dumper $decode_json;
|
|
||||||
|
|
||||||
my $name = $hash->{NAME};
|
my $name = $hash->{NAME};
|
||||||
|
|
||||||
if ( defined( $decode_json->{id} )
|
if ( defined( $decode_json->{id} )
|
||||||
@ -905,7 +1061,8 @@ sub WriteReadings {
|
|||||||
{name} . '-' . $t,
|
{name} . '-' . $t,
|
||||||
$v
|
$v
|
||||||
)
|
)
|
||||||
if ($decode_json->{abilities}[0]{properties}[$properties]{name} !~ /ethernet_status|wifi_status/ );
|
if ( $decode_json->{abilities}[0]{properties}[$properties]
|
||||||
|
{name} !~ /ethernet_status|wifi_status/ );
|
||||||
if (
|
if (
|
||||||
(
|
(
|
||||||
$decode_json->{abilities}[0]{properties}
|
$decode_json->{abilities}[0]{properties}
|
||||||
@ -931,7 +1088,6 @@ sub WriteReadings {
|
|||||||
elsif ( $decode_json->{abilities}[0]{properties}
|
elsif ( $decode_json->{abilities}[0]{properties}
|
||||||
[$properties]{name} eq 'wifi_status' )
|
[$properties]{name} eq 'wifi_status' )
|
||||||
{
|
{
|
||||||
#TODO: read valies if bridge connected to wifi
|
|
||||||
readingsBulkUpdateIfChanged( $hash,
|
readingsBulkUpdateIfChanged( $hash,
|
||||||
'wifi_status-ssid', $v->{ssid} )
|
'wifi_status-ssid', $v->{ssid} )
|
||||||
if ( ref( $v->{ssid} ) ne 'HASH' );
|
if ( ref( $v->{ssid} ) ne 'HASH' );
|
||||||
@ -967,8 +1123,7 @@ sub getDevices {
|
|||||||
my $hash = shift;
|
my $hash = shift;
|
||||||
|
|
||||||
my $name = $hash->{NAME};
|
my $name = $hash->{NAME};
|
||||||
|
RemoveInternalTimer( $hash, "FHEM::GardenaSmartBridge::getDevices" );
|
||||||
RemoveInternalTimer($hash);
|
|
||||||
|
|
||||||
if ( not IsDisabled($name) ) {
|
if ( not IsDisabled($name) ) {
|
||||||
|
|
||||||
@ -978,12 +1133,15 @@ sub getDevices {
|
|||||||
for my $gardenaDev (@list) {
|
for my $gardenaDev (@list) {
|
||||||
push( @{ $hash->{helper}{deviceList} }, $gardenaDev );
|
push( @{ $hash->{helper}{deviceList} }, $gardenaDev );
|
||||||
}
|
}
|
||||||
|
if ( AttrVal( $name, 'gardenaAccountEmail', 'none' ) ne 'none'
|
||||||
|
&& ( defined( ReadPassword( $hash, $name ) ) ) )
|
||||||
|
{
|
||||||
Write( $hash, undef, undef, undef );
|
Write( $hash, undef, undef, undef );
|
||||||
Log3 $name, 4,
|
Log3 $name, 4,
|
||||||
"GardenaSmartBridge ($name) - fetch device list and device states";
|
"GardenaSmartBridge ($name) - fetch device list and device states";
|
||||||
|
} # fi gardenaAccountEmail
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
|
|
||||||
readingsSingleUpdate( $hash, 'state', 'disabled', 1 );
|
readingsSingleUpdate( $hash, 'state', 'disabled', 1 );
|
||||||
Log3 $name, 3, "GardenaSmartBridge ($name) - device is disabled";
|
Log3 $name, 3, "GardenaSmartBridge ($name) - device is disabled";
|
||||||
}
|
}
|
||||||
@ -1005,36 +1163,29 @@ sub getToken {
|
|||||||
readingsSingleUpdate( $hash, 'state', 'get token', 1 );
|
readingsSingleUpdate( $hash, 'state', 'get token', 1 );
|
||||||
|
|
||||||
delete $hash->{helper}{session_id}
|
delete $hash->{helper}{session_id}
|
||||||
if ( defined( $hash->{helper}{session_id} )
|
if ( exists( $hash->{helper}{session_id} ) );
|
||||||
&& $hash->{helper}{session_id} );
|
|
||||||
delete $hash->{helper}{user_id}
|
delete $hash->{helper}{user_id}
|
||||||
if ( defined( $hash->{helper}{user_id} ) && $hash->{helper}{user_id} );
|
if ( exists( $hash->{helper}{user_id} ) );
|
||||||
delete $hash->{helper}{locations_id}
|
delete $hash->{helper}{locations_id}
|
||||||
if ( defined( $hash->{helper}{locations_id} )
|
if ( exists( $hash->{helper}{locations_id} ) );
|
||||||
&& $hash->{helper}{locations_id} );
|
|
||||||
|
|
||||||
# Write(
|
|
||||||
# $hash,
|
|
||||||
# '"sessions": {"email": "'
|
|
||||||
# . AttrVal( $name, 'gardenaAccountEmail', 'none' )
|
|
||||||
# . '","password": "'
|
|
||||||
# . ReadPassword( $hash, $name ) . '"}',
|
|
||||||
# undef,
|
|
||||||
# undef
|
|
||||||
# );
|
|
||||||
|
|
||||||
Write(
|
Write(
|
||||||
$hash,
|
$hash,
|
||||||
'"data": {"type":"token", "attributes":{"username": "'
|
'"data": {"type":"token", "attributes":{"username": "'
|
||||||
. AttrVal( $name, 'gardenaAccountEmail', 'none' )
|
. AttrVal( $name, 'gardenaAccountEmail', 'none' )
|
||||||
. '","password": "'
|
. '","password": "'
|
||||||
. ReadPassword( $hash, $name ) . '", "client_id":"smartgarden-jwt-client"}}',
|
. ReadPassword( $hash, $name )
|
||||||
|
. '", "client_id":"smartgarden-jwt-client"}}',
|
||||||
undef,
|
undef,
|
||||||
undef
|
undef
|
||||||
);
|
);
|
||||||
|
|
||||||
Log3 $name, 4, '"data": {"type":"token", "attributes":{"username": "' . AttrVal( $name, 'gardenaAccountEmail', 'none' ) . '","password": "'
|
Log3 $name, 4,
|
||||||
. ReadPassword( $hash, $name ) . '", "client_id":"smartgarden-jwt-client"}}';
|
'"data": {"type":"token", "attributes":{"username": "'
|
||||||
|
. AttrVal( $name, 'gardenaAccountEmail', 'none' )
|
||||||
|
. '","password": "'
|
||||||
|
. ReadPassword( $hash, $name )
|
||||||
|
. '", "client_id":"smartgarden-jwt-client"}}';
|
||||||
Log3 $name, 3,
|
Log3 $name, 3,
|
||||||
"GardenaSmartBridge ($name) - send credentials to fetch Token and locationId";
|
"GardenaSmartBridge ($name) - send credentials to fetch Token and locationId";
|
||||||
|
|
||||||
@ -1085,7 +1236,7 @@ sub ReadPassword {
|
|||||||
|
|
||||||
Log3 $name, 3,
|
Log3 $name, 3,
|
||||||
"GardenaSmartBridge ($name) - unable to read password from file: $err";
|
"GardenaSmartBridge ($name) - unable to read password from file: $err";
|
||||||
return undef;
|
return;
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -1111,7 +1262,7 @@ sub ReadPassword {
|
|||||||
else {
|
else {
|
||||||
|
|
||||||
Log3 $name, 3, "GardenaSmartBridge ($name) - No password in file";
|
Log3 $name, 3, "GardenaSmartBridge ($name) - No password in file";
|
||||||
return undef;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
return;
|
return;
|
||||||
@ -1129,59 +1280,6 @@ sub Rename {
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
sub ParseJSON {
|
|
||||||
my $hash = shift;
|
|
||||||
my $buffer = shift;
|
|
||||||
|
|
||||||
my $name = $hash->{NAME};
|
|
||||||
my $open = 0;
|
|
||||||
my $close = 0;
|
|
||||||
my $msg = '';
|
|
||||||
my $tail = '';
|
|
||||||
|
|
||||||
if ($buffer) {
|
|
||||||
for my $c ( split //, $buffer ) {
|
|
||||||
if ( $open == $close && $open > 0 ) {
|
|
||||||
$tail .= $c;
|
|
||||||
Log3 $name, 5,
|
|
||||||
"GardenaSmartBridge ($name) - $open == $close and $open > 0";
|
|
||||||
|
|
||||||
}
|
|
||||||
elsif ( ( $open == $close ) && ( $c ne '{' ) ) {
|
|
||||||
|
|
||||||
Log3 $name, 5,
|
|
||||||
"GardenaSmartBridge ($name) - Garbage character before message: "
|
|
||||||
. $c;
|
|
||||||
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
|
|
||||||
if ( $c eq '{' ) {
|
|
||||||
|
|
||||||
$open++;
|
|
||||||
|
|
||||||
}
|
|
||||||
elsif ( $c eq '}' ) {
|
|
||||||
|
|
||||||
$close++;
|
|
||||||
}
|
|
||||||
|
|
||||||
$msg .= $c;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if ( $open != $close ) {
|
|
||||||
|
|
||||||
$tail = $msg;
|
|
||||||
$msg = '';
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
Log3 $name, 5,
|
|
||||||
"GardenaSmartBridge ($name) - return msg: $msg and tail: $tail";
|
|
||||||
return ( $msg, $tail );
|
|
||||||
}
|
|
||||||
|
|
||||||
sub createHttpValueStrings {
|
sub createHttpValueStrings {
|
||||||
my ( $hash, $payload, $deviceId, $abilities, $service_id ) = @_;
|
my ( $hash, $payload, $deviceId, $abilities, $service_id ) = @_;
|
||||||
|
|
||||||
@ -1200,20 +1298,23 @@ sub createHttpValueStrings {
|
|||||||
$payload = '{}' if ( !defined($payload) );
|
$payload = '{}' if ( !defined($payload) );
|
||||||
|
|
||||||
if ( $payload eq '{}' ) {
|
if ( $payload eq '{}' ) {
|
||||||
$method = 'GET';
|
$method = 'GET' if ( defined( $hash->{helper}{session_id} ) );
|
||||||
$payload = '';
|
$payload = '';
|
||||||
$uri .= '/locations?locatioId=null&user_id=' . $hash->{helper}{user_id}
|
$uri .= '/locations?locatioId=null&user_id=' . $hash->{helper}{user_id}
|
||||||
if ( exists( $hash->{helper}{user_id} )
|
if ( exists( $hash->{helper}{user_id} )
|
||||||
&& !defined( $hash->{helper}{locations_id} ) );
|
&& !defined( $hash->{helper}{locations_id} ) );
|
||||||
readingsSingleUpdate( $hash, 'state', 'fetch locationId', 1 )
|
readingsSingleUpdate( $hash, 'state', 'fetch locationId', 1 )
|
||||||
if ( !defined( $hash->{helper}{locations_id} ) );
|
if ( exists( $hash->{helper}{user_id} )
|
||||||
$uri .= '/auth/token' if ( !defined( $hash->{helper}{session_id} ) );
|
&& !defined( $hash->{helper}{locations_id} ) );
|
||||||
$uri .= '/devices'
|
$uri .= '/devices'
|
||||||
if (!defined($abilities)
|
if (!defined($abilities)
|
||||||
&& defined( $hash->{helper}{locations_id} ) );
|
&& defined( $hash->{helper}{locations_id} ) );
|
||||||
}
|
}
|
||||||
|
|
||||||
$uri = '/devices/'.InternalVal($hash->{helper}{debug_device}, 'DEVICEID', 0 ) if ( exists ($hash->{helper}{debug_device}));
|
$uri =
|
||||||
|
'/devices/' . InternalVal( $hash->{helper}{debug_device}, 'DEVICEID', 0 )
|
||||||
|
if ( defined( $hash->{helper}{debug_device} )
|
||||||
|
&& defined( $hash->{helper}{locations_id} ) );
|
||||||
$uri = '/auth/token' if ( !defined( $hash->{helper}{session_id} ) );
|
$uri = '/auth/token' if ( !defined( $hash->{helper}{session_id} ) );
|
||||||
|
|
||||||
if ( defined( $hash->{helper}{locations_id} ) ) {
|
if ( defined( $hash->{helper}{locations_id} ) ) {
|
||||||
@ -1222,11 +1323,7 @@ sub createHttpValueStrings {
|
|||||||
$method = 'PUT';
|
$method = 'PUT';
|
||||||
my $dhash = $modules{GardenaSmartDevice}{defptr}{$deviceId};
|
my $dhash = $modules{GardenaSmartDevice}{defptr}{$deviceId};
|
||||||
|
|
||||||
$uri .=
|
$uri .= '/devices/' . $deviceId . '/settings/' . $service_id
|
||||||
'/devices/'
|
|
||||||
. $deviceId
|
|
||||||
. '/settings/'
|
|
||||||
. $service_id
|
|
||||||
if ( defined($abilities)
|
if ( defined($abilities)
|
||||||
&& defined($payload)
|
&& defined($payload)
|
||||||
&& $abilities =~ /.*_settings/ );
|
&& $abilities =~ /.*_settings/ );
|
||||||
@ -1262,7 +1359,11 @@ sub createHttpValueStrings {
|
|||||||
. $deviceId
|
. $deviceId
|
||||||
. '/abilities/'
|
. '/abilities/'
|
||||||
. $abilities
|
. $abilities
|
||||||
. ( defined($valve_id) ? '/properties/watering_timer_'. $valve_id : '/command')
|
. (
|
||||||
|
defined($valve_id)
|
||||||
|
? '/properties/watering_timer_' . $valve_id
|
||||||
|
: '/command'
|
||||||
|
);
|
||||||
|
|
||||||
}
|
}
|
||||||
elsif (defined($abilities)
|
elsif (defined($abilities)
|
||||||
@ -1279,6 +1380,19 @@ sub createHttpValueStrings {
|
|||||||
. $abilities
|
. $abilities
|
||||||
. '/properties/manual_watering_timer';
|
. '/properties/manual_watering_timer';
|
||||||
|
|
||||||
|
}
|
||||||
|
elsif (defined($abilities)
|
||||||
|
&& defined($payload)
|
||||||
|
&& $abilities eq 'watering_button_config' )
|
||||||
|
{
|
||||||
|
$method = 'PUT';
|
||||||
|
|
||||||
|
$uri .=
|
||||||
|
'/devices/'
|
||||||
|
. $deviceId
|
||||||
|
. '/abilities/watering'
|
||||||
|
. '/properties/button_config_time';
|
||||||
|
|
||||||
}
|
}
|
||||||
elsif (defined($abilities)
|
elsif (defined($abilities)
|
||||||
&& defined($payload)
|
&& defined($payload)
|
||||||
@ -1463,9 +1577,9 @@ sub DeletePassword {
|
|||||||
],
|
],
|
||||||
"release_status": "stable",
|
"release_status": "stable",
|
||||||
"license": "GPL_2",
|
"license": "GPL_2",
|
||||||
"version": "v2.4.0",
|
"version": "v2.4.7",
|
||||||
"author": [
|
"author": [
|
||||||
"Marko Oldenburg <leongaultier@gmail.com>"
|
"Marko Oldenburg <fhemdevelopment@cooltux.net>"
|
||||||
],
|
],
|
||||||
"x_fhem_maintainer": [
|
"x_fhem_maintainer": [
|
||||||
"CoolTux"
|
"CoolTux"
|
||||||
|
@ -1,8 +1,8 @@
|
|||||||
###############################################################################
|
###############################################################################
|
||||||
#
|
#
|
||||||
# Developed with Kate
|
# Developed with VSCodium and richterger perl plugin.
|
||||||
#
|
#
|
||||||
# (c) 2017-2021 Copyright: Marko Oldenburg (fhemdevelopment at cooltux dot net)
|
# (c) 2017-2022 Copyright: Marko Oldenburg (fhemdevelopment at cooltux dot net)
|
||||||
# All rights reserved
|
# All rights reserved
|
||||||
#
|
#
|
||||||
# Special thanks goes to comitters:
|
# Special thanks goes to comitters:
|
||||||
@ -72,15 +72,11 @@ eval {
|
|||||||
require JSON::MaybeXS;
|
require JSON::MaybeXS;
|
||||||
import JSON::MaybeXS qw( decode_json encode_json );
|
import JSON::MaybeXS qw( decode_json encode_json );
|
||||||
1;
|
1;
|
||||||
};
|
} or do {
|
||||||
|
|
||||||
if ($@) {
|
|
||||||
$@ = undef;
|
|
||||||
|
|
||||||
# try to use JSON wrapper
|
# try to use JSON wrapper
|
||||||
# for chance of better performance
|
# for chance of better performance
|
||||||
eval {
|
eval {
|
||||||
|
|
||||||
# JSON preference order
|
# JSON preference order
|
||||||
local $ENV{PERL_JSON_BACKEND} =
|
local $ENV{PERL_JSON_BACKEND} =
|
||||||
'Cpanel::JSON::XS,JSON::XS,JSON::PP,JSON::backportPP'
|
'Cpanel::JSON::XS,JSON::XS,JSON::PP,JSON::backportPP'
|
||||||
@ -89,10 +85,7 @@ if ($@) {
|
|||||||
require JSON;
|
require JSON;
|
||||||
import JSON qw( decode_json encode_json );
|
import JSON qw( decode_json encode_json );
|
||||||
1;
|
1;
|
||||||
};
|
} or do {
|
||||||
|
|
||||||
if ($@) {
|
|
||||||
$@ = undef;
|
|
||||||
|
|
||||||
# In rare cases, Cpanel::JSON::XS may
|
# In rare cases, Cpanel::JSON::XS may
|
||||||
# be installed but JSON|JSON::MaybeXS not ...
|
# be installed but JSON|JSON::MaybeXS not ...
|
||||||
@ -100,10 +93,7 @@ if ($@) {
|
|||||||
require Cpanel::JSON::XS;
|
require Cpanel::JSON::XS;
|
||||||
import Cpanel::JSON::XS qw(decode_json encode_json);
|
import Cpanel::JSON::XS qw(decode_json encode_json);
|
||||||
1;
|
1;
|
||||||
};
|
} or do {
|
||||||
|
|
||||||
if ($@) {
|
|
||||||
$@ = undef;
|
|
||||||
|
|
||||||
# In rare cases, JSON::XS may
|
# In rare cases, JSON::XS may
|
||||||
# be installed but JSON not ...
|
# be installed but JSON not ...
|
||||||
@ -111,10 +101,7 @@ if ($@) {
|
|||||||
require JSON::XS;
|
require JSON::XS;
|
||||||
import JSON::XS qw(decode_json encode_json);
|
import JSON::XS qw(decode_json encode_json);
|
||||||
1;
|
1;
|
||||||
};
|
} or do {
|
||||||
|
|
||||||
if ($@) {
|
|
||||||
$@ = undef;
|
|
||||||
|
|
||||||
# Fallback to built-in JSON which SHOULD
|
# Fallback to built-in JSON which SHOULD
|
||||||
# be available since 5.014 ...
|
# be available since 5.014 ...
|
||||||
@ -122,20 +109,17 @@ if ($@) {
|
|||||||
require JSON::PP;
|
require JSON::PP;
|
||||||
import JSON::PP qw(decode_json encode_json);
|
import JSON::PP qw(decode_json encode_json);
|
||||||
1;
|
1;
|
||||||
};
|
} or do {
|
||||||
|
|
||||||
if ($@) {
|
|
||||||
$@ = undef;
|
|
||||||
|
|
||||||
# Fallback to JSON::backportPP in really rare cases
|
# Fallback to JSON::backportPP in really rare cases
|
||||||
require JSON::backportPP;
|
require JSON::backportPP;
|
||||||
import JSON::backportPP qw(decode_json encode_json);
|
import JSON::backportPP qw(decode_json encode_json);
|
||||||
1;
|
1;
|
||||||
}
|
};
|
||||||
}
|
};
|
||||||
}
|
};
|
||||||
}
|
};
|
||||||
}
|
};
|
||||||
|
|
||||||
## Import der FHEM Funktionen
|
## Import der FHEM Funktionen
|
||||||
#-- Run before package compilation
|
#-- Run before package compilation
|
||||||
@ -209,6 +193,11 @@ sub Define {
|
|||||||
$hash->{helper}{STARTINGPOINTID} = '';
|
$hash->{helper}{STARTINGPOINTID} = '';
|
||||||
$hash->{helper}{schedules_paused_until_id} = '';
|
$hash->{helper}{schedules_paused_until_id} = '';
|
||||||
$hash->{helper}{eco_mode_id} = '';
|
$hash->{helper}{eco_mode_id} = '';
|
||||||
|
$hash->{helper}{button_config_time_id} = '';
|
||||||
|
$hash->{helper}{winter_mode_id} = '';
|
||||||
|
|
||||||
|
$hash->{helper}{_id} = '';
|
||||||
|
|
||||||
# IrrigationControl valve control max 6
|
# IrrigationControl valve control max 6
|
||||||
$hash->{helper}{schedules_paused_until_1_id} = '';
|
$hash->{helper}{schedules_paused_until_1_id} = '';
|
||||||
$hash->{helper}{schedules_paused_until_2_id} = '';
|
$hash->{helper}{schedules_paused_until_2_id} = '';
|
||||||
@ -283,12 +272,14 @@ sub Set {
|
|||||||
my $aArg = shift // return;
|
my $aArg = shift // return;
|
||||||
|
|
||||||
my $name = shift @$aArg;
|
my $name = shift @$aArg;
|
||||||
my $cmd = shift @$aArg // return qq{"set $name" needs at least one argument};
|
my $cmd = shift @$aArg
|
||||||
|
// return qq{"set $name" needs at least one argument};
|
||||||
|
|
||||||
my $payload;
|
my $payload;
|
||||||
my $abilities;
|
my $abilities;
|
||||||
my $service_id;
|
my $service_id;
|
||||||
my $mainboard_version = ReadingsVal( $name, 'mower_type-mainboard_version', 0.0 );
|
my $mainboard_version =
|
||||||
|
ReadingsVal( $name, 'mower_type-mainboard_version', 0.0 );
|
||||||
|
|
||||||
#set default abilitie ... overwrite in cmd to change
|
#set default abilitie ... overwrite in cmd to change
|
||||||
$abilities = 'mower'
|
$abilities = 'mower'
|
||||||
@ -306,7 +297,9 @@ sub Set {
|
|||||||
if ( lc $cmd eq 'parkuntilfurthernotice' ) {
|
if ( lc $cmd eq 'parkuntilfurthernotice' ) {
|
||||||
$payload = '"name":"park_until_further_notice"';
|
$payload = '"name":"park_until_further_notice"';
|
||||||
if ( $mainboard_version > 10.30 ) {
|
if ( $mainboard_version > 10.30 ) {
|
||||||
$payload = ' "settings":{"name":"schedules_paused_until","value":"2040-12-31T22:00:00.000Z","device":"'.$hash->{DEVICEID}.'"}';
|
$payload =
|
||||||
|
' "settings":{"name":"schedules_paused_until","value":"2038-01-18T00:00:00.000Z","device":"'
|
||||||
|
. $hash->{DEVICEID} . '"}';
|
||||||
$abilities = 'mower_settings';
|
$abilities = 'mower_settings';
|
||||||
$service_id = $hash->{helper}{schedules_paused_until_id};
|
$service_id = $hash->{helper}{schedules_paused_until_id};
|
||||||
}
|
}
|
||||||
@ -321,7 +314,9 @@ sub Set {
|
|||||||
elsif ( lc $cmd eq 'startresumeschedule' ) {
|
elsif ( lc $cmd eq 'startresumeschedule' ) {
|
||||||
$payload = '"name":"start_resume_schedule"';
|
$payload = '"name":"start_resume_schedule"';
|
||||||
if ( $mainboard_version > 10.30 ) {
|
if ( $mainboard_version > 10.30 ) {
|
||||||
$payload = ' "settings":{"name":"schedules_paused_until","value":"","device":"'.$hash->{DEVICEID}.'"}';
|
$payload =
|
||||||
|
' "settings":{"name":"schedules_paused_until","value":"","device":"'
|
||||||
|
. $hash->{DEVICEID} . '"}';
|
||||||
$abilities = 'mower_settings';
|
$abilities = 'mower_settings';
|
||||||
$service_id = $hash->{helper}{schedules_paused_until_id};
|
$service_id = $hash->{helper}{schedules_paused_until_id};
|
||||||
}
|
}
|
||||||
@ -330,21 +325,28 @@ sub Set {
|
|||||||
$payload = '"name":"start_override_timer","parameters":{"duration":'
|
$payload = '"name":"start_override_timer","parameters":{"duration":'
|
||||||
. $aArg->[0] * 60 . '}';
|
. $aArg->[0] * 60 . '}';
|
||||||
if ( $mainboard_version > 10.30 ) {
|
if ( $mainboard_version > 10.30 ) {
|
||||||
$payload = '"properties":{"name":"mower_timer","value":'.$aArg->[0] * 60 .'}';
|
$payload = '"properties":{"name":"mower_timer","value":'
|
||||||
|
. $aArg->[0] * 60 . '}';
|
||||||
$abilities = 'mower_timer';
|
$abilities = 'mower_timer';
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
elsif ( lc $cmd eq 'startpoint' ) {
|
elsif ( lc $cmd eq 'startpoint' ) {
|
||||||
my $err;
|
my $err;
|
||||||
( $err, $payload, $abilities ) = SetPredefinedStartPoints( $hash, $aArg );
|
( $err, $payload, $abilities ) =
|
||||||
|
SetPredefinedStartPoints( $hash, $aArg );
|
||||||
$service_id = $hash->{helper}{STARTINGPOINTID};
|
$service_id = $hash->{helper}{STARTINGPOINTID};
|
||||||
return $err if ( defined($err) );
|
return $err if ( defined($err) );
|
||||||
}
|
}
|
||||||
elsif ( lc $cmd eq 'eco' ) {
|
elsif ( lc $cmd eq 'eco' ) {
|
||||||
$payload = '"settings": {"name": "eco_mode", "value": '.$aArg->[0].', "device": "'.$hash->{DEVICEID}.'"}';
|
$payload =
|
||||||
|
'"settings": {"name": "eco_mode", "value": '
|
||||||
|
. $aArg->[0]
|
||||||
|
. ', "device": "'
|
||||||
|
. $hash->{DEVICEID} . '"}';
|
||||||
$abilities = 'mower_settings' if ( $mainboard_version > 10.30 );
|
$abilities = 'mower_settings' if ( $mainboard_version > 10.30 );
|
||||||
$service_id = $hash->{helper}{eco_mode_id};
|
$service_id = $hash->{helper}{eco_mode_id};
|
||||||
|
|
||||||
#$abilities['service_id'] = $hash->{helper}{SCHEDULESID} if ( $mainboard_version > 10.30 );
|
#$abilities['service_id'] = $hash->{helper}{SCHEDULESID} if ( $mainboard_version > 10.30 );
|
||||||
}
|
}
|
||||||
### electronic_pressure_pump
|
### electronic_pressure_pump
|
||||||
@ -361,6 +363,17 @@ sub Set {
|
|||||||
. $aArg->[0] * 60
|
. $aArg->[0] * 60
|
||||||
. ',"valve_id":1}}';
|
. ',"valve_id":1}}';
|
||||||
}
|
}
|
||||||
|
elsif ( lc $cmd eq 'manualbuttontime' ) {
|
||||||
|
$service_id = $hash->{helper}{button_config_time_id};
|
||||||
|
$payload =
|
||||||
|
'"properties":{"name":"button_config_time",'
|
||||||
|
. '"value":'
|
||||||
|
. $aArg->[0] * 60
|
||||||
|
. ',"timestamp":"2021-05-26T19:06:23.680Z"'
|
||||||
|
. ',"at_bound":null,"unit":"seconds","ability":"'
|
||||||
|
. $service_id . '"}';
|
||||||
|
$abilities = 'watering_button_config';
|
||||||
|
}
|
||||||
elsif ( $cmd =~ m{\AcancelOverride}xms ) {
|
elsif ( $cmd =~ m{\AcancelOverride}xms ) {
|
||||||
|
|
||||||
my $valve_id = 1;
|
my $valve_id = 1;
|
||||||
@ -377,14 +390,40 @@ sub Set {
|
|||||||
. ',"valve_id":'
|
. ',"valve_id":'
|
||||||
. $valve_id . '}}';
|
. $valve_id . '}}';
|
||||||
}
|
}
|
||||||
|
elsif ( $cmd =~ /.*Schedule/ ) {
|
||||||
|
my $duration = (
|
||||||
|
(
|
||||||
|
defined( $aArg->[0] )
|
||||||
|
? (
|
||||||
|
(
|
||||||
|
( Time::Piece->new ) +
|
||||||
|
( ONE_HOUR * $aArg->[0] ) -
|
||||||
|
( Time::Piece->new )->tzoffset
|
||||||
|
)->datetime
|
||||||
|
)
|
||||||
|
. '.000Z'
|
||||||
|
: '2038-01-18T00:00:00.000Z'
|
||||||
|
)
|
||||||
|
);
|
||||||
|
|
||||||
|
$abilities = 'wateringcomputer_settings';
|
||||||
|
$service_id = $hash->{helper}->{'schedules_paused_until_id'};
|
||||||
|
$payload =
|
||||||
|
'"settings":{"name":"schedules_paused_until"'
|
||||||
|
. ', "value":"'
|
||||||
|
. ( $cmd eq 'resumeSchedule' ? '' : $duration )
|
||||||
|
. '","device":"'
|
||||||
|
. $hash->{DEVICEID} . '"}';
|
||||||
|
}
|
||||||
elsif ( lc $cmd eq 'on' || lc $cmd eq 'off' || lc $cmd eq 'on-for-timer' ) {
|
elsif ( lc $cmd eq 'on' || lc $cmd eq 'off' || lc $cmd eq 'on-for-timer' ) {
|
||||||
my $val = (
|
my $val = (
|
||||||
defined($aArg) && ref($aArg) eq 'ARRAY'
|
scalar( !@$aArg == 0 ) && ref($aArg) eq 'ARRAY'
|
||||||
? $aArg->[0] * 60
|
? $aArg->[0] * 60
|
||||||
: lc $cmd
|
: lc $cmd
|
||||||
);
|
);
|
||||||
|
|
||||||
$payload = '"properties":{"value":"' . $val . '"}';
|
$payload =
|
||||||
|
'"properties":{"name":"power_timer", "value":"' . $val . '"}';
|
||||||
}
|
}
|
||||||
### Watering ic24
|
### Watering ic24
|
||||||
elsif ( $cmd =~ m{\AmanualDurationValve\d\z}xms ) {
|
elsif ( $cmd =~ m{\AmanualDurationValve\d\z}xms ) {
|
||||||
@ -407,27 +446,44 @@ sub Set {
|
|||||||
}
|
}
|
||||||
elsif ( $cmd =~ /.*ScheduleValve/ ) {
|
elsif ( $cmd =~ /.*ScheduleValve/ ) {
|
||||||
my $valve_id = $aArg->[0];
|
my $valve_id = $aArg->[0];
|
||||||
my $duration = (( defined($aArg->[1]) ? ( ((Time::Piece->new)+(ONE_HOUR * $aArg->[1]) - (Time::Piece->new)->tzoffset )->datetime ).'.000Z' : '2040-12-31T22:00:00.000Z'));
|
my $duration = (
|
||||||
|
(
|
||||||
|
defined( $aArg->[1] )
|
||||||
|
? (
|
||||||
|
(
|
||||||
|
( Time::Piece->new ) +
|
||||||
|
( ONE_HOUR * $aArg->[1] ) -
|
||||||
|
( Time::Piece->new )->tzoffset
|
||||||
|
)->datetime
|
||||||
|
)
|
||||||
|
. '.000Z'
|
||||||
|
: '2038-01-18T00:00:00.000Z'
|
||||||
|
)
|
||||||
|
);
|
||||||
|
|
||||||
$abilities = 'irrigation_settings';
|
$abilities = 'irrigation_settings';
|
||||||
$service_id = $hash->{helper}->{'schedules_paused_until_'.$valve_id.'_id'};
|
$service_id =
|
||||||
$payload = '"settings":{"name":"schedules_paused_until_'
|
$hash->{helper}->{ 'schedules_paused_until_' . $valve_id . '_id' };
|
||||||
|
$payload =
|
||||||
|
'"settings":{"name":"schedules_paused_until_'
|
||||||
. $valve_id
|
. $valve_id
|
||||||
. '", "value":"'
|
. '", "value":"'
|
||||||
. ( $cmd eq 'resumeScheduleValve' ? '' : $duration )
|
. ( $cmd eq 'resumeScheduleValve' ? '' : $duration )
|
||||||
. '","device":"'
|
. '","device":"'
|
||||||
. $hash->{DEVICEID}
|
. $hash->{DEVICEID} . '"}';
|
||||||
. '"}';
|
|
||||||
}
|
}
|
||||||
### Sensors
|
### Sensors
|
||||||
elsif ( lc $cmd eq 'refresh' ) {
|
elsif ( lc $cmd eq 'refresh' ) {
|
||||||
|
|
||||||
my $sensname = $aArg->[0];
|
my $sensname = $aArg->[0];
|
||||||
if ( lc $sensname eq 'temperature' ) {
|
if ( lc $sensname eq 'temperature' ) {
|
||||||
if ( ReadingsVal( $name, 'device_info-category', 'sensor' ) eq 'sensor') {
|
if ( ReadingsVal( $name, 'device_info-category', 'sensor' ) eq
|
||||||
|
'sensor' )
|
||||||
|
{
|
||||||
$payload = '"name":"measure_ambient_temperature"';
|
$payload = '"name":"measure_ambient_temperature"';
|
||||||
$abilities = 'ambient_temperature';
|
$abilities = 'ambient_temperature';
|
||||||
} else {
|
}
|
||||||
|
else {
|
||||||
$payload = '"name":"measure_soil_temperature"';
|
$payload = '"name":"measure_soil_temperature"';
|
||||||
$abilities = 'soil_temperature';
|
$abilities = 'soil_temperature';
|
||||||
}
|
}
|
||||||
@ -441,8 +497,16 @@ sub Set {
|
|||||||
$payload = '"name":"measure_soil_humidity"';
|
$payload = '"name":"measure_soil_humidity"';
|
||||||
$abilities = 'humidity';
|
$abilities = 'humidity';
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
## winter sleep
|
||||||
|
elsif ( lc $cmd eq 'winter_mode' ) {
|
||||||
|
$payload =
|
||||||
|
'"settings":{"name":"winter_mode","value":"'
|
||||||
|
. $aArg->[0]
|
||||||
|
. '","device":"'
|
||||||
|
. $hash->{DEVICEID} . '"}';
|
||||||
|
$abilities = 'winter_settings';
|
||||||
|
$service_id = $hash->{helper}->{'winter_mode_id'};
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
|
|
||||||
@ -452,7 +516,8 @@ sub Set {
|
|||||||
'parkUntilFurtherNotice:noArg parkUntilNextTimer:noArg startResumeSchedule:noArg startOverrideTimer:slider,0,1,240 startpoint'
|
'parkUntilFurtherNotice:noArg parkUntilNextTimer:noArg startResumeSchedule:noArg startOverrideTimer:slider,0,1,240 startpoint'
|
||||||
if ( AttrVal( $name, 'model', 'unknown' ) eq 'mower' );
|
if ( AttrVal( $name, 'model', 'unknown' ) eq 'mower' );
|
||||||
|
|
||||||
$list .= 'manualOverride:slider,1,1,59 cancelOverride:noArg'
|
$list .=
|
||||||
|
'manualOverride:slider,1,1,59 cancelOverride:noArg resumeSchedule:noArg stopSchedule manualButtonTime:slider,0,2,100'
|
||||||
if ( AttrVal( $name, 'model', 'unknown' ) eq 'watering_computer' );
|
if ( AttrVal( $name, 'model', 'unknown' ) eq 'watering_computer' );
|
||||||
|
|
||||||
$list .=
|
$list .=
|
||||||
@ -461,14 +526,18 @@ sub Set {
|
|||||||
|
|
||||||
$list .= 'refresh:temperature,humidity'
|
$list .= 'refresh:temperature,humidity'
|
||||||
if ( AttrVal( $name, 'model', 'unknown' ) eq 'sensor' );
|
if ( AttrVal( $name, 'model', 'unknown' ) eq 'sensor' );
|
||||||
|
|
||||||
# add light for old sensors
|
# add light for old sensors
|
||||||
$list .= ',light'
|
$list .= ',light'
|
||||||
if ( AttrVal( $name, 'model', 'unknown' ) eq 'sensor'
|
if ( AttrVal( $name, 'model', 'unknown' ) eq 'sensor'
|
||||||
&& ReadingsVal($name, 'device_info-category', 'unknown') eq 'sensor' );
|
&& ReadingsVal( $name, 'device_info-category', 'unknown' ) eq
|
||||||
|
'sensor' );
|
||||||
|
|
||||||
$list .= 'on:noArg off:noArg on-for-timer:slider,0,1,60'
|
$list .= 'on:noArg off:noArg on-for-timer:slider,0,1,720'
|
||||||
if ( AttrVal( $name, 'model', 'unknown' ) eq 'power' );
|
if ( AttrVal( $name, 'model', 'unknown' ) eq 'power' );
|
||||||
|
|
||||||
|
# all devices has abilitie to fall a sleep
|
||||||
|
$list .= ' winter_mode:awake,hibernate';
|
||||||
return "Unknown argument $cmd, choose one of $list";
|
return "Unknown argument $cmd, choose one of $list";
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -547,6 +616,32 @@ sub WriteReadings {
|
|||||||
for my $propertie (
|
for my $propertie (
|
||||||
@{ $decode_json->{abilities}[$abilities]{properties} } )
|
@{ $decode_json->{abilities}[$abilities]{properties} } )
|
||||||
{
|
{
|
||||||
|
if (
|
||||||
|
exists( $decode_json->{abilities}[$abilities]{name} )
|
||||||
|
&& ( $decode_json->{abilities}[$abilities]{name} eq
|
||||||
|
'watering' )
|
||||||
|
)
|
||||||
|
{
|
||||||
|
if ( $propertie->{name} eq 'button_config_time' ) {
|
||||||
|
if ( $hash->{helper}{ $propertie->{name} . '_id' } ne
|
||||||
|
$decode_json->{abilities}[$abilities]{id} )
|
||||||
|
{
|
||||||
|
$hash->{helper}{ $propertie->{name} . '_id' } =
|
||||||
|
$decode_json->{abilities}[$abilities]{id};
|
||||||
|
}
|
||||||
|
readingsBulkUpdateIfChanged(
|
||||||
|
$hash,
|
||||||
|
'manualButtonTime',
|
||||||
|
(
|
||||||
|
RigReadingsValue(
|
||||||
|
$hash, $propertie->{value} / 60
|
||||||
|
)
|
||||||
|
)
|
||||||
|
);
|
||||||
|
next;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
readingsBulkUpdateIfChanged(
|
readingsBulkUpdateIfChanged(
|
||||||
$hash,
|
$hash,
|
||||||
$decode_json->{abilities}[$abilities]{name} . '-'
|
$decode_json->{abilities}[$abilities]{name} . '-'
|
||||||
@ -596,6 +691,22 @@ sub WriteReadings {
|
|||||||
. $propertie->{name} eq 'light-light' )
|
. $propertie->{name} eq 'light-light' )
|
||||||
);
|
);
|
||||||
|
|
||||||
|
readingsBulkUpdateIfChanged(
|
||||||
|
$hash,
|
||||||
|
$decode_json->{abilities}[$abilities]{name} . '-'
|
||||||
|
. $propertie->{name}
|
||||||
|
. '_timestamp',
|
||||||
|
Time::Piece->strptime(
|
||||||
|
RigReadingsValue( $hash, $propertie->{timestamp} ),
|
||||||
|
"%Y-%m-%d %H:%M:%S" )->strftime('%s')
|
||||||
|
|
||||||
|
)
|
||||||
|
if (
|
||||||
|
defined( $propertie->{value} )
|
||||||
|
&& ( $decode_json->{abilities}[$abilities]{name} . '-'
|
||||||
|
. $propertie->{name} eq 'mower_timer-mower_timer' )
|
||||||
|
);
|
||||||
|
|
||||||
readingsBulkUpdateIfChanged(
|
readingsBulkUpdateIfChanged(
|
||||||
$hash,
|
$hash,
|
||||||
$decode_json->{abilities}[$abilities]{name} . '-'
|
$decode_json->{abilities}[$abilities]{name} . '-'
|
||||||
@ -633,23 +744,38 @@ sub WriteReadings {
|
|||||||
$abilities--;
|
$abilities--;
|
||||||
} while ( $abilities >= 0 );
|
} while ( $abilities >= 0 );
|
||||||
|
|
||||||
|
my $winter_mode;
|
||||||
|
|
||||||
do {
|
do {
|
||||||
#Log3 $name, 1, "Settings pro Device : ".$decode_json->{settings}[$settings]{name};
|
#Log3 $name, 1, "Settings pro Device : ".$decode_json->{settings}[$settings]{name};
|
||||||
#Log3 $name, 1, " - KEIN ARRAY" if ( ref( $decode_json->{settings}[$settings]{value} ) ne "ARRAY");
|
#Log3 $name, 1, " - KEIN ARRAY" if ( ref( $decode_json->{settings}[$settings]{value} ) ne "ARRAY");
|
||||||
#Log3 $name, 1, " - IST ARRAY" if ( ref( $decode_json->{settings}[$settings]{value} ) eq "ARRAY");
|
#Log3 $name, 1, " - IST ARRAY" if ( ref( $decode_json->{settings}[$settings]{value} ) eq "ARRAY");
|
||||||
|
|
||||||
if ( exists($decode_json->{settings}[$settings]{name})
|
if (
|
||||||
&& (
|
exists( $decode_json->{settings}[$settings]{name} )
|
||||||
$decode_json->{settings}[$settings]{name} =~ /schedules_paused_until_?\d?$/
|
&& ( $decode_json->{settings}[$settings]{name} =~
|
||||||
|| $decode_json->{settings}[$settings]{name} eq 'eco_mode' )
|
/schedules_paused_until_?\d?$/
|
||||||
|
|| $decode_json->{settings}[$settings]{name} eq 'eco_mode'
|
||||||
|
|| $decode_json->{settings}[$settings]{name} eq 'winter_mode' )
|
||||||
)
|
)
|
||||||
{
|
{
|
||||||
if ( $hash->{helper}{$decode_json->{settings}[$settings]{name}.'_id'} ne
|
if ( $hash->{helper}
|
||||||
|
{ $decode_json->{settings}[$settings]{name} . '_id' } ne
|
||||||
$decode_json->{settings}[$settings]{id} )
|
$decode_json->{settings}[$settings]{id} )
|
||||||
{
|
{
|
||||||
$hash->{helper}{$decode_json->{settings}[$settings]{name}.'_id'} =
|
$hash->{helper}
|
||||||
|
{ $decode_json->{settings}[$settings]{name} . '_id' } =
|
||||||
$decode_json->{settings}[$settings]{id};
|
$decode_json->{settings}[$settings]{id};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
# save winter mode as reading
|
||||||
|
|
||||||
|
if ( $decode_json->{settings}[$settings]{name} eq 'winter_mode' ) {
|
||||||
|
readingsBulkUpdateIfChanged( $hash, 'winter_mode',
|
||||||
|
$decode_json->{settings}[$settings]{value} );
|
||||||
|
|
||||||
|
$winter_mode = $decode_json->{settings}[$settings]{value};
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if ( ref( $decode_json->{settings}[$settings]{value} ) eq "ARRAY"
|
if ( ref( $decode_json->{settings}[$settings]{value} ) eq "ARRAY"
|
||||||
@ -683,36 +809,69 @@ sub WriteReadings {
|
|||||||
$settings--;
|
$settings--;
|
||||||
} while ( $settings >= 0 );
|
} while ( $settings >= 0 );
|
||||||
|
|
||||||
|
if ( $winter_mode ne 'hibernate' ) {
|
||||||
|
setState($hash);
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
readingsBulkUpdate( $hash, 'state',
|
||||||
|
RigReadingsValue( $hash, 'hibernate' ) );
|
||||||
|
}
|
||||||
|
|
||||||
my $online_state = ReadingsVal($name , 'device_info-connection_status', 'unknown');
|
readingsEndUpdate( $hash, 1 );
|
||||||
|
|
||||||
|
Log3 $name, 4, "GardenaSmartDevice ($name) - readings was written";
|
||||||
|
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
sub setState {
|
||||||
|
my $hash = shift;
|
||||||
|
my $name = $hash->{NAME};
|
||||||
|
|
||||||
|
my $online_state =
|
||||||
|
ReadingsVal( $name, 'device_info-connection_status', 'unknown' );
|
||||||
|
|
||||||
readingsBulkUpdate( $hash, 'state',
|
readingsBulkUpdate( $hash, 'state',
|
||||||
$online_state eq 'online' ?
|
$online_state eq 'online'
|
||||||
ReadingsVal( $name, 'mower-status', 'readingsValError') : 'offline'
|
? ReadingsVal( $name, 'mower-status', 'readingsValError' )
|
||||||
)
|
: 'offline' )
|
||||||
if ( AttrVal( $name, 'model', 'unknown' ) eq 'mower' );
|
if ( AttrVal( $name, 'model', 'unknown' ) eq 'mower' );
|
||||||
readingsBulkUpdate(
|
readingsBulkUpdate(
|
||||||
$hash, 'state',
|
$hash, 'state',
|
||||||
(
|
(
|
||||||
ReadingsVal( $name, 'watering-watering_timer_1_duration', 0 )
|
ReadingsVal( $name, 'watering-watering_timer_1_duration', 0 ) =~
|
||||||
=~ m{\A[1-9]([0-9]+)?\z}xms
|
m{\A[1-9]([0-9]+)?\z}xms
|
||||||
? RigReadingsValue( $hash, 'open' )
|
? RigReadingsValue( $hash, 'open' )
|
||||||
: RigReadingsValue( $hash, 'closed' )
|
: RigReadingsValue( $hash, 'closed' )
|
||||||
)
|
)
|
||||||
) if ( AttrVal( $name, 'model', 'unknown' ) eq 'watering_computer' );
|
) if ( AttrVal( $name, 'model', 'unknown' ) eq 'watering_computer' );
|
||||||
|
|
||||||
|
|
||||||
if ( AttrVal( $name, 'model', 'unknown' ) eq 'sensor' ) {
|
if ( AttrVal( $name, 'model', 'unknown' ) eq 'sensor' ) {
|
||||||
my $state_string = ( ReadingsVal($name, 'device_info-category', 'unknown') eq 'sensor') ? 'T: ' .ReadingsVal( $name, 'ambient_temperature-temperature', 'readingsValError' ) . '°C, ' : 'T: ' .ReadingsVal( $name, 'soil_temperature-temperature', 'readingsValError' ) . '°C, ' ;
|
my $state_string =
|
||||||
$state_string .= 'H: '. ReadingsVal( $name, 'humidity-humidity', 'readingsValError' ). '%';
|
( ReadingsVal( $name, 'device_info-category', 'unknown' ) eq
|
||||||
$state_string .= ', L: ' . ReadingsVal( $name, 'light-light', 'readingsValError' ) . 'lux' if (ReadingsVal($name, 'device_info-category', 'unknown') eq 'sensor');
|
'sensor' )
|
||||||
|
? 'T: '
|
||||||
|
. ReadingsVal( $name, 'ambient_temperature-temperature',
|
||||||
|
'readingsValError' )
|
||||||
|
. '°C, '
|
||||||
|
: 'T: '
|
||||||
|
. ReadingsVal( $name, 'soil_temperature-temperature',
|
||||||
|
'readingsValError' )
|
||||||
|
. '°C, ';
|
||||||
|
$state_string .= 'H: '
|
||||||
|
. ReadingsVal( $name, 'humidity-humidity', 'readingsValError' ) . '%';
|
||||||
|
$state_string .= ', L: '
|
||||||
|
. ReadingsVal( $name, 'light-light', 'readingsValError' ) . 'lux'
|
||||||
|
if ( ReadingsVal( $name, 'device_info-category', 'unknown' ) eq
|
||||||
|
'sensor' );
|
||||||
|
|
||||||
# if ( $online_state eq 'offline') {
|
# if ( $online_state eq 'offline') {
|
||||||
# readingsBulkUpdate( $hash, 'humidity-humidity', '-1' );
|
# readingsBulkUpdate( $hash, 'humidity-humidity', '-1' );
|
||||||
# readingsBulkUpdate( $hash, 'ambient_temperature-temperature', '-1' ) if (ReadingsVal($name, 'device_info-category', 'unknown') eq 'sensor');
|
# readingsBulkUpdate( $hash, 'ambient_temperature-temperature', '-1' ) if (ReadingsVal($name, 'device_info-category', 'unknown') eq 'sensor');
|
||||||
# readingsBulkUpdate( $hash, 'light-light', '-1' ) if (ReadingsVal($name, 'device_info-category', 'unknown') eq 'sensor');
|
# readingsBulkUpdate( $hash, 'light-light', '-1' ) if (ReadingsVal($name, 'device_info-category', 'unknown') eq 'sensor');
|
||||||
# }
|
# }
|
||||||
readingsBulkUpdate($hash, 'state', $online_state eq 'online' ? $state_string : 'offline' )
|
readingsBulkUpdate( $hash, 'state',
|
||||||
|
$online_state eq 'online' ? $state_string : 'offline' );
|
||||||
}
|
}
|
||||||
|
|
||||||
readingsBulkUpdate(
|
readingsBulkUpdate(
|
||||||
@ -730,10 +889,6 @@ sub WriteReadings {
|
|||||||
ReadingsVal( $name, 'power-power_timer', 'no info from power-timer' ) )
|
ReadingsVal( $name, 'power-power_timer', 'no info from power-timer' ) )
|
||||||
if ( AttrVal( $name, 'model', 'unknown' ) eq 'power' );
|
if ( AttrVal( $name, 'model', 'unknown' ) eq 'power' );
|
||||||
|
|
||||||
readingsEndUpdate( $hash, 1 );
|
|
||||||
|
|
||||||
Log3 $name, 4, "GardenaSmartDevice ($name) - readings was written";
|
|
||||||
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -843,7 +998,8 @@ sub ReadingLangGerman {
|
|||||||
'closed' => 'geschlossen',
|
'closed' => 'geschlossen',
|
||||||
'included' => 'inbegriffen',
|
'included' => 'inbegriffen',
|
||||||
'active' => 'aktiv',
|
'active' => 'aktiv',
|
||||||
'inactive' => 'nicht aktiv'
|
'inactive' => 'nicht aktiv',
|
||||||
|
'hibernate' => 'Winterschlaf',
|
||||||
);
|
);
|
||||||
|
|
||||||
if (
|
if (
|
||||||
@ -969,6 +1125,7 @@ sub SetPredefinedStartPoints {
|
|||||||
|
|
||||||
$payload = '"settings": ' . encode_json($decode_json_settings);
|
$payload = '"settings": ' . encode_json($decode_json_settings);
|
||||||
$abilities = 'mower_settings';
|
$abilities = 'mower_settings';
|
||||||
|
|
||||||
#$abilities['service_id'] = $hash->{helper}{STARTINGPOINTID};
|
#$abilities['service_id'] = $hash->{helper}{STARTINGPOINTID};
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
@ -1125,6 +1282,10 @@ sub SetPredefinedStartPoints {
|
|||||||
<a name="GardenaSmartDeviceset"></a>
|
<a name="GardenaSmartDeviceset"></a>
|
||||||
<b>set</b>
|
<b>set</b>
|
||||||
<ul>
|
<ul>
|
||||||
|
<li>winter_mode - awake | hibernate</li>
|
||||||
|
</ul>
|
||||||
|
<ul>
|
||||||
|
<h3>mower</h3>
|
||||||
<li>parkUntilFurtherNotice</li>
|
<li>parkUntilFurtherNotice</li>
|
||||||
<li>parkUntilNextTimer</li>
|
<li>parkUntilNextTimer</li>
|
||||||
<li>startOverrideTimer - (in minutes, 60 = 1h, 1440 = 24h, 4320 = 72h)</li>
|
<li>startOverrideTimer - (in minutes, 60 = 1h, 1440 = 24h, 4320 = 72h)</li>
|
||||||
@ -1134,10 +1295,14 @@ sub SetPredefinedStartPoints {
|
|||||||
<li>set NAME startpoint enable 1</li>
|
<li>set NAME startpoint enable 1</li>
|
||||||
<li>set NAME startpoint disable 3 enable 1</li>
|
<li>set NAME startpoint disable 3 enable 1</li>
|
||||||
</ul>
|
</ul>
|
||||||
|
<h3>irrigation control</h3>
|
||||||
<li>resumeScheduleValve - start schedule irrigation on valve n</li>
|
<li>resumeScheduleValve - start schedule irrigation on valve n</li>
|
||||||
<li>stopScheduleValve - stop schedule irrigation on valve n (Default: 2040-12-31T22:00:00.000Z) | optional params hours (now + hours)</li>
|
<li>stopScheduleValve - stop schedule irrigation on valve n (Default: 2038-01-18T00:00:00.000Z) | optional params hours (now + hours)</li>
|
||||||
<li>closeAllValves - close all valves</li>
|
<li>closeAllValves - close all valves</li>
|
||||||
|
<h3>water control</h3>
|
||||||
|
<li>manualButtonTime - set manual time for button press (in minutes) 0 disable button</li>
|
||||||
|
<li>stopSchedule - stop schedule for now + n hours (Default: 2038-01-18T00:00:00.000Z)</li>
|
||||||
|
<li>resumeSchedule - resume schedule</li>
|
||||||
</ul>
|
</ul>
|
||||||
</ul>
|
</ul>
|
||||||
|
|
||||||
@ -1273,6 +1438,10 @@ sub SetPredefinedStartPoints {
|
|||||||
<a name="GardenaSmartDeviceset"></a>
|
<a name="GardenaSmartDeviceset"></a>
|
||||||
<b>set</b>
|
<b>set</b>
|
||||||
<ul>
|
<ul>
|
||||||
|
<li>winter_mode - aufwäcken (awake)| winterschlaf (hibernate)</li>
|
||||||
|
</ul>
|
||||||
|
<ul>
|
||||||
|
<h3>mäher</h3>
|
||||||
<li>parkUntilFurtherNotice - Parken des Mähers unter Umgehung des Zeitplans</li>
|
<li>parkUntilFurtherNotice - Parken des Mähers unter Umgehung des Zeitplans</li>
|
||||||
<li>parkUntilNextTimer - Parken bis zum nächsten Zeitplan</li>
|
<li>parkUntilNextTimer - Parken bis zum nächsten Zeitplan</li>
|
||||||
<li>startOverrideTimer - Manuelles mähen (in Minuten, 60 = 1h, 1440 = 24h, 4320 = 72h)</li>
|
<li>startOverrideTimer - Manuelles mähen (in Minuten, 60 = 1h, 1440 = 24h, 4320 = 72h)</li>
|
||||||
@ -1282,9 +1451,14 @@ sub SetPredefinedStartPoints {
|
|||||||
<li>set NAME startpoint enable 1</li>
|
<li>set NAME startpoint enable 1</li>
|
||||||
<li>set NAME startpoint disable 3 enable 1</li>
|
<li>set NAME startpoint disable 3 enable 1</li>
|
||||||
</ul>
|
</ul>
|
||||||
|
<h3>irrigation control</h3>
|
||||||
<li>resumeScheduleValve - Startet Bew&aauml;sserung am Ventil n nach Zeitplan</li>
|
<li>resumeScheduleValve - Startet Bew&aauml;sserung am Ventil n nach Zeitplan</li>
|
||||||
<li>stopScheduleValve - Setzt Bew&aauml;sserung am Ventil n aus (Default: 2040-12-31T22:00:00.000Z) | Optionaler Parameter Stunden (Jetzt + Stunden)</li>
|
<li>stopScheduleValve - Setzt Bew&aauml;sserung am Ventil n aus (Default: 2038-01-18T00:00:00.000Z) | Optionaler Parameter Stunden (Jetzt + Stunden)</li>
|
||||||
<li>closeAllValves - Stopt Bew&aauml;sserung an allen Ventilen </li>
|
<li>closeAllValves - Stopt Bew&aauml;sserung an allen Ventilen </li>
|
||||||
|
<h3>water control</h3>
|
||||||
|
<li>manualButtonTime - setzt die Dauer für den manuellen Knopf (in Minuten) 0 Schaltet den Knopf aus</li>
|
||||||
|
<li>stopSchedule - Halte Zeitplan an für x Stunden - (Default: 2038-01-18T00:00:00.000Z)</li>
|
||||||
|
<li>resumeSchedule - Weiterführung des Zeitplans</li>
|
||||||
</ul>
|
</ul>
|
||||||
</ul>
|
</ul>
|
||||||
|
|
||||||
@ -1307,9 +1481,9 @@ sub SetPredefinedStartPoints {
|
|||||||
],
|
],
|
||||||
"release_status": "stable",
|
"release_status": "stable",
|
||||||
"license": "GPL_2",
|
"license": "GPL_2",
|
||||||
"version": "v2.4.0",
|
"version": "v2.4.3",
|
||||||
"author": [
|
"author": [
|
||||||
"Marko Oldenburg <leongaultier@gmail.com>"
|
"Marko Oldenburg <fhemdevelopment@cooltux.net>"
|
||||||
],
|
],
|
||||||
"x_fhem_maintainer": [
|
"x_fhem_maintainer": [
|
||||||
"CoolTux"
|
"CoolTux"
|
||||||
|
@ -1,2 +1,2 @@
|
|||||||
UPD 2021-05-22_04:53:56 46135 FHEM/73_GardenaSmartBridge.pm
|
UPD 2022-02-01_18:41:32 49520 FHEM/73_GardenaSmartBridge.pm
|
||||||
UPD 2021-05-22_04:54:14 51644 FHEM/74_GardenaSmartDevice.pm
|
UPD 2022-02-09_13:50:50 57267 FHEM/74_GardenaSmartDevice.pm
|
||||||
|
Reference in New Issue
Block a user