Injecting and passing authProvider and authToken variables to execute sonataflow (#509)

* [FLPATH-2143] : initial commit to pass the auth header token to sonataflow

* [FLPATH-2143] : pushing failed changes

* [FLPATH-2143] : enabling to send auht tokens in req body instead of headers

* [FLPATH-2143] : enabling to send auht tokens in req body instead of headers

* [FLPATH-2143] : enabling to send auht tokens in req body instead of headers

* [FLPATH-2143] : enabling to send auht tokens in req body instead of headers

* Update workspaces/orchestrator/plugins/orchestrator-backend/src/service/SonataFlowService.ts

Co-authored-by: Marek Libra <marek.libra@gmail.com>

* [FLPATH-2143] : enabling to send auht tokens in req body instead of headers

* Update workspaces/orchestrator/plugins/orchestrator-backend/src/service/SonataFlowService.ts

Co-authored-by: Marek Libra <marek.libra@gmail.com>

* [FLPATH-2143] : enabling to send auht tokens in req body instead of headers

* [FLPATH-2143] : enabling to send auht tokens in req body instead of headers

* [FLPATH-2143] : enabling to send auht tokens in req body instead of headers

* [FLPATH-2143] : enabling to send auht tokens in req body instead of headers

* [FLPATH-2143] : enabling to send auht tokens in req body instead of headers

* [FLPATH-2143] : enabling to send auht tokens in req body instead of headers

---------

Co-authored-by: Marek Libra <marek.libra@gmail.com>

Author: ishanjogi89

workspaces/orchestrator/plugins/orchestrator-backend/src/service/OrchestratorService.ts

@@ -22,6 +22,7 @@ import {
   WorkflowExecutionResponse,
   WorkflowInfo,
   WorkflowOverview,
+  AuthToken,
 } from '@red-hat-developer-hub/backstage-plugin-orchestrator-common';
 
 import { Pagination } from '../types/pagination';
@@ -185,6 +186,7 @@ export class OrchestratorService {
     definitionId: string;
     serviceUrl: string;
     inputData?: ProcessInstanceVariables;
+    authTokens?: Array<AuthToken>;
     businessKey?: string;
     cacheHandler?: CacheHandler;
   }): Promise<WorkflowExecutionResponse | undefined> {

workspaces/orchestrator/plugins/orchestrator-backend/src/service/SonataFlowService.ts

@@ -27,6 +27,7 @@ import {
   WorkflowExecutionResponse,
   WorkflowInfo,
   WorkflowOverview,
+  AuthToken,
 } from '@red-hat-developer-hub/backstage-plugin-orchestrator-common';
 
 import { Pagination } from '../types/pagination';
@@ -100,16 +101,34 @@ export class SonataFlowService {
     definitionId: string;
     serviceUrl: string;
     inputData?: ProcessInstanceVariables;
+    authTokens?: Array<AuthToken>;
     businessKey?: string;
   }): Promise<WorkflowExecutionResponse | undefined> {
     const urlToFetch = args.businessKey
       ? `${args.serviceUrl}/${args.definitionId}?businessKey=${args.businessKey}`
       : `${args.serviceUrl}/${args.definitionId}`;
+    const headers: Record<string, string> = {
+      'Content-Type': 'application/json',
+    };
+
+  	// Add X-Authentication headers from authTokens
+  	if (args.authTokens && Array.isArray(args.authTokens)) {
+    	args.authTokens.forEach((tokenObj) => {
+      	if (tokenObj.provider && tokenObj.token) {
+        const headerKey = `X-Authentication-${tokenObj.provider}`;
+        headers[headerKey] = String(tokenObj.token); // Ensure token is a string
+      	}
+      });
+  	}
+  	
+  	else {
+    	this.logger.debug('No authTokens provided or authTokens is not an array.');
+  	}
 
     const response = await fetch(urlToFetch, {
       method: 'POST',
       body: JSON.stringify(args.inputData || {}),
-      headers: { 'content-type': 'application/json' },
+      headers,
     });
 
     const json = await response.json();

workspaces/orchestrator/plugins/orchestrator-backend/src/service/api/v2.ts

@@ -18,6 +18,7 @@ import { ParsedRequest } from 'openapi-backend';
 
 import {
   AssessedProcessInstanceDTO,
+  AuthToken,
   ExecuteWorkflowRequestDTO,
   ExecuteWorkflowResponseDTO,
   Filter,
@@ -176,6 +177,8 @@ export class V2 {
       definitionId: workflowId,
       inputData:
         executeWorkflowRequestDTO.inputData as ProcessInstanceVariables,
+      authTokens:
+        executeWorkflowRequestDTO.authTokens as Array<AuthToken>,
       serviceUrl: definition.serviceUrl,
       businessKey,
       cacheHandler: 'throw',

workspaces/orchestrator/plugins/orchestrator-common/src/openapi/openapi.yaml

@@ -575,6 +575,25 @@ components:
         inputData:
           type: object
           additionalProperties: true
+        authTokens:
+          type: array
+          items:
+            $ref: '#/components/schemas/AuthToken' 
+          minItems: 1     
+          additionalProperties: true
+    AuthToken:
+      type: object
+      properties:
+        provider:
+          description: The auth token provider name
+          type: string
+        token:
+          description: The auth token itself retrieved from the above specified provider name
+          type: string
+      required:
+        - provider
+        - token
+      additionalProperties: false          
     ExecuteWorkflowResponseDTO:
       type: object
       properties: