diff --git a/Services/server/src/controllers/storageController.ts b/Services/server/src/controllers/storageController.ts index cf5b3fe..d6ba6b5 100644 --- a/Services/server/src/controllers/storageController.ts +++ b/Services/server/src/controllers/storageController.ts @@ -462,6 +462,19 @@ export class StorageController extends Controller { stream.on("error", () => reject(new Error(MINIO_ERROR_MESSAGE))); }); + // delete file that is not uploaded + await esClient.deleteByQuery({ + index: DEFAULT_INDEX, + query: { + bool: { + must: { + prefix: { pathname: stripLeadingSlash(`${body.path.join("/")}/`) }, + match: { upload: false }, + }, + }, + }, + }); + io.getInstance()?.emit("FolderDelete", { pathname: body.path.join("/") + "/" }); return this.setStatus(HttpStatusCode.NO_CONTENT);