aboutsummaryrefslogtreecommitdiff
path: root/src/server/Search.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/server/Search.ts')
-rw-r--r--src/server/Search.ts43
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
+}