Changeset 11127 in ntrip for trunk/BNC/tests/tools/ssr_harness.cpp

Timestamp:

Oct 24, 2026, 11:15:22 PM (7 days ago)

Author:

stuerze

Message:

test suite extended regardiing security aspects

File:

• trunk/BNC/tests/tools/ssr_harness.cpp (modified) (4 diffs)

trunk/BNC/tests/tools/ssr_harness.cpp

@@ -6 +6 @@
 // struct is a separate heap block here, so a write beyond a struct is
 // reported by AddressSanitizer instead of silently corrupting the next member.
+//
+// Every decoded VTEC (all formats) and metadata message (new RTCM-SSR) is
+// encoded again with the Make* function of the same class and decoded once
+// more; the result must be identical (exit code 1 otherwise).
 //
 // Usage: ssr_harness <file>   (BNC raw file or plain RTCM3 byte stream)
@@ -33 +37 @@
 }
 
+struct t_target {
+  t_target()  : co(new SsrCorr::ClockOrbit()), cb(new SsrCorr::CodeBias()),
+                v(new SsrCorr::VTEC()), pb(new SsrCorr::PhaseBias()),
+                md(new SsrCorr::MetaData()), a(new SsrCorr::Antenna()) {}
+  ~t_target() {delete co; delete cb; delete v; delete pb; delete md; delete a;}
+  int decode(SsrCorr* ssr, const unsigned char* frame, size_t size) {
+    int bytesused = 0;
+    return ssr->GetSSR(co, cb, v, pb, md, a, (const char*)frame, size, &bytesused);
+  }
+  SsrCorr::ClockOrbit* co;
+  SsrCorr::CodeBias*   cb;
+  SsrCorr::VTEC*       v;
+  SsrCorr::PhaseBias*  pb;
+  SsrCorr::MetaData*   md;
+  SsrCorr::Antenna*    a;
+};
+
+static bool sameVTEC(const SsrCorr::VTEC* v1, const SsrCorr::VTEC* v2) {
+  if (v1->EpochTime != v2->EpochTime || v1->NumLayers != v2->NumLayers ||
+      v1->Quality != v2->Quality) {
+    return false;
+  }
+  for (unsigned l = 0; l < v1->NumLayers; l++) {
+    const SsrCorr::VTEC::IonoLayers& l1 = v1->Layers[l];
+    const SsrCorr::VTEC::IonoLayers& l2 = v2->Layers[l];
+    if (l1.Height != l2.Height || l1.Degree != l2.Degree || l1.Order != l2.Order) {
+      return false;
+    }
+    for (unsigned d = 0; d <= l1.Degree; d++) {
+      for (unsigned o = 0; o <= l1.Order; o++) {
+        if (l1.Cosinus[d][o] != l2.Cosinus[d][o] || l1.Sinus[d][o] != l2.Sinus[d][o]) {
+          return false;
+        }
+      }
+    }
+  }
+  return true;
+}
+
+static bool sameMetaData(const SsrCorr::MetaData* m1, const SsrCorr::MetaData* m2) {
+  if (m1->SSRIOD != m2->SSRIOD || m1->SSRProviderID != m2->SSRProviderID ||
+      m1->SSRSolutionID != m2->SSRSolutionID || m1->NumEntries != m2->NumEntries) {
+    return false;
+  }
+  for (unsigned i = 0; i < m1->NumEntries; i++) {
+    if (memcmp(&m1->Entries[i], &m2->Entries[i], sizeof(m1->Entries[i])) != 0) {
+      return false;
+    }
+  }
+  return true;
+}
+
+static int nFailed = 0;
+
+// Decode, print a summary, encode the result again and compare
 static void decode(const char* name, SsrCorr* ssr, const unsigned char* frame, size_t size) {
-  SsrCorr::ClockOrbit* co = new SsrCorr::ClockOrbit();
-  SsrCorr::CodeBias*   cb = new SsrCorr::CodeBias();
-  SsrCorr::VTEC*       v  = new SsrCorr::VTEC();
-  SsrCorr::PhaseBias*  pb = new SsrCorr::PhaseBias();
-  SsrCorr::MetaData*   md = new SsrCorr::MetaData();
-  SsrCorr::Antenna*    a  = new SsrCorr::Antenna();
-  int bytesused = 0;
-
-  int irc = ssr->GetSSR(co, cb, v, pb, md, a, (const char*)frame, size, &bytesused);
+  t_target t1;
+  int irc = t1.decode(ssr, frame, size);
   printf("  %-8s irc %3d", name, irc);
-  if (irc >= 0 && v->NumLayers) {
+  if (irc >= 0 && t1.v->NumLayers) {
     double sum = 0.0;
     printf("  VTEC");
-    for (unsigned l = 0; l < v->NumLayers; l++) {
-      const SsrCorr::VTEC::IonoLayers& layer = v->Layers[l];
+    for (unsigned l = 0; l < t1.v->NumLayers; l++) {
+      const SsrCorr::VTEC::IonoLayers& layer = t1.v->Layers[l];
       printf(" %u/%u", layer.Degree, layer.Order);
       for (unsigned d = 0; d <= layer.Degree; d++) {
@@ -57 +109 @@
     }
     printf("  sum(C-S) %.3f", sum);
+
+    char buffer[CLOCKORBIT_BUFFERSIZE];
+    size_t len = ssr->MakeVTEC(t1.v, 0, buffer, sizeof(buffer));
+    t_target t2;
+    bool ok = len > 0 && t2.decode(ssr, (const unsigned char*)buffer, len) >= 0 && sameVTEC(t1.v, t2.v);
+    printf("  re-encoded: %s", ok ? "identical" : "DIFFERENT");
+    nFailed += !ok;
   }
-  if (irc >= 0 && md->NumEntries) {
-    printf("  META %u entries, additional data", md->NumEntries);
-    for (unsigned i = 0; i < md->NumEntries; i++) {
-      if (md->Entries[i].additionalParameterIndicator) {
-        printf(" %u:0x%x", md->Entries[i].additionalParameterNumBits,
-               md->Entries[i].additionalParameterData);
+  if (irc >= 0 && t1.md->NumEntries) {
+    printf("  META %u entries, additional data", t1.md->NumEntries);
+    for (unsigned i = 0; i < t1.md->NumEntries; i++) {
+      if (t1.md->Entries[i].additionalParameterIndicator) {
+        printf(" %u:0x%x", t1.md->Entries[i].additionalParameterNumBits,
+               t1.md->Entries[i].additionalParameterData);
       }
+    }
+    SsrCorrRtcmNew* rtcmNew = dynamic_cast<SsrCorrRtcmNew*>(ssr);
+    if (rtcmNew) {
+      char buffer[CLOCKORBIT_BUFFERSIZE];
+      size_t len = rtcmNew->MakeMetaData(t1.md, buffer, sizeof(buffer));
+      t_target t2;
+      bool ok = len > 0 && t2.decode(ssr, (const unsigned char*)buffer, len) >= 0 && sameMetaData(t1.md, t2.md);
+      printf("  re-encoded: %s", ok ? "identical" : "DIFFERENT");
+      nFailed += !ok;
     }
   }
   printf("\n");
-
-  delete co; delete cb; delete v; delete pb; delete md; delete a;
 }
 
@@ -111 +177 @@
     ii += len + 6;
   }
+  if (nFailed) {
+    printf("%d decoded messages differ after re-encoding\n", nFailed);
+    return 1;
+  }
   return 0;
 }