diff options
Diffstat (limited to 'src/server/updateSearch.ts')
-rw-r--r-- | src/server/updateSearch.ts | 22 |
1 files changed, 17 insertions, 5 deletions
diff --git a/src/server/updateSearch.ts b/src/server/updateSearch.ts index de1fd25e1..f5de00978 100644 --- a/src/server/updateSearch.ts +++ b/src/server/updateSearch.ts @@ -6,8 +6,8 @@ import pLimit from 'p-limit'; const suffixMap: { [type: string]: (string | [string, string | ((json: any) => any)]) } = { "number": "_n", "string": "_t", - // "boolean": "_b", - // "image": ["_t", "url"], + "boolean": "_b", + "image": ["_t", "url"], "video": ["_t", "url"], "pdf": ["_t", "url"], "audio": ["_t", "url"], @@ -92,9 +92,21 @@ async function update() { } } await cursor.forEach(updateDoc); - await Promise.all(updates.map(update => { - return limit(() => Search.Instance.updateDocument(update)); - })); + for (let i = 0; i < updates.length; i++) { + console.log(i); + const result = await Search.Instance.updateDocument(updates[i]); + try { + console.log(JSON.parse(result).responseHeader.status); + } catch { + console.log("Error:"); + console.log(updates[i]); + console.log(result); + console.log("\n"); + } + } + // await Promise.all(updates.map(update => { + // return limit(() => Search.Instance.updateDocument(update)); + // })); cursor.close(); } |