move to blobs

Author: KnorpelSenf

README.md

@@ -88,14 +88,11 @@ const job = await cloudConvert.jobs.create({
 
 const uploadTask = job.tasks.filter(task => task.name === 'upload-my-file')[0];
 
-const inputFile = fs.createReadStream('./file.pdf');
+const inputFile = fs.openAsBlob('./file.pdf');
 
 await cloudConvert.tasks.upload(uploadTask, inputFile, 'file.pdf');
 ```
 
-> **Note on custom streams**:
-> The length of the stream needs to be known prior to uploading. The SDK automatically detects the file size of file-based read streams. If you are using a custom stream, you need to pass a `filesize` as fourth parameter to the `upload()` method.
-
 ## Websocket Events
 
 The node SDK can subscribe to events of the [CloudConvert socket.io API](https://cloudconvert.com/api/v2/socket#socket).

lib/CloudConvert.ts

@@ -1,5 +1,4 @@
 import io from 'socket.io-client';
-import FormData from 'form-data';
 import { version } from '../package.json';
 import JobsResource, { type JobEventData } from './JobsResource';
 import SignedUrlResource from './SignedUrlResource';
@@ -59,10 +58,7 @@ export default class CloudConvert {
             method,
             headers: {
                 Authorization: `Bearer ${this.apiKey}`,
-                'User-Agent': `cloudconvert-node/v${version} (https://github.com/cloudconvert/cloudconvert-node)`,
-                ...(parameters instanceof FormData
-                    ? parameters.getHeaders()
-                    : {})
+                'User-Agent': `cloudconvert-node/v${version} (https://github.com/cloudconvert/cloudconvert-node)`
             },
             body:
                 parameters instanceof FormData

lib/TasksResource.ts

@@ -1,7 +1,5 @@
-import FormData, { type Stream } from 'form-data';
 import CloudConvert from './CloudConvert';
 import { type JobTask } from './JobsResource';
-import { ReadStream, statSync } from 'fs';
 
 export type TaskEvent = 'created' | 'updated' | 'finished' | 'failed';
 export type TaskStatus = 'waiting' | 'processing' | 'finished' | 'error';
@@ -589,9 +587,8 @@ export default class TasksResource {
 
     async upload(
         task: Task | JobTask,
-        stream: Stream,
-        filename: string | null = null,
-        size: number | null = null
+        stream: Blob,
+        filename?: string
     ): Promise<any> {
         if (task.operation !== 'import/upload') {
             throw new Error('The task operation is not import/upload');
@@ -602,22 +599,10 @@ export default class TasksResource {
         }
 
         const formData = new FormData();
-
         for (const parameter in task.result.form.parameters) {
             formData.append(parameter, task.result.form.parameters[parameter]);
         }
-
-        const fileOptions: { filename?: string; knownLength?: number } = {};
-
-        if (filename) {
-            fileOptions.filename = filename;
-        }
-        if (size) {
-            fileOptions.knownLength = size;
-        } else if (stream instanceof ReadStream) {
-            fileOptions.knownLength = statSync(stream.path).size;
-        }
-        formData.append('file', stream, fileOptions);
+        formData.append('file', stream, filename);
 
         return await this.cloudConvert.call(
             'POST',

package.json

@@ -19,7 +19,6 @@
         "node": ">=19.8.0"
     },
     "dependencies": {
-        "form-data": "^4.0.0",
         "socket.io-client": "^4.7.4"
     },
     "devDependencies": {