export async function getLatestPipelineExecutionId()

in lib/apitools.ts [145:160]

• 14 lines of code
• 3 McCabe index (conditional complexity)

export async function getLatestPipelineExecutionId(pipeline: string): Promise<string | undefined> {
  const client = new CodePipelineClient({ region: process.env.AWS_REGION });
  const input: GetPipelineStateCommandInput = { name: pipeline };
  const command = new GetPipelineStateCommand(input);

  const response = await client.send(command);

  if (response.stageStates) {
    const sourceIndex = response.stageStates.findIndex(s => s.stageName === 'Source');
    if (sourceIndex >= 0) {
      const sourceStage = response.stageStates[sourceIndex];
      return sourceStage.latestExecution?.pipelineExecutionId;
    }
  }
  return undefined;
}