FHEM/fhem-mirror
2
0
Fork 0
mirror of https://github.com/fhem/fhem-mirror.git synced 2025-03-15 04:20:56 +00:00
Code Issues Releases Wiki Activity

38_netatmo: new token refresh handling and fallback reading

Browse Source 
git-svn-id: https://svn.fhem.de/fhem/trunk@28982 2b470e98-0d58-463d-a4d8-8e2adae1ed80
This commit is contained in:
moises 2024-06-17 15:05:16 +00:00
parent 6037441979
commit f4d50d6ed0
2 changed files with 19 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
fhem/CHANGED
View File

@ -1,5 +1,6 @@
# Add changes at the top of the list. Keep it in ASCII, and 80-char wide.
# Do not insert empty lines here, update check depends on it
- change: 38_netatmo: new token refresh handling and fallback reading
- bugfix: 76_SolarForecast: fix Warnings
- change: 76_SolarForecast: set moduleAzimuth to attr setupStringAzimuth
set moduleDeclination to setupStringDeclination

25
fhem/FHEM/38_netatmo.pm
View File

@ -11,7 +11,7 @@
#
#
##############################################################################
# Release 30 / 2024-06-08
# Release 31 / 2024-06-17
package main;
@ -449,9 +449,8 @@ netatmo_Define($$)
$hash->{helper}{password} = $password;
$hash->{helper}{client_id} = $client_id;
$hash->{helper}{client_secret} = $client_secret;
$hash->{refresh_token} = $refresh_token if(!defined($hash->{refresh_token}));
$hash->{refresh_token} = $refresh_token;
$hash->{helper}{refresh_token} = $hash->{refresh_token};
$hash->{helper}{refresh_token} = $refresh_token if(!$hash->{helper}{refresh_token});
$hash->{helper}{last_refresh} = 0;
$hash->{helper}{INTERVAL} = 60*60 if( !$hash->{helper}{INTERVAL} );
@ -2916,19 +2915,29 @@ netatmo_dispatch($$$)
Log3 $name, 5, Dumper($json);
if( ref($json) eq "HASH" && $json->{error} ) {
if(ref($json->{error}) ne "HASH") {
if(ref($json->{error}) ne "HASH") { #only error on login/token, error->message on other data communication
$hash->{STATE} = "LOGIN FAILED" if($hash->{SUBTYPE} eq "ACCOUNT");
$hash->{status} = $json->{error};
Log3 $name, 2, "$name: json message error: ".$json->{error};
readingsSingleUpdate( $hash, "active", $hash->{status}, 1 ) if($hash->{status} ne "no data");
if($param->{type} eq "token" && $json->{error} eq "invalid_grant"){
#if($hash->{expires_at} <= int(gettimeofday())){
$hash->{status} = "invalid_grant error";
if($hash->{status} eq "invalid_grant error"){
$hash->{network} = "disconnected" if($hash->{SUBTYPE} eq "ACCOUNT");
CommandDeleteReading( undef, "$hash->{NAME} .refreshtoken" );
$attr{$name}{disable} = "1" if($hash->{SUBTYPE} eq "ACCOUNT");
Log3 $name, 2, "$name: invalid refresh ticket, disabling module";
}
else {
#if($hash->{expires_at} <= int(gettimeofday())){
$hash->{status} = "invalid_grant error";
Log3 $name, 2, "$name: invalid refresh ticket, retrying once";
$hash->{helper}{refresh_token} = ReadingsVal($name, ".refreshtoken", undef);
InternalTimer(gettimeofday()+5, "netatmo_refreshToken", $hash, 0);
#}
}
}
else {
$hash->{status} = $json->{error};
}
return undef;
}
@ -3366,6 +3375,8 @@ netatmo_parseToken($$)
if($old_refresh ne $hash->{refresh_token}){
if($hash->{SUBTYPE} eq "ACCOUNT"){
readingsSingleUpdate( $hash, ".refreshtoken", $json->{refresh_token}, 0 );
my @defarray = split(/ /, $hash->{DEF});
pop(@defarray);
push(@defarray, $json->{refresh_token});