From 1118b4be2d254e2b31a4291a47d8917c41ca1a0a Mon Sep 17 00:00:00 2001
From: Mike Huot <mhuot@opennms.com>
Date: Thu, 23 Nov 2023 10:58:42 -0600
Subject: [PATCH] Moved the node sysoids to new field AllNodesBySysOid to
 prevent mapping explosion

---
 src/elastic.ts | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/src/elastic.ts b/src/elastic.ts
index c70e92b..855883f 100644
--- a/src/elastic.ts
+++ b/src/elastic.ts
@@ -28,12 +28,13 @@ export class Elastic {
 
     public async saveReport(reportName: string, report: any) {
         report["@timestamp"] = new Date().getTime();
-        let nodesSySysOid: any = {};
-        _.each(report["nodesBySysOid"], (number, oid) => {
-            const newID = oid.replace(/\./g, '_');
-            nodesSySysOid[newID] = number;
+        let allNodesBySysOid = Object.entries(report["nodesBySysOid"]).map(([key, value]) => {
+            return { "oid": key, "value": value };
         });
-        report["nodesBySysOid"] = nodesSySysOid;
+    
+        report["AllNodesBySysOid"] = allNodesBySysOid;
+        delete report["nodesBySysOid"];
+
         try {
             await this.httpclient.post(`/${reportName}${Elastic.LOG_SUFFIX}/_doc`, report);
             console.log(`Successfully saved report to log index for report: ${reportName}`);