diff options
| author | woxtu <woxtup@gmail.com> | 2023-07-27 09:04:19 +0900 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-07-27 09:04:19 +0900 |
| commit | cb0fa9a8ab168f5e66ff324d730df7d33d8934d1 (patch) | |
| tree | f5827e0178babdf589dbad8c83e9a0d5d5801ae5 /packages/backend/src/core/DownloadService.ts | |
| parent | refactor: forkでデフォルトのノート文字数を変更した場合、... (diff) | |
| download | sharkey-cb0fa9a8ab168f5e66ff324d730df7d33d8934d1.tar.gz sharkey-cb0fa9a8ab168f5e66ff324d730df7d33d8934d1.tar.bz2 sharkey-cb0fa9a8ab168f5e66ff324d730df7d33d8934d1.zip | |
Use promises API (#11351)
Diffstat (limited to 'packages/backend/src/core/DownloadService.ts')
| -rw-r--r-- | packages/backend/src/core/DownloadService.ts | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/packages/backend/src/core/DownloadService.ts b/packages/backend/src/core/DownloadService.ts index 09039a8b57..1ad7c0137b 100644 --- a/packages/backend/src/core/DownloadService.ts +++ b/packages/backend/src/core/DownloadService.ts @@ -1,6 +1,5 @@ import * as fs from 'node:fs'; -import * as stream from 'node:stream'; -import * as util from 'node:util'; +import * as stream from 'node:stream/promises'; import { Inject, Injectable } from '@nestjs/common'; import ipaddr from 'ipaddr.js'; import chalk from 'chalk'; @@ -14,7 +13,6 @@ import { StatusError } from '@/misc/status-error.js'; import { LoggerService } from '@/core/LoggerService.js'; import type Logger from '@/logger.js'; -const pipeline = util.promisify(stream.pipeline); import { bindThis } from '@/decorators.js'; @Injectable() @@ -102,7 +100,7 @@ export class DownloadService { }); try { - await pipeline(req, fs.createWriteStream(path)); + await stream.pipeline(req, fs.createWriteStream(path)); } catch (e) { if (e instanceof Got.HTTPError) { throw new StatusError(`${e.response.statusCode} ${e.response.statusMessage}`, e.response.statusCode, e.response.statusMessage); @@ -129,7 +127,7 @@ export class DownloadService { // write content at URL to temp file await this.downloadUrl(url, path); - const text = await util.promisify(fs.readFile)(path, 'utf8'); + const text = await fs.promises.readFile(path, 'utf8'); return text; } finally { |