import {
  ListJobExecutionsForThingCommand,
  ListJobExecutionsForThingCommandInput,
  IoTClient,
} from '@aws-sdk/client-iot';
import {
  Request,
  Response,
} from '@softchef/lambda-events';
import { AwsError } from '../../constracts';

export async function handler(event: { [key: string]: any }) {
  const request = new Request(event);
  const response = new Response();
  try {
    const validated = request.validate(joi => {
      return {
        thingName: joi.string().required(),
        status: joi.string().allow('CANCELED', 'FAILED', 'IN_PROGRESS', 'QUEUED', 'REJECTED', 'REMOVED', 'SUCCEEDED', 'TIMED_OUT'),
      };
    });
    if (validated.error) {
      return response.error(validated.details, 422);
    }
    const parameters: ListJobExecutionsForThingCommandInput = {
      thingName: request.get('thingName'),
      status: request.get('status'),
    };
    if (request.has('nextToken')) {
      parameters.nextToken = request.get('nextToken');
    }
    const iotClient = new IoTClient({});
    const jobsExecutionForThing = await iotClient.send(
      new ListJobExecutionsForThingCommand(parameters),
    );
    return response.json({
      executionSummaries: jobsExecutionForThing.executionSummaries,
      nextToken: jobsExecutionForThing.nextToken,
    });
  } catch (error) {
    if ((error as AwsError).Code === 'ResourceNotFoundException') {
      return response.error(error, 404);
    } else {
      return response.error(error);
    }
  }
}