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 | 2x 4x 4x 4x 1x 3x 3x 3x 1x 3x 3x 2x | import { produceMessage } from "libs/api/kafka";
import { response } from "libs/handler-lib";
import { getUserByEmail } from "./userManagementService";
type SubmitGroupDivisionBody = {
userEmail: string;
group: string;
division: string;
};
export const submitGroupDivision = async (body: SubmitGroupDivisionBody) => {
try {
const topicName = process.env.topicName as string;
if (!topicName) {
throw new Error("Topic name is not defined");
}
const { userEmail, group, division } = body;
const userInfo = await getUserByEmail(userEmail);
await produceMessage(
topicName,
userInfo.id,
JSON.stringify({
eventType: "user-info",
email: userInfo.email,
group,
division,
fullName: userInfo.fullName,
}),
);
return response({
statusCode: 200,
body: { message: "Group and division submitted successfully." },
});
} catch (error) {
console.error("Error submitting group and division:", { error });
return response({
statusCode: 500,
body: { message: `Internal Server Error: ${error.message}` },
});
}
};
export const handler = submitGroupDivision;
|