Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 | 3x 46x 1x 45x 45x 1x 44x 1x 43x 43x 15x 15x 28x 28x 3x | import { response } from "libs/handler-lib";
import { APIGatewayEvent } from "aws-lambda";
import { submissionPayloads } from "./submissionPayloads";
import { produceMessage } from "libs/api/kafka";
import { BaseSchemas } from "shared-types/events";
export const submit = async (event: APIGatewayEvent) => {
if (!event.body) {
return response({
statusCode: 400,
body: "Event body required",
});
}
const body: BaseSchemas = JSON.parse(event.body);
// If there's no event, we reject
if (!body.event) {
return response({
statusCode: 400,
body: { message: "Bad Request - Missing event name in body" },
});
}
// If the event is unknown, we reject
if (!(body.event in submissionPayloads)) {
return response({
statusCode: 400,
body: { message: `Bad Request - Unknown event type ${body.event}` },
});
}
try {
const eventBody = await submissionPayloads[body.event](event);
await produceMessage(process.env.topicName as string, body.id, JSON.stringify(eventBody));
return response({
statusCode: 200,
body: { message: "success" },
});
} catch (err) {
console.error("Error has occured during submission:", err);
return response({
statusCode: 500,
body: { message: "Internal server error" },
});
}
};
export const handler = submit;
|