Add pending status

Author: KirillSergeevich

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@linkedapi/node",
-  "version": "1.2.16",
+  "version": "1.2.17",
   "description": "Control your LinkedIn accounts and retrieve real-time data, all through this Node.js SDK.",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

src/core/operation.ts

@@ -6,8 +6,8 @@ import {
   TLinkedApiErrorType,
   TWorkflowCancelResponse,
   TWorkflowCompletion,
+  TWorkflowInProgressStatus,
   TWorkflowResponse,
-  TWorkflowRunningStatus,
 } from '../types';
 
 import { pollWorkflowResult } from './poll-results';
@@ -83,9 +83,12 @@ export abstract class Operation<TParams, TResult> {
 
   public async status(
     workflowId: string,
-  ): Promise<TWorkflowRunningStatus | TMappedResponse<TResult>> {
+  ): Promise<TWorkflowInProgressStatus | TMappedResponse<TResult>> {
     const workflowResult = await this.getWorkflowResult(workflowId);
-    if (workflowResult.workflowStatus === 'running') {
+    if (
+      workflowResult.workflowStatus === 'running' ||
+      workflowResult.workflowStatus === 'pending'
+    ) {
       return workflowResult.workflowStatus;
     }
     const result = this.getCompletion(workflowResult);

src/core/poll-results.ts

@@ -1,9 +1,9 @@
-import { LinkedApiError, TWorkflowRunningStatus } from '../types';
+import { LinkedApiError, TWorkflowInProgressStatus } from '../types';
 
 import { WaitForCompletionOptions } from './operation';
 
 export async function pollWorkflowResult<TResult>(
-  workflowResultFn: () => Promise<TWorkflowRunningStatus | TResult>,
+  workflowResultFn: () => Promise<TWorkflowInProgressStatus | TResult>,
   options: WaitForCompletionOptions,
 ): Promise<TResult> {
   const sleep = (ms: number) => new Promise((resolve) => setTimeout(resolve, ms));
@@ -18,7 +18,7 @@ export async function pollWorkflowResult<TResult>(
     try {
       const result = await workflowResultFn();
 
-      if (result !== 'running') {
+      if (result !== 'running' && result !== 'pending') {
         return result;
       }
       invalidAttempts = 0;

src/types/workflows.ts

@@ -9,9 +9,13 @@ export type TWorkflowDefinition =
   | TSingleActionWorkflowDefinition
   | TSingleActionWorkflowDefinition[];
 
+export type TWorkflowPendingStatus = 'pending';
+
 export type TWorkflowRunningStatus = 'running';
 
-export type TWorkflowStatus = TWorkflowRunningStatus | 'completed' | 'failed';
+export type TWorkflowInProgressStatus = TWorkflowPendingStatus | TWorkflowRunningStatus;
+
+export type TWorkflowStatus = TWorkflowInProgressStatus | 'completed' | 'failed';
 
 export type TWorkflowCompletion<TResult extends TWorkflowData = TWorkflowData> =
   | TWorkflowCompletionSingleAction<TResult>