Added buffer upload in assets

Author: sunil-lakshman

CHANGELOG.md

@@ -1,5 +1,9 @@
 # Changelog
 
+## [v1.19.6](https://github.com/contentstack/contentstack-management-javascript/tree/v1.19.6) (2025-03-31)
+ - Enhancement
+    - Added buffer upload in assets
+
 ## [v1.19.5](https://github.com/contentstack/contentstack-management-javascript/tree/v1.19.5) (2025-03-17)
  - Fix
     - Added AuditLog in the stack class

lib/stack/asset/index.js

@@ -291,11 +291,21 @@ export function createFormData (data) {
     if (typeof data.title === 'string') {
       formData.append('asset[title]', data.title)
     }
-    const uploadStream = createReadStream(data.upload)
-    if (typeof data.content_type === 'string') {
-      formData.append('asset[upload]', uploadStream, { contentType: data.content_type })
+    // Handle Buffer Upload
+    if (Buffer.isBuffer(data.upload)) {
+      formData.append("asset[upload]", data.upload, {
+        filename: data.filename || "uploaded_file",
+        contentType: data.content_type || "application/octet-stream",
+      });
+    } else if (typeof data.upload === "string") { // Handle File Path Upload
+      const uploadStream = createReadStream(data.upload);
+      if (typeof data.content_type === "string") {
+        formData.append("asset[upload]", uploadStream, { contentType: data.content_type });
+      } else {
+        formData.append("asset[upload]", uploadStream);
+      }
     } else {
-      formData.append('asset[upload]', uploadStream)
+      throw new Error("Invalid upload format. Must be a file path or Buffer.");
     }
     return formData
   }

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@contentstack/management",
-  "version": "1.19.5",
+  "version": "1.19.6",
   "description": "The Content Management API is used to manage the content of your Contentstack account",
   "main": "./dist/node/contentstack-management.js",
   "browser": "./dist/web/contentstack-management.js",

package.json

@@ -1,3 +1,4 @@
+import fs from 'fs';
 import path from 'path'
 import { expect } from 'chai'
 import { describe, it, setup } from 'mocha'
@@ -38,6 +39,31 @@ describe('Assets api Test', () => {
       })
       .catch(done)
   })
+  
+  it('should upload asset from buffer', (done) => {
+    const filePath = path.join(__dirname, '../mock/customUpload.html');
+    const fileBuffer = fs.readFileSync(filePath);  // Read file into Buffer
+    const asset = {
+      upload: fileBuffer,                  // Buffer upload
+      filename: 'customUpload.html',       // Ensure filename is provided
+      content_type: 'text/html',           // Set content type
+      title: 'buffer-asset',
+      description: 'Buffer Asset Desc',
+      tags: ['Buffer']
+    };
+    makeAsset().create(asset)
+      .then((asset) => {
+        jsonWrite(asset, 'bufferAsset.json');
+        expect(asset.uid).to.be.not.equal(null);
+        expect(asset.url).to.be.not.equal(null);
+        expect(asset.filename).to.be.equal('customUpload.html');
+        expect(asset.title).to.be.equal('buffer-asset');
+        expect(asset.description).to.be.equal('Buffer Asset Desc');
+        expect(asset.content_type).to.be.equal('text/html');
+        done();
+      })
+      .catch(done);
+  });
 
   it('should download asset from URL.', done => {
     makeAsset().download({ url: assetURL, responseType: 'stream' })

test/sanity-check/api/asset-test.js

@@ -1,3 +1,4 @@
+import fs from 'fs';
 import path from 'path'
 import Axios from 'axios'
 import { expect } from 'chai'
@@ -171,6 +172,49 @@ describe('Contentstack Asset test', () => {
       .catch(done)
   })
 
+  it('should upload asset from buffer', (done) => {
+    const mock = new MockAdapter(Axios);
+    mock.onPost('/assets').reply(200, {
+      asset: {
+        uid: 'mock-uid',
+        url: '/assets',
+        filename: 'customUpload.html',
+        title: 'buffer-asset',
+        description: 'Buffer Asset Desc',
+        content_type: 'text/html',
+        tags: ['Buffer'],
+        parent_uid: 'UID'
+      }
+    });
+    const filePath = path.join(__dirname, '../api/mock/customUpload.html');
+    const fileBuffer = fs.readFileSync(filePath); 
+    const assetUpload = {
+      upload: fileBuffer,                  // Buffer upload
+      filename: 'customUpload.html',       // Filename to identify the file
+      content_type: 'text/html',           // MIME type
+      title: 'buffer-asset',
+      description: 'Buffer Asset Desc',
+      tags: ['Buffer'],
+      parent_uid: 'UID'
+    };
+    const form = createFormData(assetUpload)(); // Create FormData for Buffer upload
+    const boundary = form.getBoundary();
+    expect(boundary).to.be.equal(form.getBoundary());
+    expect(boundary.length).to.be.greaterThan(30);
+    makeAsset()
+      .create(assetUpload)
+      .then((asset) => {
+        expect(asset.uid).to.be.equal('mock-uid');
+        expect(asset.filename).to.be.equal('customUpload.html');
+        expect(asset.title).to.be.equal('buffer-asset');
+        expect(asset.description).to.be.equal('Buffer Asset Desc');
+        expect(asset.content_type).to.be.equal('text/html');
+        expect(asset.tags).to.include('Buffer');
+        done();
+      })
+      .catch(done);
+  });
+
   it('Asset replace test', done => {
     var mock = new MockAdapter(Axios)
     mock.onPut('/assets/UID').reply(200, {