Merge pull request #241 from contentstack/staging

DX | 13-01-2025 | Release

Author: cs-raj

CHANGELOG.md

@@ -1,4 +1,8 @@
 # Changelog
+
+## [v1.19.0](https://github.com/contentstack/contentstack-management-javascript/tree/v1.19.0) (2025-01-13)
+ - Feature
+   - Release 2.0 feature
 ## [v1.18.4](https://github.com/contentstack/contentstack-management-javascript/tree/v1.18.4) (2024-11-22)
  - Enhancement
     - Added support for response headers.

LICENSE

@@ -1,6 +1,6 @@
 MIT License
 
-Copyright (c) 2012-2024 Contentstack
+Copyright (c) 2012-2025 Contentstack
 
 Permission is hereby granted, free of charge, to any person obtaining a copy
 of this software and associated documentation files (the "Software"), to deal

lib/core/concurrency-queue.js

@@ -205,7 +205,7 @@ export function ConcurrencyQueue ({ axios, config }) {
       } else {
         return Promise.reject(responseHandler(error))
       }
-    } else if (response.status === 429 || (response.status === 401 && this.config.refreshToken)) {
+    } else if ((response.status === 401 && this.config.refreshToken)) {
       retryErrorType = `Error with status: ${response.status}`
       networkError++
 

lib/stack/bulkOperation/index.js

@@ -9,6 +9,109 @@ export function BulkOperation (http, data = {}) {
   this.stackHeaders = data.stackHeaders
   this.urlPath = `/bulk`
 
+  /**
+   * The addItems request allows you to add multiple items to a release in bulk.
+   * @memberof BulkOperation
+   * @func addItems
+   * @returns {Promise<Object>} Response Object.
+   * @param {Object} params.data - The data containing the items to be added to the release.
+   * @param {String} [params.bulk_version] - The bulk version.
+   * @example
+   * const itemsData = {
+   *   items: [
+   *     {
+   *       uid: '{{entry_uid}}',
+   *       content_type: '{{content_type_uid}}'
+   *     }
+   *   ]
+   * }
+   * client.stack({ api_key: 'api_key'}).bulkOperation().addItems({ data: itemsData })
+   * .then((response) => { console.log(response) })
+   */
+  this.addItems = async ({ data, bulk_version = "" }) => {
+    this.urlPath = `/bulk/release/items`;
+    const headers = {
+      headers: {
+        ...cloneDeep(this.stackHeaders),
+      },
+    };
+    if (bulk_version) headers.headers.bulk_version = bulk_version;
+    try {
+      const response = await http.post(this.urlPath, data, headers);
+      if (response.data) {
+        return response.data;
+      }
+    } catch (error) {
+      console.error(error);
+    }
+  };
+
+  /**
+   * The updateItems request allows you to update multiple items in a release in bulk.
+   * @memberof BulkOperation
+   * @func updateItems
+   * @returns {Promise<Object>} Response Object.
+   * @param {Object} params.data - The data containing the items to be updated in the release.
+   * @param {String} [params.bulk_version] - The bulk version.
+   * @example
+   * const itemsData = {
+   *   items: [
+   *     {
+   *       uid: '{{entry_uid}}',
+   *       content_type: '{{content_type_uid}}'
+   *     }
+   *   ]
+   * }
+   * client.stack({ api_key: 'api_key'}).bulkOperation().updateItems({ data: itemsData })
+   * .then((response) => { console.log(response) })
+   */
+  this.updateItems = async ({ data, bulk_version = "" }) => {
+    this.urlPath = `/bulk/release/update_items`;
+    const headers = {
+      headers: {
+        ...cloneDeep(this.stackHeaders),
+      },
+    };
+    if (bulk_version) headers.headers.bulk_version = bulk_version;
+    try {
+      const response = await http.put(this.urlPath, data, headers);
+      if (response.data) {
+        return response.data;
+      }
+    } catch (error) {
+      console.error(error);
+    }
+  };
+
+  /**
+   * The jobStatus request allows you to check the status of a bulk job.
+   * @memberof BulkOperation
+   * @func jobStatus
+   * @returns {Promise<Object>} Response Object.
+   * @param {String} params.job_id - The ID of the job.
+   * @param {String} [params.bulk_version] - The bulk version.
+   * @example
+   * client.stack({ api_key: 'api_key'}).bulkOperation().jobStatus({ job_id: 'job_id' })
+   * .then((response) => { console.log(response) })
+   */
+  this.jobStatus = async ({ job_id, bulk_version = "" }) => {
+    this.urlPath = `/bulk/jobs/${job_id}`;
+    const headers = {
+      headers: {
+        ...cloneDeep(this.stackHeaders),
+      },
+    };
+    if (bulk_version) headers.headers.bulk_version = bulk_version;
+    try {
+      const response = await http.get(this.urlPath, headers);
+      if (response.data) {
+        return response.data;
+      }
+    } catch (error) {
+      console.error(error);
+    }
+  };
+
   /**
    * The Publish entries and assets in bulk request allows you to publish multiple entries and assets at the same time.
    * @memberof BulkOperation

lib/stack/release/items/index.js

@@ -52,25 +52,36 @@ export function ReleaseItem (http, data = {}) {
      * client.stack({ api_key: 'api_key'}).release('release_uid').delete({items})
      * .then((response) => console.log(response.notice))
      */
-    this.delete = async (items) => {
+    this.delete = async (params) => {
       let param = {}
-      if (items === undefined) {
+      if (params.items === undefined && params.item === undefined) {
         param = {all: true}
+        params.items = []
       }
       try {
         const headers = {
           headers: { ...cloneDeep(this.stackHeaders) },
           data: {
-            ...cloneDeep(items)
+            ...cloneDeep(params)
           },
           params: {
             ...cloneDeep(param)
           }
         } || {}
+        
+        if (params.release_version) {
+          headers.headers['release_version'] = params.release_version;
+        }
+        
+        if (params.item) {
+          this.urlPath = `releases/${data.releaseUid}/item`
+          headers.data['item'] = params.item
+        } else
+        headers.data['items'] = params.items
 
         const response = await http.delete(this.urlPath, headers)
         if (response.data) {
-          return new Release(http, { ...response.data, stackHeaders: data.stackHeaders })
+          return response.data
         } else {
           throw error(response)
         }
@@ -129,9 +140,18 @@ export function ReleaseItem (http, data = {}) {
           ...cloneDeep(this.stackHeaders)
         }
       } || {}
+      
+      if (param.release_version) { 
+        headers.headers['release_version'] = param.release_version;
+      }
+      if (param.item) {
+        this.urlPath = `releases/${data.releaseUid}/item`
+        param['item'] = param.item
+      } else
+        param['items'] = param.items
 
       try {
-        const response = await http.post(param.item ? `releases/${data.releaseUid}/item` : this.urlPath, param, headers)
+        const response = await http.post(this.urlPath, param, headers)
         if (response.data) {
           if (response.data) {
             return new Release(http, { ...response.data, stackHeaders: data.stackHeaders })
@@ -166,7 +186,10 @@ export function ReleaseItem (http, data = {}) {
             ...cloneDeep(param)
           }
         } || {}
-
+        if (param.release_version) {
+          headers.headers['release_version'] = param.release_version;
+          delete headers.params.release_version;
+        }
         const response = await http.get(this.urlPath, headers)
         if (response.data) {
           return new ContentstackCollection(response, http, this.stackHeaders, ReleaseItemCollection)
@@ -177,6 +200,44 @@ export function ReleaseItem (http, data = {}) {
         error(err) 
       }
     }
+
+    /**
+     * The move request allows you to move multiple items within a release.
+     * @memberof ReleaseItem
+     * @func move
+     * @returns {Promise<Object>} Response Object.
+     * @param {Object} params.param - The data containing the items to be moved within the release.
+     * @param {String} [params.release_version] - The release version.
+     * @example
+     * const moveData = {
+     *   items: [
+     *     {
+     *       uid: '{{entry_uid}}',
+     *       content_type: '{{content_type_uid}}'
+     *     }
+     *   ]
+     * }
+     * client.stack({ api_key: 'api_key'}).release('release_uid').item().move({ param: moveData, release_version: '1.0' })
+     * .then((response) => { console.log(response) })
+     */
+    this.move = async ({ param, release_version = '' }) => {
+      const headers = {
+        headers: {
+          ...cloneDeep(this.stackHeaders)
+        }
+      } || {}
+      if (release_version) {
+        headers.headers['release_version'] = release_version;
+      }
+      try {
+        const response = await http.put(`${this.urlPath}/move`, param, headers)
+        if (response.data) {
+          return response.data
+        }
+      } catch (err) {
+        throw error(err)
+      }
+    }
   }
   return this
 }