allow to show unmapped XDR transducer values

lib/config/GwConverterConfig.h

@@ -71,9 +71,12 @@ class GwConverterConfig{
       int rmcInterval=1000;
       int rmcCheckTime=4000;
       int winst312=256;
+      bool unmappedXdr=false;
+      unsigned long xdrTimeout=60000;
       std::vector<WindMapping> windMappings;
       void init(GwConfigHandler *config, GwLog*logger){
         minXdrInterval=config->getInt(GwConfigDefinitions::minXdrInterval,100);
+        xdrTimeout=config->getInt(GwConfigDefinitions::timoSensor);
         starboardRudderInstance=config->getInt(GwConfigDefinitions::stbRudderI,0);
         portRudderInstance=config->getInt(GwConfigDefinitions::portRudderI,-1);
         min2KInterval=config->getInt(GwConfigDefinitions::min2KInterval,50);
@@ -83,6 +86,7 @@ class GwConverterConfig{
         rmcInterval=config->getInt(GwConfigDefinitions::sendRMCi,1000);
         if (rmcInterval < 0) rmcInterval=0;
         if (rmcInterval > 0 && rmcInterval <100) rmcInterval=100;
+        unmappedXdr=config->getBool(GwConfigDefinitions::unknownXdr);
         winst312=config->getInt(GwConfigDefinitions::winst312,256);
         for (auto && it:windConfigs){
           String cfg=config->getString(it.second);

lib/nmea0183ton2k/NMEA0183DataToN2K.cpp

@@ -189,6 +189,7 @@ private:
         if (N2kIsNA(v)) return N2kInt8NA;
         return v;
     }
+    
     void convertXDR(const SNMEA0183Msg &msg){
         XdrMappingList foundMappings;
         for (int offset=0;offset <= (msg.FieldCount()-4);offset+=4){
@@ -199,7 +200,19 @@ private:
             String unit=msg.Field(offset+2);
             String transducerName=msg.Field(offset+3);
             GwXDRFoundMapping found=xdrMappings->getMapping(transducerName,type,unit);
-            if (found.empty) continue;
+            if (found.empty) {
+                if (config.unmappedXdr){
+                    const GwXDRType *typeDef=xdrMappings->findType(type,unit);
+                    GwXdrUnknownMapping mapping(transducerName,unit,typeDef,config.xdrTimeout);
+                    value=mapping.valueFromXdr(value);
+                    if (boatData->update(value,msg.sourceId,&mapping)){
+                        //TODO: potentially update the format
+                        LOG_DEBUG(GwLog::DEBUG+1,"found unmapped XDR %s:%s, value %f",
+                        transducerName.c_str(),mapping.getBoatItemFormat().c_str(),value);
+                    }
+                }
+                continue;
+            }
             value=found.valueFromXdr(value);
             if (!boatData->update(value,msg.sourceId,&found)) continue;
             LOG_DEBUG(GwLog::DEBUG+1,"found mapped XDR %s:%s, value %f",

lib/xdrmappings/GwXDRMappings.cpp

@@ -58,6 +58,7 @@ GwXDRType *types[] = {
     new GwXDRType(GwXDRType::DISPLACEMENTD, "A", "D",DegToRad,RadToDeg,"rd"),
     new GwXDRType(GwXDRType::RPM,"T","R")
     };
+static GwXDRType genericType(GwXDRType::GENERIC, "G", "");
 template<typename T, int size>
 int GetArrLength(T(&)[size]){return size;}
 static GwXDRType *findType(GwXDRType::TypeCode type, int *start = NULL)
@@ -82,6 +83,19 @@ static GwXDRType *findType(GwXDRType::TypeCode type, int *start = NULL)
     return NULL;
 }
 
+static GwXDRType *findType(const String &typeString, const String &unitString)
+{
+    int len=GetArrLength(types);
+    for (int i=0; i< len; i++)
+    {
+        if (types[i]->xdrtype == typeString && types[i]->xdrunit == unitString)
+        {
+            return types[i];
+        }
+    }
+    return &genericType;
+}
+
 #include "GwXdrTypeMappings.h"
 
 static GwXDRType::TypeCode findTypeMapping(GwXDRCategory category, int field)
@@ -199,7 +213,7 @@ GwXDRMappingDef *GwXDRMappingDef::fromString(String s)
     }
     return rt;
 }
-String GwXDRMappingDef::getTransducerName(int instance)
+String GwXDRMappingDef::getTransducerName(int instance) const
 {
     String name = xdrName;
     if (instanceMode == GwXDRMappingDef::IS_AUTO)
@@ -257,7 +271,7 @@ bool GwXDRMappings::addMapping(GwXDRMappingDef *def)
             LOG_DEBUG(GwLog::ERROR, "no type mapping for %s", def->toString().c_str());
             return false;
         }
-        GwXDRType *type = findType(code, &typeIndex);
+        GwXDRType *type = ::findType(code, &typeIndex);
         if (!type)
         {
             LOG_DEBUG(GwLog::ERROR, "no type definition for %s", def->toString().c_str());
@@ -298,7 +312,7 @@ bool GwXDRMappings::addMapping(GwXDRMappingDef *def)
                 LOG_DEBUG(GwLog::LOG, "append mapping with n183key %s", n183key.c_str());
                 it->second.push_back(mapping);
             }
-            type = findType(code, &typeIndex);
+            type = ::findType(code, &typeIndex);
             if (!type)
                 break;
             mapping = new GwXDRMapping(def, type);
@@ -471,7 +485,7 @@ String GwXDRMappings::getXdrEntry(String mapping, double value,int instance){
     {
         return rt;
     }
-    GwXDRType *type = findType(code, &typeIndex);
+    GwXDRType *type = ::findType(code, &typeIndex);
     bool first=true;
     unsigned long invalidTime=config->getInt(GwConfigDefinitions::timoSensor);
     while (type){
@@ -480,8 +494,12 @@ String GwXDRMappings::getXdrEntry(String mapping, double value,int instance){
         if (first) first=false;
         else rt+=",";
         rt+=found.buildXdrEntry(value).entry;
-        type = findType(code, &typeIndex);
+        type = ::findType(code, &typeIndex);
     }
     delete def;
     return rt;
 }
+
+const GwXDRType * GwXDRMappings::findType(const String &typeString, const String &unitString) const{
+    return ::findType(typeString,unitString);
+}

lib/xdrmappings/GwXDRMappings.h

@@ -140,7 +140,7 @@ class GwXDRMappingDef{
         rt += xdrUnit;
         return rt;
     }
-    String getTransducerName(int instance);
+    String getTransducerName(int instance) const;
     private:
     static bool handleToken(String tok,int index,GwXDRMappingDef *def);
 };
@@ -163,12 +163,12 @@ class GwXDRFoundMapping : public GwBoatItemNameProvider{
             String entry;
             String transducer;
         };
-        GwXDRMappingDef *definition=NULL;
+        const GwXDRMappingDef *definition=NULL;
-        GwXDRType *type=NULL;
+        const GwXDRType *type=NULL;
         int instanceId=-1;
         bool empty=true;
         unsigned long timeout=0;
-        GwXDRFoundMapping(GwXDRMappingDef *definition,GwXDRType *type, unsigned long timeout){
+        GwXDRFoundMapping(const GwXDRMappingDef *definition,const GwXDRType *type, unsigned long timeout){
             this->definition=definition;
             this->type=type;
             this->timeout=timeout;
@@ -182,7 +182,7 @@ class GwXDRFoundMapping : public GwBoatItemNameProvider{
             empty=false;
         }
         GwXDRFoundMapping(){}
-        String getTransducerName(){
+        virtual String getTransducerName(){
             return definition->getTransducerName(instanceId);
         }
         double valueFromXdr(double value){
@@ -203,6 +203,24 @@ class GwXDRFoundMapping : public GwBoatItemNameProvider{
         }
 };
 
+class GwXdrUnknownMapping : public GwXDRFoundMapping{
+    String name;
+    String unit;
+    public:
+    GwXdrUnknownMapping(const String &xdrName, const String &xdrUnit,const GwXDRType *type,unsigned long timeout):
+        name(xdrName),unit(xdrUnit), GwXDRFoundMapping(nullptr,type,timeout){
+
+    }
+    virtual String getTransducerName(){
+        return name;
+    }
+    virtual String getBoatItemFormat(){
+        String rt=GwXDRFoundMapping::getBoatItemFormat();
+        if (type->xdrunit.isEmpty()) rt+=unit;
+        return rt;
+    }
+};
+
 //the class GwXDRMappings is not intended to be deleted
 //the deletion will leave memory leaks!
 class GwConfigHandler;
@@ -229,6 +247,7 @@ class GwXDRMappings{
         GwXDRFoundMapping getMapping(GwXDRCategory category,int selector,int field=0,int instance=-1);
         String getXdrEntry(String mapping, double value,int instance=0);
         const char * getUnMapped();
+        const GwXDRType * findType(const String &typeString, const String &unitString) const;
 
 };
 

web/config.json

@@ -210,6 +210,14 @@
          "description":"send out the converted data on the NMEA2000 bus\nIf set to off the converted data will still be shown at the data tab.",
          "category":"converter"
      },
+     {
+        "name":"unknownXdr",
+        "label":"show unknown XDR",
+        "type":"boolean",
+        "default":"false",
+        "description":"show received XDR transducer values in data display if there is no XDR mapping for them",
+        "category":"converter"
+    },
      {
         "name":"sendRMCi",
         "label":"send RMC interval",