Api

import { customerSetup, submitJob } from './handler';
import {
    healthCheckResponse,
    internalErrorResponse,
    optionsResponse,
    routeNotFoundResponse
} from './response';

export const lambdaHandler = async (event: any, context: any, callback: any) => {
    console.log(event);
    return await getRoute(event, context, callback);
};

const getRoute = async (event: any, context: any, callback: any) => {
    try {
        console.log('IN getRoute');
        const requestVerb = `${event['requestContext']['http']['method']}`;
        console.log(`requestVerb ${requestVerb}`);
        if (requestVerb === 'OPTIONS') {
            console.log('IN OPTIONS response');
            console.log(optionsResponse());
            return callback(null, optionsResponse());
        }
        const pathParameters = `${event['pathParameters']['proxy']}`.toLowerCase();
        const path = `${requestVerb} ${pathParameters}`;
        console.log(`path: ${path}`);
        switch (path) {
            case 'POST submitjob':
                console.log('IN submitJob case');
                return await submitJob(event, context, callback);
            case 'POST customer_setup':
                return await customerSetup(event, context, callback);
            // case 'POST deleteCustomer':
            //     // TODO: Get proper object off of event to make this work
            //     // Was not wired up before, so need to reattach
            //     // And this needs to be protected/authenticated.
            //     const companyDomainName = event.message.rds_host;
            //     return await deleteCluster('us-east-1', companyName, callback);
            case 'GET healthcheck':
                return callback(null, healthCheckResponse());
            default:
                return callback(null, routeNotFoundResponse());
        }
    } catch (error) {
        console.log(error);
        return callback('ERROR: Get Route Failed.', internalErrorResponse());
    }
};