summaryrefslogtreecommitdiff
path: root/packages/backend/src/queue/processors
diff options
context:
space:
mode:
authordakkar <dakkar@thenautilus.net>2025-01-23 12:24:06 +0000
committerdakkar <dakkar@thenautilus.net>2025-01-23 12:24:06 +0000
commitb3d2cd65aab57508dd28050f0b288b3bd95c144a (patch)
tree339b4b0578794c9e76664246ce277a207972e412 /packages/backend/src/queue/processors
parentmerge: Remove node 20 from engines in backend (!867) (diff)
downloadsharkey-b3d2cd65aab57508dd28050f0b288b3bd95c144a.tar.gz
sharkey-b3d2cd65aab57508dd28050f0b288b3bd95c144a.tar.bz2
sharkey-b3d2cd65aab57508dd28050f0b288b3bd95c144a.zip
use `import` configuration for downloads in emoji importer
Diffstat (limited to 'packages/backend/src/queue/processors')
-rw-r--r--packages/backend/src/queue/processors/ImportCustomEmojisProcessorService.ts6
1 files changed, 5 insertions, 1 deletions
diff --git a/packages/backend/src/queue/processors/ImportCustomEmojisProcessorService.ts b/packages/backend/src/queue/processors/ImportCustomEmojisProcessorService.ts
index 17ba71df3d..666a709ab9 100644
--- a/packages/backend/src/queue/processors/ImportCustomEmojisProcessorService.ts
+++ b/packages/backend/src/queue/processors/ImportCustomEmojisProcessorService.ts
@@ -17,6 +17,7 @@ import { bindThis } from '@/decorators.js';
import { QueueLoggerService } from '../QueueLoggerService.js';
import type * as Bull from 'bullmq';
import type { DbUserImportJobData } from '../types.js';
+import type { Config } from '@/config.js';
// TODO: 名前衝突時の動作を選べるようにする
@Injectable()
@@ -24,6 +25,9 @@ export class ImportCustomEmojisProcessorService {
private logger: Logger;
constructor(
+ @Inject(DI.config)
+ private config: Config,
+
@Inject(DI.driveFilesRepository)
private driveFilesRepository: DriveFilesRepository,
@@ -57,7 +61,7 @@ export class ImportCustomEmojisProcessorService {
try {
fs.writeFileSync(destPath, '', 'binary');
- await this.downloadService.downloadUrl(file.url, destPath);
+ await this.downloadService.downloadUrl(file.url, destPath, { operationTimeout: this.config.import?.downloadTimeout, maxSize: this.config.import?.maxFileSize });
} catch (e) { // TODO: 何度か再試行
if (e instanceof Error || typeof e === 'string') {
this.logger.error(e);