FHEM/fhem-mirror
2
0
Fork 0
mirror of https://github.com/fhem/fhem-mirror.git synced 2025-04-08 07:24:21 +00:00
Code Issues Releases Wiki Activity

bugfix: parse for MQTT2*

Browse Source 
git-svn-id: https://svn.fhem.de/fhem/trunk@18450 2b470e98-0d58-463d-a4d8-8e2adae1ed80
This commit is contained in:
hexenmeister 2019-01-29 21:47:53 +00:00
parent a662a224e9
commit b79f21cdea
1 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
fhem/FHEM/10_MQTT_GENERIC_BRIDGE.pm
View File

@ -30,6 +30,10 @@
# #
# CHANGE LOG # CHANGE LOG
# #
# 29.01.2019 1.1.3
# bugfix : Parse liefert [NEXT] nur, wenn onmessage wirklich ein array
# geliefert hat, sonst ""
#
# 19.01.2019 1.1.2 # 19.01.2019 1.1.2
# change : in 'Parse' wird als erstes Element '[NEXT]' zurueckgegeben, # change : in 'Parse' wird als erstes Element '[NEXT]' zurueckgegeben,
# damit ggf. weitere Geraete-Module aufgerufen werden # damit ggf. weitere Geraete-Module aufgerufen werden
@ -296,7 +300,7 @@ use warnings;
#my $DEBUG = 1; #my $DEBUG = 1;
my $cvsid = '$Id$'; my $cvsid = '$Id$';
my $VERSION = "version 1.1.1 by hexenmeister\n$cvsid"; my $VERSION = "version 1.1.3 by hexenmeister\n$cvsid";
my %sets = ( my %sets = (
); );
@ -2580,10 +2584,19 @@ sub Parse($$) {
Log3($hash->{NAME},5,"MQTT_GENERIC_BRIDGE: [$hash->{NAME}] Parse ($iiodt : '$ioname'): Msg: $topic => $value"); Log3($hash->{NAME},5,"MQTT_GENERIC_BRIDGE: [$hash->{NAME}] Parse ($iiodt : '$ioname'): Msg: $topic => $value");
#return onmessage($hash, $topic, $value); #return onmessage($hash, $topic, $value);
my @ret = onmessage($hash, $topic, $value); # my @ret = onmessage($hash, $topic, $value);
# unshift(@ret, "[NEXT]"); # damit weitere Geraetemodule ggf. aufgerufen werden
# return @ret;
my $fret = onmessage($hash, $topic, $value);
return "" unless defined $fret;
if( ref($fret) eq 'ARRAY' ) {
my @ret=@{$fret};
unshift(@ret, "[NEXT]"); # damit weitere Geraetemodule ggf. aufgerufen werden unshift(@ret, "[NEXT]"); # damit weitere Geraetemodule ggf. aufgerufen werden
return @ret; return @ret;
} }
Log3($hash->{NAME},1,"MQTT_GENERIC_BRIDGE: [$hash->{NAME}] Parse ($iiodt : '$ioname'): internal error: onmessage returned an unexpected value: ".$fret);
return "";
}
} }
# Routine MQTT-Message Callback # Routine MQTT-Message Callback
@ -2670,7 +2683,7 @@ sub onmessage($$$) {
#updateSubTime($device,$reading); #updateSubTime($device,$reading);
#} #}
} }
return @updatedList if($updated); return \@updatedList if($updated);
return undef; return undef;
} }
1; 1;