diff options
| author | Sam Wilkins <samwilkins333@gmail.com> | 2019-07-01 03:35:47 -0400 |
|---|---|---|
| committer | Sam Wilkins <samwilkins333@gmail.com> | 2019-07-01 03:35:47 -0400 |
| commit | 5373b236dcb83c6d245da1e38c3caf13973b1b95 (patch) | |
| tree | cb86de35577d74d44b97a99809a7a5d02ce28084 /src/server | |
| parent | a2e447925dd9fc9300d1c812cd202acf0de1aa95 (diff) | |
| parent | 707e66f1d934e6b6185d9701a8b5138c0f15c90e (diff) | |
Merge branch 'master' of https://github.com/browngraphicslab/Dash-Web
Diffstat (limited to 'src/server')
| -rw-r--r-- | src/server/index.ts | 4 | ||||
| -rw-r--r-- | src/server/updateSearch.ts | 22 |
2 files changed, 19 insertions, 7 deletions
diff --git a/src/server/index.ts b/src/server/index.ts index e645e29b4..a93940907 100644 --- a/src/server/index.ts +++ b/src/server/index.ts @@ -516,8 +516,8 @@ function GetRefFields([ids, callback]: [string[], (result?: Transferable[]) => v 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"], 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(); } |