summaryrefslogtreecommitdiff
path: root/packages/backend/src/server/api/ApiCallService.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2023-07-27 13:00:14 +0900
committerGitHub <noreply@github.com>2023-07-27 13:00:14 +0900
commita8d45d4b0d24e0c422d4e6d8feab57035239db56 (patch)
tree7fd6414990788c281997c75882961b8364e337ab /packages/backend/src/server/api/ApiCallService.ts
parentMerge pull request #11338 from misskey-dev/develop (diff)
parentchore: update pnpm to 8.6.10 (diff)
downloadmisskey-a8d45d4b0d24e0c422d4e6d8feab57035239db56.tar.gz
misskey-a8d45d4b0d24e0c422d4e6d8feab57035239db56.tar.bz2
misskey-a8d45d4b0d24e0c422d4e6d8feab57035239db56.zip
Merge pull request #11384 from misskey-dev/develop
Release: 13.14.2
Diffstat (limited to 'packages/backend/src/server/api/ApiCallService.ts')
-rw-r--r--packages/backend/src/server/api/ApiCallService.ts7
1 files changed, 2 insertions, 5 deletions
diff --git a/packages/backend/src/server/api/ApiCallService.ts b/packages/backend/src/server/api/ApiCallService.ts
index c4c02e7afe..3e8b9fb727 100644
--- a/packages/backend/src/server/api/ApiCallService.ts
+++ b/packages/backend/src/server/api/ApiCallService.ts
@@ -1,7 +1,6 @@
import { randomUUID } from 'node:crypto';
-import { pipeline } from 'node:stream';
import * as fs from 'node:fs';
-import { promisify } from 'node:util';
+import * as stream from 'node:stream/promises';
import { Inject, Injectable } from '@nestjs/common';
import { DI } from '@/di-symbols.js';
import { getIpHash } from '@/misc/get-ip-hash.js';
@@ -21,8 +20,6 @@ import type { FastifyRequest, FastifyReply } from 'fastify';
import type { OnApplicationShutdown } from '@nestjs/common';
import type { IEndpointMeta, IEndpoint } from './endpoints.js';
-const pump = promisify(pipeline);
-
const accessDenied = {
message: 'Access denied.',
code: 'ACCESS_DENIED',
@@ -138,7 +135,7 @@ export class ApiCallService implements OnApplicationShutdown {
}
const [path] = await createTemp();
- await pump(multipartData.file, fs.createWriteStream(path));
+ await stream.pipeline(multipartData.file, fs.createWriteStream(path));
const fields = {} as Record<string, unknown>;
for (const [k, v] of Object.entries(multipartData.fields)) {