chore: remove duplicates

Redocly · Jan 20, 2025 · d2df098 · d2df098
1 parent 4b4a862
commit d2df098
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 9 deletions.
diff --git a/packages/cli/src/cms/api/api-client.ts b/packages/cli/src/cms/api/api-client.ts
@@ -11,6 +11,7 @@ import type {
   PushResponse,
   UpsertRemoteResponse,
 } from './types';
+import type { Readable } from 'stream';
 
 interface BaseApiClient {
   request(url: string, options: FetchWithTimeoutOptions): Promise<Response>;
@@ -372,7 +373,7 @@ export type PushPayload = {
   isMainBranch?: boolean;
 };
 
-async function streamToBuffer(stream: ReadStream): Promise<Buffer> {
+export async function streamToBuffer(stream: ReadStream | Readable): Promise<Buffer> {
   const chunks: Buffer[] = [];
   for await (const chunk of stream) {
     chunks.push(chunk);

diff --git a/packages/cli/src/commands/push.ts b/packages/cli/src/commands/push.ts
@@ -21,6 +21,7 @@ import {
 } from '../utils/miscellaneous';
 import { promptClientToken } from './login';
 import { handlePush as handleCMSPush } from '../cms/commands/push';
+import { streamToBuffer } from '../cms/api/api-client';
 
 import type { Config, BundleOutputFormat, Region } from '@redocly/openapi-core';
 import type { CommandArgs } from '../wrapper';
@@ -463,11 +464,3 @@ async function uploadFileToS3(url: string, filePathOrBuffer: string | Buffer) {
 
   return fetch(url, requestOptions);
 }
-
-async function streamToBuffer(stream: Readable): Promise<Buffer> {
-  const chunks: Buffer[] = [];
-  for await (const chunk of stream) {
-    chunks.push(chunk);
-  }
-  return Buffer.concat(chunks);
-}