From 346442dbf5a610ea7ecb4ebeb5d3f01de6e902dd Mon Sep 17 00:00:00 2001
From: Fritz Ray <fritz.ray@eduworks.com>
Date: Tue, 21 Nov 2023 15:41:28 -0800
Subject: [PATCH] Sped up multiput.

---
 src/main/server/skyRepo.js | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/src/main/server/skyRepo.js b/src/main/server/skyRepo.js
index 48bd23021..d902d9afc 100644
--- a/src/main/server/skyRepo.js
+++ b/src/main/server/skyRepo.js
@@ -8725,7 +8725,7 @@ let skyrepoPutInternalIndexBulk = global.skyrepoPutInternalIndexBulk = async fun
     let recordsToGet = [...response.items];
     let oldIndexRecords = [];
     while (recordsToGet.length > 0)
-        oldIndexRecords.push(...(await skyrepoManyGetIndexRecords(recordsToGet.splice(0, 10).filter((x) => !x.index.error && x.index._index !== 'permanent').map((x) => {
+        oldIndexRecords.push(...(await skyrepoManyGetIndexRecords.call(this, recordsToGet.splice(0, 1000).filter((x) => !x.index.error && x.index._index !== 'permanent').map((x) => {
             let obj = x.index;
             const erld = new EcRemoteLinkedData(null, null);
             erld.copyFrom(map[obj._id].object);
@@ -8942,7 +8942,7 @@ let skyrepoManyGetIndexRecords = async function (ary) {
         return [];
     }
     let hashIds = ary.map((x) => EcCrypto.md5(x));
-    let microSearchUrl = elasticEndpoint + '/_search?version&q=';
+    let microSearchUrl = "";
     for (let id of ary) {
         microSearchUrl += '@id:"' + id + '" OR ';
     }
@@ -8953,7 +8953,11 @@ let skyrepoManyGetIndexRecords = async function (ary) {
         }
     }
 
-    const microSearch = await httpGet(microSearchUrl, true, elasticHeaders());
+    const searchParameters = await (searchObj).call(this, microSearchUrl, null, 10000);
+    if (skyrepoDebug) {
+        global.auditLogger.report(global.auditLogger.LogCategory.NETWORK, global.auditLogger.Severity.DEBUG, 'SkyrepSearch', JSON.stringify(searchParameters));
+    }
+    const microSearch = await httpPost(searchParameters, searchUrl(), 'application/json', false, null, null, true, elasticHeaders());
 
     if (skyrepoDebug) {
         global.auditLogger.report(global.auditLogger.LogCategory.NETWORK, global.auditLogger.Severity.DEBUG, 'SkyrepManyGetIndexRecords', microSearchUrl);