[Test PR] SDK Multipart support

package.json

@@ -1,5 +1,5 @@
 {
-  "name": "node-appwrite",
+  "name": "node-appwrite-1",
   "homepage": "https://appwrite.io/support",
   "description": "Appwrite is an open-source self-hosted backend server that abstract and simplify complex and repetitive development tasks behind a very simple REST API",
   "version": "13.0.0",
@@ -42,12 +42,13 @@
   },
   "devDependencies": {
     "@types/node": "20.11.25",
-    "tsup": "7.2.0",
     "esbuild-plugin-file-path-extensions": "^2.0.0",
     "tslib": "2.6.2",
+    "tsup": "7.2.0",
     "typescript": "5.4.2"
   },
   "dependencies": {
-    "node-fetch-native-with-agent": "1.7.2"
+    "node-fetch-native-with-agent": "1.7.2",
+    "parse-multipart-data": "^1.5.0"
   }
 }

src/NewPayload.ts

@@ -0,0 +1,47 @@
+import { realpathSync, readFileSync } from "fs";
+export class NewPayload {
+  private data: Buffer;
+
+  constructor(data: Buffer) {
+    this.data = data;
+  }
+
+  public getData(): Buffer {
+    return this.data;
+  }
+
+  public static fromBuffer(buffer: Buffer): Buffer {
+    return Buffer.from(buffer);
+  }
+
+  public toBuffer(): Buffer {
+    return this.data;
+  }
+
+  public static fromString(string: string): Buffer {
+    return Buffer.from(string);
+  }
+
+  public toString(encoding: BufferEncoding = "utf8"): string {
+    return this.data.toString(encoding);
+  }
+
+  public static fromJson(json: object): Buffer {
+    return Buffer.from(JSON.stringify(json));
+  }
+
+  public toJson(): object {
+    return JSON.parse(this.data.toString());
+  }
+
+  public static fromPath(path: string): Buffer {
+    const realPath = realpathSync(path);
+    const contents = readFileSync(realPath);
+    return Buffer.from(contents);
+  }
+
+  public toFile(fileName: string): File {
+    const blob = new Blob([this.data]);
+    return new File([blob], fileName);
+  }
+}

src/client.ts

@@ -1,6 +1,9 @@
 import { fetch, FormData, File } from 'node-fetch-native-with-agent';
 import { createAgent } from 'node-fetch-native-with-agent/agent';
 import { Models } from './models';
+import { NewPayload } from './NewPayload';
+import * as multipart from 'parse-multipart-data';
+const { buffer } = require('node:stream/consumers');  
 
 type Payload = {
     [key: string]: any;
@@ -331,7 +334,24 @@ class Client {
             data = await response.json();
         } else if (responseType === 'arrayBuffer') {
             data = await response.arrayBuffer();
-        } else {
+        } else if (response.headers.get('content-type')?.includes('multipart/form-data')) {
+            const body = await buffer(response.body);
+            const boundary = multipart.getBoundary(
+              response.headers.get("content-type") || ""
+            );
+            const parts = multipart.parse(body, boundary);
+            const partsObject: { [key: string]: Buffer } = {};
+            for (const part of parts) {
+              if (part.name) {
+                partsObject[part.name] = part.data;
+              }
+            }
+            data = {
+              ...partsObject,
+              responseBody: new NewPayload(partsObject.responseBody),
+            };
+        }
+        else {
             data = {
                 message: await response.text()
             };

src/index.ts

@@ -33,3 +33,5 @@ export { ImageGravity } from './enums/image-gravity';
 export { ImageFormat } from './enums/image-format';
 export { PasswordHash } from './enums/password-hash';
 export { MessagingProviderType } from './enums/messaging-provider-type';
+export { NewPayload } from './NewPayload';
+export { InputFile } from './inputFile';

src/services/functions.ts

@@ -2,6 +2,7 @@ import { AppwriteException, Client, type Payload, UploadProgress } from '../clie
 import type { Models } from '../models';
 import { Runtime } from '../enums/runtime';
 import { ExecutionMethod } from '../enums/execution-method';
+import { NewPayload } from '../NewPayload';
 
 export class Functions {
     client: Client;
@@ -624,22 +625,22 @@ Use the "command" param to set the entrypoint used to execute your cod
      * Trigger a function execution. The returned object will return you the current execution status. You can ping the `Get Execution` endpoint to get updates on the current execution status. Once this endpoint is called, your function execution process will start asynchronously.
      *
      * @param {string} functionId
-     * @param {string} body
+     * @param {NewPayload} body
      * @param {boolean} async
      * @param {string} xpath
      * @param {ExecutionMethod} method
      * @param {object} headers
      * @throws {AppwriteException}
      * @returns {Promise<Models.Execution>}
      */
-    async createExecution(functionId: string, body?: string, async?: boolean, xpath?: string, method?: ExecutionMethod, headers?: object): Promise<Models.Execution> {
+    async createExecution(functionId: string, body?: NewPayload, async?: boolean, xpath?: string, method?: ExecutionMethod, headers?: object): Promise<Models.Execution> {
         if (typeof functionId === 'undefined') {
             throw new AppwriteException('Missing required parameter: "functionId"');
         }
         const apiPath = '/functions/{functionId}/executions'.replace('{functionId}', functionId);
         const payload: Payload = {};
         if (typeof body !== 'undefined') {
-            payload['body'] = body;
+            payload['body'] = body ? body.getData() : body;
         }
         if (typeof async !== 'undefined') {
             payload['async'] = async;
@@ -656,7 +657,8 @@ Use the &quot;command&quot; param to set the entrypoint used to execute your cod
         const uri = new URL(this.client.config.endpoint + apiPath);
 
         const apiHeaders: { [header: string]: string } = {
-            'content-type': 'application/json',
+            'content-type': 'multipart/form-data',
+            'accept': 'multipart/form-data',
         }
 
         return await this.client.call(