diff options
Diffstat (limited to 'src/server/Search.ts')
-rw-r--r-- | src/server/Search.ts | 43 |
1 files changed, 23 insertions, 20 deletions
diff --git a/src/server/Search.ts b/src/server/Search.ts index 25bd8badf..b21ee853a 100644 --- a/src/server/Search.ts +++ b/src/server/Search.ts @@ -4,32 +4,33 @@ import * as rp from 'request-promise'; const pathTo = (relative: string) => `http://localhost:8983/solr/dash/${relative}`; export namespace Search { - export async function updateDocument(document: any) { try { - return await rp.post(pathTo("update"), { + return await rp.post(pathTo('update'), { headers: { 'content-type': 'application/json' }, - body: JSON.stringify([document]) + body: JSON.stringify([document]), }); } catch (e) { // console.warn("Search error: " + e + document); } + return undefined; } export async function updateDocuments(documents: any[]) { try { - return await rp.post(pathTo("update"), { + return await rp.post(pathTo('update'), { headers: { 'content-type': 'application/json' }, - body: JSON.stringify(documents) + body: JSON.stringify(documents), }); } catch (e) { // console.warn("Search error: ", e, documents); } + return undefined; } export async function search(query: any) { try { - const output = await rp.get(pathTo("select"), { qs: query }); + const output = await rp.get(pathTo('select'), { qs: query }); const searchResults = JSON.parse(output); const { docs, numFound } = searchResults.response; const ids = docs.map((field: any) => field.id); @@ -41,16 +42,16 @@ export namespace Search { export async function clear() { try { - await rp.post(pathTo("update"), { + await rp.post(pathTo('update'), { body: { delete: { - query: "*:*" - } + query: '*:*', + }, }, - json: true + json: true, }); } catch (e: any) { - console.log(red("Unable to clear search...")); + console.log(red('Unable to clear search...')); console.log(red(e.message)); } } @@ -63,16 +64,18 @@ export namespace Search { const count = Math.min(docs.length - index, nToDelete); const deleteIds = docs.slice(index, index + count); index += count; - promises.push(rp.post(pathTo("update"), { - body: { - delete: { - query: deleteIds.map(id => `id:"${id}"`).join(" ") - } - }, - json: true - })); + promises.push( + rp.post(pathTo('update'), { + body: { + delete: { + query: deleteIds.map(id => `id:"${id}"`).join(' '), + }, + }, + json: true, + }) + ); } return Promise.all(promises); } -}
\ No newline at end of file +} |