🤯 Added a ES indice delete endpoint

services/library.service.ts

@@ -547,25 +547,25 @@ export default class ImportService extends Service {
 				flushDB: {
 					rest: "POST /flushDB",
 					params: {},
-					async handler(ctx: Context<{}>) {
+					handler: async (ctx: Context<{}>) => {
 						return await Comic.collection
 							.drop()
-							.then((data) => {
+							.then(async (data) => {
 								console.info(data);
-								const foo = fsExtra.emptyDirSync(
+								const coversFolderDeleteResult = fsExtra.emptyDirSync(
 									path.resolve(`${USERDATA_DIRECTORY}/covers`)
 								);
-								const foo2 = fsExtra.emptyDirSync(
+								const  expandedFolderDeleteResult = fsExtra.emptyDirSync(
 									path.resolve(
 										`${USERDATA_DIRECTORY}/expanded`
 									)
 								);
-								return { data, foo, foo2 };
+								const eSIndicesDeleteResult = await ctx.broker.call("search.deleteElasticSearchIndices", {});
+								return { data, coversFolderDeleteResult, expandedFolderDeleteResult, eSIndicesDeleteResult };
 							})
 							.catch((error) => error);
 					},
 				},
-
 				unrarArchive: {
 					rest: "POST /unrarArchive",
 					params: {},

services/search.service.ts

@@ -69,10 +69,11 @@ export default class SettingsService extends Service {
 									};
 									pagination: {
 										size: number;
-										from: number,
+										from: number;
 									};
 								}>
 							) => {
+								try {
 									console.log(ctx.params);
 									const { query, pagination } = ctx.params;
 									let eSQuery = {};
@@ -83,7 +84,11 @@ export default class SettingsService extends Service {
 									} else {
 										Object.assign(eSQuery, {
 											multi_match: {
-											fields: ["rawFileDetails.name", "sourcedMetadata.comicvine.name", "sourcedMetadata.comicvine.volumeInformation.name"],
+												fields: [
+													"rawFileDetails.name",
+													"sourcedMetadata.comicvine.name",
+													"sourcedMetadata.comicvine.volumeInformation.name",
+												],
 												query: query.volumeName,
 											},
 										});
@@ -101,6 +106,18 @@ export default class SettingsService extends Service {
 									);
 
 									return result;
+								} catch (error) {
+									return new Errors.MoleculerClientError("Failed to return data", 404, "ElasticSearch error", error);
+								}
+							},
+						},
+						deleteElasticSearchIndices: {
+							rest: "GET /deleteElasticSearchIndices",
+							params: {},
+							handler: async (ctx: Context<{}>) => {
+								return await eSClient.indices.delete({
+									index: "comics",
+								});
 							},
 						},
 					},