Add undocumented assemblyId parameter to createAssembly

Author: mifi

package.json

@@ -39,7 +39,8 @@
     "p-retry": "^4.2.0",
     "request": "^2.88.2",
     "temp": "^0.9.1",
-    "tsd": "^0.14.0"
+    "tsd": "^0.14.0",
+    "uuid": "^8.3.2"
   },
   "repository": {
     "type": "git",

src/Transloadit.js

@@ -115,12 +115,17 @@ class TransloaditClient {
       onAssemblyProgress = () => {},
       files = {},
       uploads = {},
+      assemblyId,
     } = opts
 
     // Keep track of how long the request took
     const startTimeMs = getHrTimeMs()
 
-    this._lastUsedAssemblyUrl = `${this._endpoint}/assemblies`
+    // Undocumented feature to allow specifying the assembly id from the client
+    // (not recommended for general use due to security)
+    const urlSuffix = assemblyId != null ? `/assemblies/${assemblyId}` : '/assemblies'
+
+    this._lastUsedAssemblyUrl = `${this._endpoint}${urlSuffix}`
 
     for (const [, path] of Object.entries(files)) {
       await access(path, fs.F_OK | fs.R_OK)
@@ -163,8 +168,8 @@ class TransloaditClient {
       const useTus = isResumable && allStreams.every(isFileBasedStream)
 
       const requestOpts = {
-        urlSuffix: '/assemblies',
-        method   : 'post',
+        urlSuffix,
+        method: 'post',
         timeout,
         params,
       }

test/integration/__tests__/live-api.js

@@ -16,6 +16,7 @@ const got = require('got')
 const pipeline = promisify(streamPipeline)
 const intoStream = require('into-stream')
 const request = require('request')
+const uuid = require('uuid')
 
 const Transloadit = require('../../../src/Transloadit')
 
@@ -261,6 +262,24 @@ describe('API integration', function () {
       })
     })
 
+    it('should allow setting an explicit assemblyId on createAssembly', async () => {
+      const client = createClient()
+
+      const assemblyId = uuid.v4().replace(/-/g, '')
+      const params = {
+        assemblyId,
+        waitForCompletion: true,
+        params           : {
+          steps: {
+            dummy: dummyStep,
+          },
+        },
+      }
+
+      const result = await client.createAssembly(params)
+      expect(result.assembly_id).toEqual(assemblyId)
+    })
+
     it('should throw a proper error for request stream', async () => {
       const client = createClient()
 

yarn.lock

@@ -5228,7 +5228,7 @@ uuid@^3.3.2:
   resolved "https://registry.yarnpkg.com/uuid/-/uuid-3.4.0.tgz#b23e4358afa8a202fe7a100af1f5f883f02007ee"
   integrity sha512-HjSDRw6gZE5JMggctHBcjVak08+KEVhSIiDzFnT9S9aegmp85S/bReBVTb4QTFaRNptJ9kuYaNhnbNEOkbKb/A==
 
-uuid@^8.3.0:
+uuid@^8.3.0, uuid@^8.3.2:
   version "8.3.2"
   resolved "https://registry.yarnpkg.com/uuid/-/uuid-8.3.2.tgz#80d5b5ced271bb9af6c445f21a1a04c606cefbe2"
   integrity sha512-+NYs2QeMWy+GWFOEm9xnn6HCDp0l7QBD7ml8zLUmJ+93Q5NF0NocErnwkTkXVFNiX3/fpC6afS8Dhb/gz7R7eg==