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

Merge branch 'dev/methapon' into development

Browse source
This commit is contained in:
Methapon2001 2023-12-01 11:49:08 +07:00
commit b0afe16fbd
No known key found for this signature in database
GPG key ID: 849924FEF46BD132
2 changed files with 14 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

2
Services/server/src/app.ts
View file

@ -35,4 +35,4 @@ app.listen(PORT, "0.0.0.0", () =>
console.log(`[APP] Application is running on http://localhost:${PORT}`),
);
// rabbitmq.init(amqHandler).catch((e) => console.error(e));
rabbitmq.init(amqHandler).catch((e) => console.error(e));

16
Services/server/src/rabbitmq/handler.ts
View file

@ -21,9 +21,19 @@ export async function handler(key: string, event: string): Promise<boolean> {
}
if (!cachedBuffer[key]) {
const stream = await minioClient.getObject(bucket, pathname);
const buffer = Buffer.concat(await stream.toArray());
cachedBuffer[key] = buffer;
try {
const stream = await minioClient.getObject(bucket, pathname);
const buffer = Buffer.concat(await stream.toArray());
cachedBuffer[key] = buffer;
} catch (e: any) {
if (e.code === "NoSuchKey") {
console.info(`[AMQ] Key: ${key} received but cannot be found.`)
delete cachedBuffer[key];
delete cachedMetadata[key];
await ensureDelete(pathname);
return true;
}
}
}
if (!cachedMetadata[key]) {