hrms-bangkok/hrms-edm
7
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

feat: update/delete drawer

Browse source 
Also included subfolder and file
This commit is contained in:
Methapon2001 2023-11-17 11:09:47 +07:00
parent 5a120dce76
commit ea40c17796
No known key found for this signature in database
GPG key ID: 849924FEF46BD132
1 changed files with 57 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

59
Prototype/server/src/controllers/cabinetController.ts
View file

@ -2,7 +2,6 @@ import {
Body,
Controller,
Delete,
Example,
Get,
Path,
Post,
@ -10,7 +9,6 @@ import {
Route,
Security,
SuccessResponse,
Response,
Tags,
} from "tsoa";
import * as Minio from "minio";
@ -130,4 +128,61 @@ export class CabinetController extends Controller {
this.setStatus(HttpStatusCode.CREATED);
return;
}
@Put("/{cabinetName}/drawer/{drawerName}")
@Tags("Drawer")
@SuccessResponse(HttpStatusCode.NO_CONTENT, "Success")
public async editDrawer(
@Path() cabinetName: string,
@Path() drawerName: string,
@Body() body: { name: string },
): Promise<void> {
const fullpath = `${cabinetName}/${drawerName}/`;
return new Promise((resolve, reject) => {
const stream = minioClient.listObjectsV2("ehr", fullpath, true);
stream.on("data", (v) => {
if (!(v && v.name)) return;
const destination = `${cabinetName}/${body.name}/${v.name.slice(fullpath.length)}`;
const source = `/ehr/${v.name}`;
const cond = new Minio.CopyConditions();
minioClient.copyObject("ehr", destination, source, cond, (e) => {
if (e) {
return reject(new Error("Failed to move."));
}
return minioClient.removeObject("ehr", v.name);
});
});
stream.on("end", () => {
this.setStatus(HttpStatusCode.NO_CONTENT);
resolve();
});
stream.on("error", () => reject(new Error("Object storage error occured.")));
});
}
@Delete("/{cabinetName}/drawer/{drawerName}")
@Tags("Drawer")
@SuccessResponse(HttpStatusCode.OK)
public async deleteDrawer(@Path() cabinetName: string, @Path() drawerName: string) {
return new Promise((resolve, reject) => {
const objects: string[] = [];
const stream = minioClient.listObjectsV2("ehr", `${cabinetName}/${drawerName}/`, true);
stream.on("data", (v) => {
if (!(v && v.name)) return;
objects.push(v.name);
});
stream.on("close", () => minioClient.removeObjects("ehr", objects));
stream.on("error", () => reject(new Error("Object storage error occured.")));
resolve(true);
});
}
}