Reverting changes

Author: Diler Zaza

packages/core/src/shared/clients/stepFunctions.ts

@@ -7,17 +7,34 @@ import {
     CreateStateMachineCommand,
     CreateStateMachineCommandInput,
     CreateStateMachineCommandOutput,
+    DescribeExecutionCommand,
+    DescribeExecutionCommandInput,
+    DescribeExecutionCommandOutput,
+    DescribeMapRunCommand,
+    DescribeMapRunCommandInput,
+    DescribeMapRunCommandOutput,
     DescribeStateMachineCommand,
     DescribeStateMachineCommandInput,
     DescribeStateMachineCommandOutput,
+    DescribeStateMachineForExecutionCommand,
+    DescribeStateMachineForExecutionCommandInput,
+    DescribeStateMachineForExecutionCommandOutput,
+    GetExecutionHistoryCommand,
+    GetExecutionHistoryCommandInput,
+    GetExecutionHistoryCommandOutput,
     ListStateMachinesCommand,
     ListStateMachinesCommandInput,
     ListStateMachinesCommandOutput,
+    RedriveExecutionCommand,
+    RedriveExecutionCommandInput,
+    RedriveExecutionCommandOutput,
     SFNClient,
     StartExecutionCommand,
     StartExecutionCommandInput,
     StartExecutionCommandOutput,
     StateMachineListItem,
+    StopExecutionCommand,
+    StopExecutionCommandInput,
     TestStateCommand,
     TestStateCommandInput,
     TestStateCommandOutput,
@@ -26,6 +43,7 @@ import {
     UpdateStateMachineCommandOutput,
 } from '@aws-sdk/client-sfn'
 import { ClientWrapper } from './clientWrapper'
+import { StopAccessLoggingOutput } from 'aws-sdk/clients/mediastore'
 // import { StopExecutionInput } from 'aws-sdk/clients/stepfunctions'
 
 export class StepFunctionsClient extends ClientWrapper<SFNClient> {
@@ -51,10 +69,38 @@ export class StepFunctionsClient extends ClientWrapper<SFNClient> {
         return this.makeRequest(DescribeStateMachineCommand, request)
     }
 
+    public async getStateMachineDetailsForExecution(
+        request: DescribeStateMachineForExecutionCommandInput
+    ): Promise<DescribeStateMachineForExecutionCommandOutput> {
+        return this.makeRequest(DescribeStateMachineForExecutionCommand, request)
+    }
+
+    public async getExecutionDetails(request: DescribeExecutionCommandInput): Promise<DescribeExecutionCommandOutput> {
+        return this.makeRequest(DescribeExecutionCommand, request)
+    }
+
+    public async getMapRunDetails(request: DescribeMapRunCommandInput): Promise<DescribeMapRunCommandOutput> {
+        return this.makeRequest(DescribeMapRunCommand, request)
+    }
+
+    public async getExecutionHistory(
+        request: GetExecutionHistoryCommandInput
+    ): Promise<GetExecutionHistoryCommandOutput> {
+        return this.makeRequest(GetExecutionHistoryCommand, request)
+    }
+
+    public async reDriveExecution(request: RedriveExecutionCommandInput): Promise<RedriveExecutionCommandOutput> {
+        return this.makeRequest(RedriveExecutionCommand, request)
+    }
+
     public async executeStateMachine(request: StartExecutionCommandInput): Promise<StartExecutionCommandOutput> {
         return this.makeRequest(StartExecutionCommand, request)
     }
 
+    public async stopExecution(request: StopExecutionCommandInput): Promise<StopAccessLoggingOutput> {
+        return this.makeRequest(StopExecutionCommand, request)
+    }
+
     public async createStateMachine(request: CreateStateMachineCommandInput): Promise<CreateStateMachineCommandOutput> {
         return this.makeRequest(CreateStateMachineCommand, request)
     }

packages/core/src/stepFunctions/executionDetails/executionDetailProvider.ts

@@ -108,22 +108,6 @@ export class ExecutionDetailProvider {
                 executionArn,
             }
 
-            // Create execution details context
-            const context: ExecutionDetailsContext = {
-                stateMachineName: executionArn.split(':').pop() || 'Unknown',
-                mode: WorkflowMode.Readonly, // Execution details are typically read-only
-                panel,
-                textDocument: {} as vscode.TextDocument, // Not applicable for execution details
-                disposables: [],
-                workSpacePath: '',
-                defaultTemplatePath: '',
-                defaultTemplateName: '',
-                fileStates: {},
-                loaderNotification: undefined,
-                fileId: executionArn,
-                executionArn,
-            }
-
             // Handle messages from the webview
             panel.webview.onDidReceiveMessage(async (message) => {
                 this.logger.debug('Received message from execution details webview: %O', message)

packages/core/src/stepFunctions/executionDetails/handleMessage.ts

@@ -73,46 +73,3 @@ async function initMessageHandler(context: ExecutionDetailsContext) {
         } as InitResponseMessage)
     }
 }
-<<<<<<< HEAD
-
-/**
- * Handler for managing webview stage load, which updates load notifications.
- * @param context The context object containing the necessary information for the webview.
- */
-async function loadStageMessageHandler(context: ExecutionDetailsContext) {
-    context.loaderNotification?.progress.report({ increment: 25 })
-    setTimeout(() => {
-        context.loaderNotification?.resolve()
-    }, 100)
-}
-
-/**
- * Handler for making API calls from the webview and returning the response.
- * @param request The request message containing the API to call and the parameters
- * @param context The webview context used for returning the API response to the webview
- */
-function apiCallMessageHandler(request: ApiCallRequestMessage, context: WebviewContext) {
-    const logger = getLogger('stepfunctions')
-    const apiHandler = new WorkflowStudioApiHandler(globals.awsContext.getCredentialDefaultRegion(), context)
-    apiHandler.performApiCall(request).catch((error) => logger.error('%s API call failed: %O', request.apiName, error))
-}
-
-/**
- * Handles unsupported or unrecognized messages by sending a response to the webview. Ensures compatibility with future
- * commands and message types, preventing issues if the user has an outdated extension version.
- * @param context The context object containing information about the webview environment
- * @param originalMessage The original message that was not supported
- */
-async function handleUnsupportedMessage(context: ExecutionDetailsContext, originalMessage: Message) {
-    const logger = getLogger('stepfunctions')
-
-    logger.warn('Received unsupported message: %O', originalMessage)
-
-    await context.panel.webview.postMessage({
-        messageType: MessageType.RESPONSE,
-        command: Command.UNSUPPORTED_COMMAND,
-        originalMessage,
-    } as UnsupportedMessage)
-}
-=======
->>>>>>> 5aa458d7d (feat(stepfunctions): enable hardcoded execution details page)

packages/core/src/stepFunctions/messageHandlers/stepFunctionApiHandler.ts

@@ -41,28 +41,28 @@ export class stepFunctionApiHandler {
                     response = await this.testState(params)
                     break
                 case ApiAction.SFNDescribeStateMachine:
-                    response = await this.clients.sfn.getStateMachineDetails(params.stateMachineArn)
+                    response = await this.clients.sfn.getStateMachineDetails(params)
                     break
                 case ApiAction.SFNDescribeStateMachineForExecution:
-                    response = await this.clients.sfn.getStateMachineDetailsForExecution(params.executionArn)
+                    response = await this.clients.sfn.getStateMachineDetailsForExecution(params)
                     break
                 case ApiAction.SFNDescribeExecution:
-                    response = await this.clients.sfn.getExecutionDetails(params.executionArn)
+                    response = await this.clients.sfn.getExecutionDetails(params)
                     break
                 case ApiAction.SFNDescribeMapRun:
-                    response = await this.clients.sfn.getMapRunDetails(params.mapRunArn)
+                    response = await this.clients.sfn.getMapRunDetails(params)
                     break
                 case ApiAction.SFNGetExecutionHistory:
-                    response = await this.clients.sfn.getExecutionHistory(params.executionArn)
+                    response = await this.clients.sfn.getExecutionHistory(params)
                     break
                 case ApiAction.SFNRedriveExecution:
-                    response = await this.clients.sfn.reDriveExecution(params.executionArn)
+                    response = await this.clients.sfn.reDriveExecution(params)
                     break
                 case ApiAction.SFNStartExecution:
-                    response = await this.clients.sfn.executeStateMachine(params.stateMachineArn, params.input)
+                    response = await this.clients.sfn.executeStateMachine(params)
                     break
                 case ApiAction.SFNStopExecution:
-                    response = await this.clients.sfn.stopExecution(params.executionArn)
+                    response = await this.clients.sfn.stopExecution(params)
                     break
                 default:
                     throw new Error(`Unknown API: ${apiName}`)