feat(service): move triggerCDNode from dashboard

Author: Elessar1802

src/Common/Common.service.ts

@@ -43,6 +43,7 @@ import {
 } from './Types'
 import { ApiResourceType } from '../Pages'
 import { RefVariableType } from './CIPipeline.Types'
+import { STAGE_MAP } from '@Pages/App/Trigger/constants'
 
 export const getTeamListMin = (): Promise<TeamList> => {
     // ignore active field
@@ -68,13 +69,6 @@ interface UserRole extends ResponseType {
     }
 }
 
-const stageMap = {
-    PRECD: 'PRE',
-    CD: 'DEPLOY',
-    POSTCD: 'POST',
-    APPROVAL: 'APPROVAL',
-}
-
 export const SourceTypeMap = {
     BranchFixed: 'SOURCE_TYPE_BRANCH_FIXED',
     WEBHOOK: 'WEBHOOK',
@@ -369,7 +363,7 @@ export const genericCDMaterialsService = (
         default:
             URL = getUrlWithSearchParams(`${ROUTES.CD_MATERIAL_GET}/${cdMaterialID}/material`, {
                 ...manipulatedParams,
-                stage: stageMap[stage],
+                stage: STAGE_MAP[stage],
             })
             break
     }

src/Common/Constants.ts

@@ -128,6 +128,7 @@ export const ROUTES = {
     FILE_UPLOAD: 'file/upload',
     PLUGIN_GLOBAL_VARIABLES: 'plugin/global/list/global-variable',
     CONFIG_COMPARE_SECRET: 'config/compare/secret',
+    CD_TRIGGER_POST: 'app/cd-pipeline/trigger',
 }
 
 export enum KEY_VALUE {

src/Pages/App/Trigger/constants.ts

@@ -0,0 +1,6 @@
+export const STAGE_MAP = {
+    PRECD: 'PRE',
+    CD: 'DEPLOY',
+    POSTCD: 'POST',
+    APPROVAL: 'APPROVAL',
+}

src/Pages/App/Trigger/index.ts

@@ -0,0 +1,3 @@
+export { triggerCDNode } from './service'
+export { getAPIOptionsWithTriggerTimeout } from './utils'
+export type { TriggerCDNodeServiceProps, TriggerCDPipelinePayloadType } from './types'

src/Pages/App/Trigger/service.ts

@@ -0,0 +1,42 @@
+import { post } from '@Common/Api'
+import { DeploymentNodeType } from '@Common/Types'
+import { DeploymentWithConfigType } from '@Shared/constants'
+import { ROUTES } from '@Common/Constants'
+import { TriggerCDNodeServiceProps, TriggerCDPipelinePayloadType } from './types'
+import { getAPIOptionsWithTriggerTimeout } from './utils'
+import { STAGE_MAP } from './constants'
+
+export const triggerCDNode = ({
+    pipelineId,
+    ciArtifactId,
+    appId,
+    stageType,
+    deploymentWithConfig,
+    wfrId,
+    runtimeParamsPayload,
+    abortControllerRef,
+}: TriggerCDNodeServiceProps) => {
+    const areRuntimeParamsConfigured =
+        runtimeParamsPayload && (stageType === DeploymentNodeType.POSTCD || stageType === DeploymentNodeType.PRECD)
+
+    const request: TriggerCDPipelinePayloadType = {
+        pipelineId,
+        appId,
+        ciArtifactId,
+        cdWorkflowType: STAGE_MAP[stageType],
+        ...(areRuntimeParamsConfigured && runtimeParamsPayload),
+    }
+
+    if (deploymentWithConfig) {
+        request.deploymentWithConfig =
+            deploymentWithConfig === DeploymentWithConfigType.LAST_SAVED_CONFIG
+                ? deploymentWithConfig
+                : DeploymentWithConfigType.SPECIFIC_TRIGGER_CONFIG
+
+        if (deploymentWithConfig !== DeploymentWithConfigType.LAST_SAVED_CONFIG) {
+            request.wfrIdForDeploymentWithSpecificTrigger = wfrId
+        }
+    }
+
+    return post(ROUTES.CD_TRIGGER_POST, request, { ...getAPIOptionsWithTriggerTimeout(), abortControllerRef })
+}

src/Pages/App/Trigger/types.ts

@@ -0,0 +1,26 @@
+import { DeploymentNodeType } from '@Common/Types'
+import { RuntimeParamsTriggerPayloadType } from '@Shared/types'
+import { MutableRefObject } from 'react'
+
+export interface TriggerCDNodeServiceProps {
+    pipelineId: number
+    ciArtifactId: number
+    appId: number
+    stageType: DeploymentNodeType
+    deploymentWithConfig?: string
+    wfrId?: number
+    abortControllerRef?: MutableRefObject<AbortController>
+    /**
+     * Would be available only case of PRE/POST CD
+     */
+    runtimeParamsPayload?: RuntimeParamsTriggerPayloadType
+}
+
+export interface TriggerCDPipelinePayloadType
+    extends Pick<
+        TriggerCDNodeServiceProps,
+        'pipelineId' | 'appId' | 'ciArtifactId' | 'runtimeParamsPayload' | 'deploymentWithConfig'
+    > {
+    cdWorkflowType: string
+    wfrIdForDeploymentWithSpecificTrigger?: number
+}

src/Pages/App/Trigger/utils.ts

@@ -0,0 +1,11 @@
+import { APIOptions } from '@Common/Types'
+
+export const getAPIOptionsWithTriggerTimeout = (options?: APIOptions): APIOptions => {
+    const _options: APIOptions = options ? JSON.parse(JSON.stringify(options)) : {}
+
+    if (window._env_.TRIGGER_API_TIMEOUT) {
+        _options.timeout = window._env_.TRIGGER_API_TIMEOUT
+    }
+
+    return _options
+}

src/Pages/App/index.ts

@@ -1 +1,2 @@
 export * from './AppConfiguration'
+export * from './Trigger'

src/Pages/ResourceBrowser/ResourceBrowser.Types.ts

@@ -15,7 +15,7 @@
  */
 
 import { NodeType, Nodes } from '@Shared/types'
-import { RefObject } from 'react'
+import { MutableRefObject, RefObject } from 'react'
 
 export interface GVKType {
     Group: string
@@ -92,7 +92,7 @@ export interface BulkOperation {
      * Would these keys beside the name
      */
     additionalKeys?: BulkOperationAdditionalKeysType[]
-    operation: (signal: AbortSignal, data?: unknown) => Promise<void>
+    operation: (abortControllerRef: MutableRefObject<AbortController>, data?: unknown) => Promise<void>
 }
 
 export type BulkOperationModalProps = {