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

Compare commits

base: FHEM:patch-fixCheckAndRenewToken
Branches Tags
FHEM:dev FHEM:patch-fixCheckAndRenewToken FHEM:master FHEM:testing
..
compare: FHEM:testing
Branches Tags
FHEM:patch-fixCheckAndRenewToken FHEM:master FHEM:testing FHEM:dev

1 Commits
patch-fixC ... testing

Author SHA1 Message Date
Marko Oldenburg
3722ecab7c Merge pull request 'devel' (#9) from devel into testing 
Reviewed-on: #9
 2021-07-05 13:15:14 +02:00
3 changed files with 387 additions and 333 deletions
Expand all files Collapse all files

27
FHEM/46_TeslaPowerwall2AC.pm
View File

@@ -1,8 +1,8 @@
############################################################################### ###############################################################################
# #
# Developed with VSCodium and richterger perl plugin. # Developed with Kate
# #
# (c) 2017-2023 Copyright: Marko Oldenburg (fhemdevelopment at cooltux dot net) # (c) 2017-2021 Copyright: Marko Oldenburg (fhemdevelopment at cooltux dot net)
# All rights reserved # All rights reserved
# #
# This script is free software; you can redistribute it and/or modify # This script is free software; you can redistribute it and/or modify
@@ -56,19 +56,21 @@ package FHEM::TeslaPowerwall2AC;
use strict; use strict;
use warnings; use warnings;
use FHEM::Meta; use FHEM::Meta;
require FHEM::Devices::Tesla::Powerwall; use GPUtils qw(GP_Export);
use GPUtils qw(GP_Import); require FHEM::Devices::Tesla::Powerwall;
#-- Run before package compilation #-- Run before package compilation
BEGIN { BEGIN {
#-- Export to main context with different name
GP_Import(qw( readingFnAttributes ));
}
sub ::TeslaPowerwall2AC_Initialize { goto &Initialize } #-- Export to main context with different name
GP_Export(
qw(
Initialize
)
);
}
sub Initialize { sub Initialize {
@@ -87,7 +89,7 @@ sub Initialize {
. 'disable:1 ' . 'disable:1 '
. 'devel:1 ' . 'devel:1 '
. 'emailaddr ' . 'emailaddr '
. $readingFnAttributes; . $::readingFnAttributes;
$hash->{parseParams} = 1; $hash->{parseParams} = 1;
@@ -96,6 +98,7 @@ sub Initialize {
1; 1;
=pod =pod
=item device =item device
@@ -196,9 +199,9 @@ sub Initialize {
], ],
"release_status": "stable", "release_status": "stable",
"license": "GPL_2", "license": "GPL_2",
"version": "v2.1.0", "version": "v2.0.0",
"author": [ "author": [
"Marko Oldenburg <fhemdevelopment@cooltux.net>" "Marko Oldenburg <leongaultier@gmail.com>"
], ],
"x_fhem_maintainer": [ "x_fhem_maintainer": [
"CoolTux" "CoolTux"

4
controls_TeslaPowerwall2AC.txt
View File

@@ -1,2 +1,2 @@
UPD 2023-11-11_18:10:27 6874 FHEM/46_TeslaPowerwall2AC.pm UPD 2021-04-23_08:24:15 6944 FHEM/46_TeslaPowerwall2AC.pm
UPD 2023-11-11_18:10:25 28434 lib/FHEM/Devices/Tesla/Powerwall.pm UPD 2021-07-05_13:05:54 29269 lib/FHEM/Devices/Tesla/Powerwall.pm

477
lib/FHEM/Devices/Tesla/Powerwall.pm
View File

@@ -1,8 +1,8 @@
############################################################################### ###############################################################################
# #
# Developed with VSCodium and richterger perl plugin # Developed with Kate
# #
# (c) 2016-2021 Copyright: Marko Oldenburg (fhemdevelopment at cooltux dot net) # (c) 2017-2021 Copyright: Marko Oldenburg (fhemdevelopment at cooltux dot net)
# All rights reserved # All rights reserved
# #
# This script is free software; you can redistribute it and/or modify # This script is free software; you can redistribute it and/or modify
@@ -56,20 +56,10 @@ package FHEM::Devices::Tesla::Powerwall;
use strict; use strict;
use warnings; use warnings;
use experimental qw( switch );
use HttpUtils; use HttpUtils;
use GPUtils qw(GP_Import);
use FHEM::Core::Authentication::Passwords qw(:ALL); use FHEM::Core::Authentication::Passwords qw(:ALL);
BEGIN { use Data::Dumper;
# Import from main context
GP_Import(
qw( init_done
defs
)
);
}
# 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
@@ -77,11 +67,15 @@ 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'
@@ -90,7 +84,10 @@ eval {
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 ...
@@ -98,7 +95,10 @@ eval {
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 ...
@@ -106,7 +106,10 @@ eval {
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 ...
@@ -114,17 +117,21 @@ eval {
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;
}; }
}; }
}; }
}; }
}; }
my %paths = ( my %paths = (
'statussoe' => 'system_status/soe', 'statussoe' => 'system_status/soe',
@@ -148,12 +155,9 @@ my %cmdPaths = (
sub Define { sub Define {
my $hash = shift; my $hash = shift;
my $aArg = shift; my $aArg = shift;
my $version;
return $@ unless ( FHEM::Meta::SetInternals($hash) ); return $@ unless ( FHEM::Meta::SetInternals($hash) );
use version 0.60; our $VERSION = FHEM::Meta::Get( $hash, 'version' );
$version = FHEM::Meta::Get( $hash, 'version' );
our $VERSION = $version;
return q{too few parameters: define <name> TeslaPowerwall2AC <HOST>} return q{too few parameters: define <name> TeslaPowerwall2AC <HOST>}
if ( scalar( @{$aArg} ) != 3 ); if ( scalar( @{$aArg} ) != 3 );
@@ -169,12 +173,30 @@ sub Define {
::CommandAttr( undef, $name . q{ room Tesla} ) ::CommandAttr( undef, $name . q{ room Tesla} )
if ( ::AttrVal( $name, 'room', 'none' ) eq 'none' ); if ( ::AttrVal( $name, 'room', 'none' ) eq 'none' );
::Log3 $name, 3, ::Log3($name, 3,
"TeslaPowerwall2AC ($name) - defined TeslaPowerwall2AC Device with Host $host and Interval $hash->{INTERVAL}"; qq(TeslaPowerwall2AC ($name) - defined TeslaPowerwall2AC Device with Host $host and Interval $hash->{INTERVAL}));
### create password object to handle pass keystore ### create password object to handle pass keystore
$hash->{helper}->{passObj} = $hash->{helper}->{passObj} = FHEM::Core::Authentication::Passwords->new($hash->{TYPE});
FHEM::Core::Authentication::Passwords->new( $hash->{TYPE} );
## kann nach einiger Zeit gelöscht werden genauso wie auch ReadPassword und DeletePassword
if ( defined( ReadPassword( $hash, $name ) ) ) {
my ($passResp,$passErr);
($passResp,$passErr) = $hash->{helper}->{passObj}->setStorePassword($name,ReadPassword( $hash, $name ));
::Log3($name, 1,
qq(TeslaPowerwall2AC ($name) - error while saving the password - $passErr))
if ( !defined($passResp)
and defined($passErr) );
::Log3($name, 1,
qq(TeslaPowerwall2AC ($name) - password successfully saved))
if ( defined($passResp)
and !defined($passErr) );
DeletePassword($hash);
}
return; return;
} }
@@ -184,24 +206,24 @@ sub Undef {
my $name = shift; my $name = shift;
::RemoveInternalTimer($hash); ::RemoveInternalTimer($hash);
::Log3 $name, 3, "TeslaPowerwall2AC ($name) - Device $name deleted"; ::Log3($name, 3, qq(TeslaPowerwall2AC ($name) - Device $name deleted));
return; return;
} }
sub Attr { sub Attr {
my ( $cmd, $name, $attrName, $attrVal ) = @_; my ( $cmd, $name, $attrName, $attrVal ) = @_;
my $hash = $defs{$name}; my $hash = $::defs{$name};
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);
::readingsSingleUpdate( $hash, 'state', 'disabled', 1 ); ::readingsSingleUpdate( $hash, 'state', 'disabled', 1 );
::Log3 $name, 3, "TeslaPowerwall2AC ($name) - disabled"; ::Log3($name, 3, qq(TeslaPowerwall2AC ($name) - disabled));
} }
elsif ( $cmd eq 'del' ) { elsif ( $cmd eq 'del' ) {
::Log3 $name, 3, "TeslaPowerwall2AC ($name) - enabled"; ::Log3($name, 3, qq(TeslaPowerwall2AC ($name) - enabled));
} }
} }
@@ -209,13 +231,13 @@ sub Attr {
if ( $cmd eq 'set' ) { if ( $cmd eq 'set' ) {
return return
'check disabledForIntervals Syntax HH:MM-HH:MM or \'HH:MM-HH:MM HH:MM-HH:MM ...\'' 'check disabledForIntervals Syntax HH:MM-HH:MM or \'HH:MM-HH:MM HH:MM-HH:MM ...\''
unless ( $attrVal =~ /^((\d{2}:\d{2})-(\d{2}:\d{2})\s?)+$/x ); unless ( $attrVal =~ /^((\d{2}:\d{2})-(\d{2}:\d{2})\s?)+$/ );
::Log3 $name, 3, "TeslaPowerwall2AC ($name) - disabledForIntervals"; ::Log3($name, 3, qq(TeslaPowerwall2AC ($name) - disabledForIntervals));
::readingsSingleUpdate( $hash, 'state', 'disabled', 1 ); ::readingsSingleUpdate( $hash, 'state', 'disabled', 1 );
} }
elsif ( $cmd eq 'del' ) { elsif ( $cmd eq 'del' ) {
::Log3 $name, 3, "TeslaPowerwall2AC ($name) - enabled"; ::Log3($name, 3, qq(TeslaPowerwall2AC ($name) - enabled));
::readingsSingleUpdate( $hash, 'state', 'active', 1 ); ::readingsSingleUpdate( $hash, 'state', 'active', 1 );
} }
} }
@@ -223,8 +245,8 @@ sub Attr {
if ( $attrName eq 'interval' ) { if ( $attrName eq 'interval' ) {
if ( $cmd eq 'set' ) { if ( $cmd eq 'set' ) {
if ( $attrVal < 60 ) { if ( $attrVal < 60 ) {
::Log3 $name, 3, ::Log3($name, 3,
"TeslaPowerwall2AC ($name) - interval too small, please use something >= 60 (sec), default is 300 (sec)"; qq(TeslaPowerwall2AC ($name) - interval too small, please use something >= 60 (sec), default is 300 (sec)));
return return
q{interval too small, please use something >= 60 (sec), default is 300 (sec)}; q{interval too small, please use something >= 60 (sec), default is 300 (sec)};
@@ -232,16 +254,16 @@ q{interval too small, please use something >= 60 (sec), default is 300 (sec)};
else { else {
::RemoveInternalTimer($hash); ::RemoveInternalTimer($hash);
$hash->{INTERVAL} = $attrVal; $hash->{INTERVAL} = $attrVal;
::Log3 $name, 3, ::Log3($name, 3,
"TeslaPowerwall2AC ($name) - set interval to $attrVal"; qq(TeslaPowerwall2AC ($name) - set interval to $attrVal));
Timer_GetData($hash); Timer_GetData($hash);
} }
} }
elsif ( $cmd eq 'del' ) { elsif ( $cmd eq 'del' ) {
::RemoveInternalTimer($hash); ::RemoveInternalTimer($hash);
$hash->{INTERVAL} = 300; $hash->{INTERVAL} = 300;
::Log3 $name, 3, ::Log3($name, 3,
"TeslaPowerwall2AC ($name) - set interval to default"; qq(TeslaPowerwall2AC ($name) - set interval to default));
Timer_GetData($hash); Timer_GetData($hash);
} }
} }
@@ -263,14 +285,12 @@ sub Notify {
Timer_GetData($hash) Timer_GetData($hash)
if ( if (
( ( grep /^INITIALIZED$/, @{$events}
grep { /^INITIALIZED$/x } @{$events} or grep /^ATTR.$name.emailaddr$/, @{$events}
or grep { /^ATTR.$name.emailaddr$/x } @{$events} or grep /^DELETEATTR.$name.disable$/, @{$events}
or grep { /^DELETEATTR.$name.disable$/x } @{$events} or grep /^DELETEATTR.$name.interval$/, @{$events}
or grep { /^DELETEATTR.$name.interval$/x } @{$events} or grep /^DEFINED.$name$/, @{$events} )
or grep { /^DEFINED.$name$/x } @{$events} and $::init_done
)
&& $init_done
); );
return; return;
} }
@@ -283,40 +303,65 @@ sub Get {
my $cmd = shift @$aArg // return qq(get $name needs at least one argument); my $cmd = shift @$aArg // return qq(get $name needs at least one argument);
my $arg; my $arg;
$cmd = lc($cmd); if ( $cmd eq 'statusSOE' ) {
$arg = lc($cmd);
}
elsif ( $cmd eq 'aggregates' ) {
$arg = lc($cmd);
}
elsif ( $cmd eq 'siteinfo' ) {
$arg = lc($cmd);
}
elsif ( $cmd eq 'powerwalls' ) {
$arg = lc($cmd);
}
elsif ( $cmd eq 'sitemaster' ) {
$arg = lc($cmd);
}
elsif ( $cmd eq 'registration' ) {
$arg = lc($cmd);
}
elsif ( $cmd eq 'status' ) {
$arg = lc($cmd);
}
else {
given ($cmd) {
when ('statussoe') { $arg = $cmd; }
when ('aggregates') { $arg = $cmd; }
when ('siteinfo') { $arg = $cmd; }
when ('powerwalls') { $arg = $cmd; }
when ('sitemaster') { $arg = $cmd; }
when ('registration') { $arg = $cmd; }
when ('status') { $arg = $cmd; }
default {
my $list = ''; my $list = '';
$list .= $list .=
'statusSOE:noArg aggregates:noArg siteinfo:noArg sitemaster:noArg powerwalls:noArg registration:noArg status:noArg' 'statusSOE:noArg aggregates:noArg siteinfo:noArg sitemaster:noArg powerwalls:noArg registration:noArg status:noArg'
if ( ::AttrVal( $name, 'emailaddr', 'none' ) ne 'none' if( ::AttrVal($name,'emailaddr','none') ne 'none'
&& exists( $hash->{helper}->{passObj} ) && exists($hash->{helper}->{passObj})
&& defined( $hash->{helper}->{passObj}->getReadPassword($name) ) && defined($hash->{helper}->{passObj}->getReadPassword($name))
&& defined( $hash->{TOKEN} ) ); && defined($hash->{TOKEN}) );
return 'Unknown argument ' . $cmd . ', choose one of ' . $list; return 'Unknown argument ' . $cmd . ', choose one of ' . $list;
} }
}
return 'There are still path commands in the action queue' return 'There are still path commands in the action queue'
if ( defined( $hash->{actionQueue} ) if ( defined( $hash->{actionQueue} )
&& scalar( @{ $hash->{actionQueue} } ) > 0 ); && scalar( @{ $hash->{actionQueue} } ) > 0 );
unshift @{ $hash->{actionQueue} }, $arg; unshift( @{ $hash->{actionQueue} }, $arg );
Write($hash); Write($hash);
return; return;
} }
sub Set { ## no critic (Subroutine with high complexity score) sub Set {
my $hash = shift; my $hash = shift;
my $aArg = shift; my $aArg = shift;
my $hArg = shift; my $hArg = shift;
@@ -325,63 +370,57 @@ sub Set { ## no critic (Subroutine with high complexity score)
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 $arg; my $arg;
if ( $cmd eq 'powerwalls' ) { if ( $cmd eq 'powerwalls' ) {
$arg = lc( $cmd . $aArg->[0] ); $arg = lc( $cmd . $aArg->[0] );
} }
elsif ( lc $cmd eq 'setpassword' ) { elsif ( lc $cmd eq 'setpassword' ) {
return q{please set Attribut emailaddr first} return q{please set Attribut emailaddr first}
if ( ::AttrVal( $name, 'emailaddr', 'none' ) eq 'none' ); if ( ::AttrVal( $name, 'emailaddr', 'none' ) eq 'none' );
return qq(usage: $cmd pass=<password>) if ( scalar( @{$aArg} ) != 0
return qq(usage: $cmd pass=<password>) || scalar(keys %{$hArg}) != 1 );
if ( scalar( @{$aArg} ) != 0 my ($passResp,$passErr);
|| scalar( keys %{$hArg} ) != 1 ); ($passResp,$passErr) = $hash->{helper}->{passObj}->setStorePassword($name,$hArg->{'pass'});
my ( $passResp, $passErr );
( $passResp, $passErr ) = $hash->{helper}->{passObj}
->setStorePassword( $name, $hArg->{'pass'} );
return qq{error while saving the password - $passErr} return qq{error while saving the password - $passErr}
if (!defined($passResp) if ( !defined($passResp)
&& defined($passErr) ); and defined($passErr) );
return Timer_GetData($hash) return Timer_GetData($hash)
if ( defined($passResp) if ( defined($passResp)
&& !defined($passErr) ); and !defined($passErr) );
} }
elsif ( lc $cmd eq 'removepassword' ) { elsif ( lc $cmd eq 'removepassword' ) {
return "usage: $cmd" if ( scalar( @{$aArg} ) != 0 ); return "usage: $cmd" if ( scalar( @{$aArg} ) != 0 );
my ( $passResp, $passErr ); my ($passResp,$passErr);
( $passResp, $passErr ) = ($passResp,$passErr) = $hash->{helper}->{passObj}->setDeletePassword($name);
$hash->{helper}->{passObj}->setDeletePassword($name);
return qq{error while saving the password - $passErr} return qq{error while saving the password - $passErr}
if (!defined($passResp) if ( !defined($passResp)
&& defined($passErr) ); and defined($passErr) );
return q{password successfully removed} return q{password successfully removed}
if ( defined($passResp) if ( defined($passResp)
&& !defined($passErr) ); and !defined($passErr) );
} }
else { else {
my $list = ( my $list = ( exists($hash->{helper}->{passObj})
exists( $hash->{helper}->{passObj} ) && defined($hash->{helper}->{passObj}->getReadPassword($name))
&& defined( $hash->{helper}->{passObj}->getReadPassword($name) )
? 'removePassword:noArg ' ? 'removePassword:noArg '
: 'setPassword ' : 'setPassword ');
);
$list .= 'powerwalls:run,stop' $list .= 'powerwalls:run,stop'
if ( ::AttrVal( $name, 'devel', 0 ) == 1 if ( ::AttrVal( $name, 'devel', 0 ) == 1
&& exists( $hash->{helper}->{passObj} ) && exists($hash->{helper}->{passObj})
&& defined( $hash->{helper}->{passObj}->getReadPassword($name) ) && defined($hash->{helper}->{passObj}->getReadPassword($name))
&& defined( $hash->{TOKEN} ) ); && defined($hash->{TOKEN}) );
return 'Unknown argument ' . $cmd . ', choose one of ' . $list; return 'Unknown argument ' . $cmd . ', choose one of ' . $list;
} }
unshift @{ $hash->{actionQueue} }, $arg; unshift( @{ $hash->{actionQueue} }, $arg );
Write($hash); Write($hash);
return; return;
@@ -393,7 +432,7 @@ sub Timer_GetData {
::RemoveInternalTimer($hash); ::RemoveInternalTimer($hash);
if ( exists( $hash->{actionQueue} ) if ( defined( $hash->{actionQueue} )
&& scalar( @{ $hash->{actionQueue} } ) == 0 ) && scalar( @{ $hash->{actionQueue} } ) == 0 )
{ {
if ( !::IsDisabled($name) ) { if ( !::IsDisabled($name) ) {
@@ -402,22 +441,18 @@ sub Timer_GetData {
if ( ::AttrVal( $name, 'emailaddr', 'none' ) eq 'none' ); if ( ::AttrVal( $name, 'emailaddr', 'none' ) eq 'none' );
return ::readingsSingleUpdate( $hash, 'state', return ::readingsSingleUpdate( $hash, 'state',
'please set password first', 1 ) 'please set password first', 1 )
if ( if ( !exists($hash->{helper}->{passObj})
!exists( $hash->{helper}->{passObj} ) || ( exists($hash->{helper}->{passObj})
|| ( && !defined($hash->{helper}->{passObj}->getReadPassword($name))
exists( $hash->{helper}->{passObj} )
&& !defined(
$hash->{helper}->{passObj}->getReadPassword($name)
)
) )
); );
if ( !exists( $hash->{TOKEN} ) ) { if ( !defined( $hash->{TOKEN}) ) {
unshift @{ $hash->{actionQueue} }, 'login'; unshift( @{ $hash->{actionQueue} }, 'login' );
} }
else { else {
while ( my $obj = each %paths ) { while ( my $obj = each %paths ) {
unshift @{ $hash->{actionQueue} }, $obj; unshift( @{ $hash->{actionQueue} }, $obj );
} }
} }
@@ -430,11 +465,8 @@ sub Timer_GetData {
::InternalTimer( ::gettimeofday() + $hash->{INTERVAL}, ::InternalTimer( ::gettimeofday() + $hash->{INTERVAL},
\&FHEM::Devices::Tesla::Powerwall::Timer_GetData, $hash ); \&FHEM::Devices::Tesla::Powerwall::Timer_GetData, $hash );
::Log3($name, 4,
::Log3 $name, 4, qq(TeslaPowerwall2AC ($name) - Call ::InternalTimer Timer_GetData));
"TeslaPowerwall2AC ($name) - Call ::InternalTimer Timer_GetData";
return;
} }
sub Write { sub Write {
@@ -462,15 +494,13 @@ sub Write {
header => $header, header => $header,
hash => $hash, hash => $hash,
setCmd => $path, setCmd => $path,
sslargs => sslargs => { SSL_hostname => 0, verify_hostname => 0, SSL_verify_mode => 0 },
{ SSL_hostname => 0, verify_hostname => 0, SSL_verify_mode => 0 },
doTrigger => 1, doTrigger => 1,
callback => \&ErrorHandling, callback => \&ErrorHandling,
} }
); );
return ::Log3 $name, 4, ::Log3($name, 4, qq(TeslaPowerwall2AC ($name) - Send with URI: https://$uri));
"TeslaPowerwall2AC ($name) - Send with URI: https://$uri";
} }
sub ErrorHandling { sub ErrorHandling {
@@ -491,7 +521,7 @@ sub ErrorHandling {
::readingsBulkUpdate( $hash, 'lastRequestError', $err, 1 ); ::readingsBulkUpdate( $hash, 'lastRequestError', $err, 1 );
::readingsEndUpdate( $hash, 1 ); ::readingsEndUpdate( $hash, 1 );
::Log3 $name, 3, "TeslaPowerwall2AC ($name) - RequestERROR: $err"; ::Log3($name, 3, qq(TeslaPowerwall2AC ($name) - RequestERROR: $err));
$hash->{actionQueue} = []; $hash->{actionQueue} = [];
return; return;
@@ -499,7 +529,7 @@ sub ErrorHandling {
} }
if ( $data eq '' if ( $data eq ''
&& exists( $param->{code} ) && exists($param->{code})
&& $param->{code} != 200 ) && $param->{code} != 200 )
{ {
@@ -508,41 +538,21 @@ sub ErrorHandling {
::readingsBulkUpdate( $hash, 'lastRequestError', $param->{code}, 1 ); ::readingsBulkUpdate( $hash, 'lastRequestError', $param->{code}, 1 );
::Log3 $name, 3, ::Log3($name, 3,
"TeslaPowerwall2AC ($name) - RequestERROR: $param->{code}"; qq(TeslaPowerwall2AC ($name) - RequestERROR: " . $param->{code}));
::readingsEndUpdate( $hash, 1 ); ::readingsEndUpdate( $hash, 1 );
::Log3 $name, 5, ::Log3($name, 5,
"TeslaPowerwall2AC ($name) - RequestERROR: received http code $param->{code} without any data after requesting"; qq(TeslaPowerwall2AC ($name) - RequestERROR: received http code "
. $param->{code}
. " without any data after requesting));
$hash->{actionQueue} = []; $hash->{actionQueue} = [];
return; return;
} }
## Fehler für neuen Token if ( $data =~ m#{"code":(\d+),"error":"(.+)","message":"(.+)"}$# ) {
## {"code":401,"error":"User session not found from HEZwKy9lY17-gLagEdpyzk3IsJgUvrE1XFzmxcw==","message":"Invalid bearer token"}
if ( $data =~ m#{"code":(\d+),"error":"(.+)","message":"(.+)"}\z#xms ) {
if ( $1 == 401
&& $2 =~ m#\AUser\ssession\snot\sfound\sfrom\s.*#xms
&& $3 eq 'Invalid bearer token' )
{
$hash->{actionQueue} = [];
delete $hash->{TOKEN};
unshift @{ $hash->{actionQueue} }, 'login';
::Log3 $name, 1,
"TeslaPowerwall2AC ($name) - Invalid bearer token. Empty action queue";
::Log3 $name, 1,
"TeslaPowerwall2AC ($name) - Invalid bearer token. run relogin";
::Log3 $name, 1,
"TeslaPowerwall2AC ($name) - Invalid bearer token. New action queue "
. join ',', @{ $hash->{actionQueue} };
return Write($hash);
}
::readingsBeginUpdate($hash); ::readingsBeginUpdate($hash);
@@ -562,16 +572,15 @@ sub ErrorHandling {
::readingsEndUpdate( $hash, 1 ); ::readingsEndUpdate( $hash, 1 );
} }
### End Error Handling #### End Error Handling
::InternalTimer( ::gettimeofday() + 3, ::InternalTimer( ::gettimeofday() + 3, \&FHEM::Devices::Tesla::Powerwall::Write, $hash )
\&FHEM::Devices::Tesla::Powerwall::Write, $hash )
if ( defined( $hash->{actionQueue} ) if ( defined( $hash->{actionQueue} )
&& scalar( @{ $hash->{actionQueue} } ) > 0 ); && scalar( @{ $hash->{actionQueue} } ) > 0 );
::Log3 $name, 4, "TeslaPowerwall2AC ($name) - Recieve JSON data: $data"; ::Log3($name, 4, qq(TeslaPowerwall2AC ($name) - Recieve JSON data: $data));
return ResponseProcessing( $hash, $param->{setCmd}, $data ); ResponseProcessing( $hash, $param->{setCmd}, $data );
} }
sub ResponseProcessing { sub ResponseProcessing {
@@ -585,7 +594,7 @@ sub ResponseProcessing {
$decode_json = eval { decode_json($json) }; $decode_json = eval { decode_json($json) };
if ($@) { if ($@) {
::Log3 $name, 4, "TeslaPowerwall2AC ($name) - error while request: $@"; ::Log3($name, 4, qq(TeslaPowerwall2AC ($name) - error while request: $@));
::readingsBeginUpdate($hash); ::readingsBeginUpdate($hash);
::readingsBulkUpdate( $hash, 'JSON Error', $@ ); ::readingsBulkUpdate( $hash, 'JSON Error', $@ );
::readingsBulkUpdate( $hash, 'state', 'JSON error' ); ::readingsBulkUpdate( $hash, 'state', 'JSON error' );
@@ -595,9 +604,9 @@ sub ResponseProcessing {
return return
if ( ref($decode_json) eq 'HASH' if ( ref($decode_json) eq 'HASH'
&& defined( $decode_json->{error} ) && defined($decode_json->{error})
&& $decode_json->{error} && $decode_json->{error}
&& defined( $decode_json->{code} ) && defined($decode_json->{code})
&& $decode_json->{code} ); && $decode_json->{code} );
#### Verarbeitung der Readings zum passenden Path #### Verarbeitung der Readings zum passenden Path
@@ -622,7 +631,7 @@ sub ResponseProcessing {
$readings = $decode_json; $readings = $decode_json;
} }
return WriteReadings( $hash, $path, $readings ); WriteReadings( $hash, $path, $readings );
} }
sub WriteReadings { sub WriteReadings {
@@ -632,7 +641,7 @@ sub WriteReadings {
my $name = $hash->{NAME}; my $name = $hash->{NAME};
::Log3 $name, 4, "TeslaPowerwall2AC ($name) - Write Readings"; ::Log3($name, 4, qq(TeslaPowerwall2AC ($name) - Write Readings));
::readingsBeginUpdate($hash); ::readingsBeginUpdate($hash);
while ( my ( $r, $v ) = each %{$readings} ) { while ( my ( $r, $v ) = each %{$readings} ) {
@@ -648,8 +657,8 @@ sub WriteReadings {
sprintf( sprintf(
"%.1f", "%.1f",
( (
::ReadingsVal( $name, 'siteinfo-nominal_system_energy_kWh', 0 ) ::ReadingsVal( $name, 'siteinfo-nominal_system_energy_kWh', 0 ) /
/ 100 100
) * ::ReadingsVal( $name, 'statussoe-percentage', 0 ) ) * ::ReadingsVal( $name, 'statussoe-percentage', 0 )
) )
); );
@@ -669,8 +678,6 @@ sub WriteReadings {
); );
::readingsEndUpdate( $hash, 1 ); ::readingsEndUpdate( $hash, 1 );
return;
} }
sub ReadingsProcessing_Aggregates { sub ReadingsProcessing_Aggregates {
@@ -702,49 +709,42 @@ sub ReadingsProcessing_Powerwalls {
my %readings; my %readings;
if ( ref($decode_json) eq 'HASH' ) { if ( ref($decode_json) eq 'HASH' ) {
for ( keys %{$decode_json} ) { for (keys %{$decode_json}) {
$readings{$_} = $decode_json->{$_} $readings{$_} = $decode_json->{$_}
if ( ref( $decode_json->{$_} ) ne 'ARRAY' if ( ref($decode_json->{$_}) ne 'ARRAY'
&& defined( $decode_json->{$_} ) ); && defined($decode_json->{$_}) );
if ( ref( $decode_json->{$_} ) eq 'ARRAY' ) { if ( ref($decode_json->{$_}) eq 'ARRAY' ) {
my $i = 0; my $i = 0;
my $r1 = $_; my $r1 = $_;
my $hRef; for my $hRef (@{$decode_json->{$_}}) {
for my $hRef ( @{ $decode_json->{$_} } ) { for (keys %{$hRef}) {
if ( ref($hRef) eq 'HASH' ) { $r1 =~ s/s$//g;
for ( keys %{$hRef} ) {
$r1 =~ s/s$//xg;
$readings{qq(${r1}_${i}_${_})} = $hRef->{$_} $readings{qq(${r1}_${i}_${_})} = $hRef->{$_}
if ( ref( $hRef->{$_} ) ne 'ARRAY' if ( ref($hRef->{$_}) ne 'ARRAY'
&& ref( $hRef->{$_} ) ne 'HASH' && ref($hRef->{$_}) ne 'HASH'
&& defined( $hRef->{$_} ) ); && defined($hRef->{$_}) );
if ( ref( $hRef->{$_} ) eq 'HASH' ) { if ( ref($hRef->{$_}) eq 'HASH' ) {
my $r2 = $_; my $r2 = $_;
my $r3 = $hRef->{$_}; my $r3 = $hRef->{$_};
for ( keys %{$r3} ) { for (keys %{$r3}) {
$readings{qq(${r1}_${i}_${r2}_${_})} = $readings{qq(${r1}_${i}_${r2}_${_})} = $r3->{$_}
$r3->{$_} if ( ref($r3->{$_}) ne 'ARRAY'
if ( ref( $r3->{$_} ) ne 'ARRAY' && defined($r3->{$_}) );
&& defined( $r3->{$_} ) );
if ( ref( $r3->{$_} ) eq 'ARRAY' ) { if ( ref($r3->{$_}) eq 'ARRAY' ) {
my $ii = 0; my $ii = 0;
my $r4 = $_; my $r4 = $_;
for $hRef ( @{ $r3->{$_} } ) { for $hRef (@{$r3->{$_}}) {
for ( keys %{$hRef} ) { for (keys %{$hRef}) {
$r4 =~ s/s$//xg; $r4 =~ s/s$//g;
$readings{ $readings{qq(${r1}_${i}_${r2}_${r4}_${ii}_${_})} = $hRef->{$_}
qq(${r1}_${i}_${r2}_${r4}_${ii}_${_}) if ( ref($hRef->{$_}) ne 'HASH'
} = $hRef->{$_} && defined($hRef->{$_}) );
if (
ref( $hRef->{$_} ) ne 'HASH'
&& defined( $hRef->{$_} ) );
} }
$ii++; $ii++
}
} }
} }
} }
@@ -890,19 +890,12 @@ sub CreateUri {
my $name = $hash->{NAME}; my $name = $hash->{NAME};
my $host = $hash->{HOST}; my $host = $hash->{HOST};
my $header = my $header = ( defined($hash->{TOKEN}) ? 'Cookie: AuthCookie=' . $hash->{TOKEN} : undef );
defined( $hash->{TOKEN} )
? 'Cookie: AuthCookie=' . $hash->{TOKEN}
: undef;
my $method = 'GET'; my $method = 'GET';
my $uri = ( my $uri = ( $path ne 'login' ? $host . '/api/' . $paths{$path} : $host . '/api/login/Basic' );
$path ne 'login'
? $host . '/api/' . $paths{$path}
: $host . '/api/login/Basic'
);
my $data; my $data;
if ( $path eq 'login' ) { if ( $path eq 'login' ) {
$method = 'POST'; $method = 'POST';
$header = 'Content-Type: application/json'; $header = 'Content-Type: application/json';
@@ -910,39 +903,97 @@ sub CreateUri {
'{"username":"customer","password":"' '{"username":"customer","password":"'
. $hash->{helper}->{passObj}->getReadPassword($name) . $hash->{helper}->{passObj}->getReadPassword($name)
. '","email":"' . '","email":"'
. ::AttrVal( $name, 'emailaddr', 'test@test.de' ) . ::AttrVal($name,'emailaddr','test@test.de')
. '","force_sm_off":false}'; . '","force_sm_off":false}'
} }
elsif ($path eq 'powerwallsstop' elsif ( $path eq 'powerwallsstop'
|| $path eq 'powerwallsruns' ) || $path eq 'powerwallsruns' )
{ {
$uri = $host . '/api/' . $cmdPaths{$path}; $uri = $host . '/api/' . $cmdPaths{$path};
} }
return $uri, $method, $header, $data, $path; return ( $uri, $method, $header, $data, $path );
}
### Kann nach einiger Zeit entfernt werden
sub ReadPassword {
my $hash = shift;
my $name = shift;
my $index = $hash->{TYPE} . q{_} . $name . q{_passwd};
my $key = ::getUniqueId() . $index;
my ( $password, $err );
::Log3($name, 4, qq(TeslaPowerwall2AC ($name) - Read password from file));
( $err, $password ) = ::getKeyValue($index);
if ( defined($err) ) {
::Log3($name, 3,
qq(TeslaPowerwall2AC ($name) - unable to read password from file: $err));
return;
}
if ( defined($password) ) {
if ( eval qq(use Digest::MD5;1) ) {
$key = Digest::MD5::md5_hex( unpack "H*", $key );
$key .= Digest::MD5::md5_hex($key);
}
my $dec_pwd = '';
for my $char ( map { pack( 'C', hex($_) ) } ( $password =~ /(..)/g ) ) {
my $decode = chop($key);
$dec_pwd .= chr( ord($char) ^ ord($decode) );
$key = $decode . $key;
}
return $dec_pwd;
}
else {
::Log3($name, 3, qq(TeslaPowerwall2AC ($name) - No password in file));
return;
}
return;
}
#### kann nach einiger Zeit gelöscht werden, entferne auch Code aus der Define Fn
sub DeletePassword {
my $hash = shift;
::setKeyValue( $hash->{TYPE} . q(_) . $hash->{NAME} . q(_passwd), undef );
return;
} }
sub Rename { sub Rename {
my $new = shift; my $new = shift;
my $old = shift; my $old = shift;
my $hash = $defs{$new}; my $hash = $::defs{$new};
my ( $passResp, $passErr ); my ($passResp,$passErr);
( $passResp, $passErr ) = ($passResp,$passErr) = $hash->{helper}->{passObj}->setRename($new,$old);
$hash->{helper}->{passObj}->setRename( $new, $old );
::Log3 $new, 1, ::Log3($new, 1,
"TeslaPowerwall2AC ($new) - error while change the password hash after rename - $passErr" qq(TeslaPowerwall2AC ($new) - error while change the password hash after rename - $passErr))
if (!defined($passResp) if ( !defined($passResp)
&& defined($passErr) ); and defined($passErr) );
::Log3 $new, 1, ::Log3($new, 1,
"TeslaPowerwall2AC ($new) - change password hash after rename successfully" qq(TeslaPowerwall2AC ($new) - change password hash after rename successfully))
if ( defined($passResp) if ( defined($passResp)
&& !defined($passErr) ); and !defined($passErr) );
return; return;
} }
1; 1;