fix(storeurl): support for workflows to storeURL (#406)

* fix(storeurl): support for workflows to storeURL

* fix(storeurl): add support workflow to StoreUrl

* fix(storeurl): check workflowId exist

* fix(storeurl): storeUrl - add workflow

* test(storeurl): storeUrl - add test

Author: konradkrk

src/lib/api/store.spec.ts

@@ -31,7 +31,10 @@ const mockedSession: Session = {
   urls: config.urls,
 };
 
+const workflowIds = ['123', '321'];
+
 const storeTaskDef = [{ name: 'store', params: {} }];
+const storeTaskDefWithWorkflows = [{ name: 'store', params: {} }];
 const sourceToStore = 'urlToStore';
 
 describe('StoreURL', () => {
@@ -157,4 +160,18 @@ describe('StoreURL', () => {
     })).rejects.toEqual(expect.any(FilestackError));
   });
 
+  it('should be able to run storeUrl with workflows', async () => {
+    await storeURL({
+      session: mockedSession,
+      url: sourceToStore,
+      workflowIds,
+    });
+
+    expect(FsRequest.post).toHaveBeenCalledWith(`${mockedSession.urls.processUrl}/process`, {
+      apikey: mockedSession.apikey,
+      sources: [ sourceToStore ],
+      tasks: storeTaskDefWithWorkflows,
+    }, {});
+  });
+
 });

src/lib/api/store.ts

@@ -30,6 +30,7 @@ export type StoreUrlParams = {
   security?: Security;
   uploadTags?: UploadTags;
   headers?: {[key: string]: string},
+  workflowIds?: string[]
 };
 
 /**
@@ -41,6 +42,7 @@ export type StoreUrlParams = {
  * @param token
  * @param security
  * @param uploadTags
+ * @param workflowIds
  */
 export const storeURL = ({
   session,
@@ -50,6 +52,7 @@ export const storeURL = ({
   security,
   uploadTags,
   headers,
+  workflowIds,
 }: StoreUrlParams): Promise<any> => {
   if (!url || typeof url !== 'string') {
     return Promise.reject(new FilestackError('url is required for storeURL'));
@@ -91,6 +94,10 @@ export const storeURL = ({
     }];
   }
 
+  if (workflowIds && workflowIds.length > 0) {
+    filelink.addTask('store', { workflows: workflowIds });
+  }
+
   return FsRequest.post(`${session.urls.processUrl}/process`, {
     apikey: session.apikey,
     sources,

src/lib/client.spec.ts

@@ -145,7 +145,9 @@ describe('client', () => {
     const options = {};
     const token = {};
     const uploadTags = { test: '123' };
-    await client.storeURL(url, options, token, defaultSecurity, uploadTags);
+    const headers = { 'test': '123' };
+    const workflowIds = ['123', '321'];
+    await client.storeURL(url, options, token, defaultSecurity, uploadTags,headers, workflowIds);
 
     expect(storeURL).toHaveBeenCalledWith({
       session: defaultSession,
@@ -154,6 +156,8 @@ describe('client', () => {
       token,
       security: defaultSecurity,
       uploadTags,
+      headers,
+      workflowIds,
     });
   });
 

src/lib/client.ts

@@ -310,8 +310,9 @@ export class Client extends EventEmitter {
    * @param security  Optional security override.
    * @param uploadTags Optional tags visible in webhooks.
    * @param headers    Optional headers to send
+   * @param workflowIds    Optional workflowIds to send
    */
-  storeURL(url: string, storeParams?: StoreParams, token?: any, security?: Security, uploadTags?: UploadTags, headers?: {[key: string]: string}): Promise<Object> {
+  storeURL(url: string, storeParams?: StoreParams, token?: any, security?: Security, uploadTags?: UploadTags, headers?: {[key: string]: string}, workflowIds?: string[]): Promise<Object> {
     return storeURL({
       session: this.session,
       url,
@@ -320,6 +321,7 @@ export class Client extends EventEmitter {
       security,
       uploadTags,
       headers,
+      workflowIds,
     });
   }