@@ -108,9 +108,9 @@ while (my $mqttMessage = <$SUB> ) {

       if ($queue eq "RESULT"){ # topic nou sonoff v6.2.1 sonoff bridge

         my $decoded = decode_json($json);

         if (exists $decoded->{'RfReceived'}{'Data'}){

-          addRF ($topic, "Data", $decoded->{'RfReceived'}{'Data'});

+          addRF ($topic, $decoded->{'RfReceived'}{'Sync'}, $decoded->{'RfReceived'}{'Low'}, $decoded->{'RfReceived'}{'High'}, $decoded->{'RfReceived'}{'Data'});

         }

-      }            

+      }

       if ($queue eq "ESP"){

         my $decoded = decode_json($json);

         if (exists $decoded->{'Temp'}){     

@@ -238,11 +238,11 @@ sub delDB {

 # adaug/updatez in tabela get433info din baza de date 

 sub addRF {

-  (my $topic, my $camp, my $valoare) = @_;

+  (my $topic, my $sync, my $low, my $high, my $data) = @_;

   (my $user, my $devid) = split /\-/, $topic;

-  my $query = "insert into get433info values (?, ?, ?, ?) on duplicate key update camp=?";

+  my $query = "insert into get433info values (?, ?, ?, ?, ?, ?) on duplicate key update data=?";

   my $sth = $dbh->prepare($query) or die "Can't prepare $query: $dbh->errstr\n";

-  $sth->execute("$user", "$devid", "$camp", "$valoare", "$camp");

+  $sth->execute("$user", "$devid", "$sync", "$low", "$high" "$data", "$data");

   $sth->finish();

   return;

 }