github-mirrors/immich
1
0
Fork 0
mirror of https://github.com/immich-app/immich.git synced 2026-05-18 03:10:24 +03:00
Code Issues Packages Projects Releases Wiki Activity

fix abortion return

Browse Source
This commit is contained in:
mertalev
2025-10-08 00:41:47 -04:00
parent 3f1133f9b7
commit 5e07976288
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/src/services/asset-upload.service.ts
+6 -5
View File
@@ -41,13 +41,14 @@ export class AssetUploadService extends BaseService {
@OnEvent({ name: 'UploadAbort', workers: [ImmichWorker.Api] }) @OnEvent({ name: 'UploadAbort', workers: [ImmichWorker.Api] })
onUploadAbort({ assetId, abortTime }: ArgOf<'UploadAbort'>) { onUploadAbort({ assetId, abortTime }: ArgOf<'UploadAbort'>) {
const entry = this.activeRequests.get(assetId); const entry = this.activeRequests.get(assetId);
if (entry && abortTime > entry.startTime) { if (!entry) {
this.activeRequests.delete(assetId);
entry.req.destroy();
return true;
}
return false; return false;
} }
if (abortTime > entry.startTime) {
entry.req.destroy();
}
return this.activeRequests.delete(assetId);
}
async startUpload(auth: AuthDto, req: Readable, res: Response, dto: StartUploadDto): Promise<void> { async startUpload(auth: AuthDto, req: Readable, res: Response, dto: StartUploadDto): Promise<void> {
this.logger.verboseFn(() => `Starting upload: ${JSON.stringify(dto)}`); this.logger.verboseFn(() => `Starting upload: ${JSON.stringify(dto)}`);