Merge pull request 'feat(ems): implement POST /api/v1/employees with transactional insertion' (#3) from feature/ems-router-refactor into main

Reviewed-on: #3

ems-service/controllers/employee.controller.ts

@@ -0,0 +1,104 @@
+import pool from "../../shared/db.ts";
+
+export const getEmployees = async (ctx: any) => {
+  try {
+    const [rows] = await pool.query(
+      `SELECT 
+        e.employee_code, 
+        p.first_name, 
+        p.last_name, 
+        d.name AS department, 
+        j.title AS designation,
+        c.work_email
+       FROM employees e
+       JOIN partners p ON e.partner_id = p.partner_id
+       JOIN contracts c ON e.employee_id = c.employee_id
+       JOIN departments d ON c.department_id = d.department_id
+       JOIN job_positions j ON c.job_id = j.job_id`
+    );
+    
+    ctx.response.body = { 
+      success: true, 
+      count: (rows as any[]).length,
+      data: rows 
+    };
+  } catch (error) {
+    ctx.response.status = 500;
+    ctx.response.body = { 
+      success: false, 
+      error: (error as Error).message 
+    };
+  }
+};
+
+export const createEmployee = async (ctx: any) => {
+  // 1. Extract the JSON payload from the request
+  const body = ctx.request.body;
+  if (body.type() !== "json") {
+    ctx.response.status = 400;
+    ctx.response.body = { success: false, error: "Invalid JSON body" };
+    return;
+  }
+  
+  const data = await body.json();
+  
+  // 2. Acquire a dedicated connection from the pool for our transaction
+  const connection = await pool.getConnection();
+
+  try {
+    // 3. Start the transaction
+    await connection.beginTransaction();
+
+    // STEP A: Insert into Partners
+    const [partnerResult] = await connection.execute(
+      `INSERT INTO partners (first_name, last_name, dob, gender, personal_email, personal_phone) 
+       VALUES (?, ?, ?, ?, ?, ?)`,
+      [data.firstName, data.lastName, data.dob, data.gender, data.personalEmail, data.personalPhone]
+    );
+    const partnerId = (partnerResult as any).insertId;
+
+    // STEP B: Insert into Addresses
+    await connection.execute(
+      `INSERT INTO addresses (partner_id, address_type, door_number, landmark, address_line, pincode, district, state) 
+       VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,
+      [partnerId, data.address.type, data.address.doorNumber, data.address.landmark, data.address.line, data.address.pincode, data.address.district, data.address.state]
+    );
+
+    // STEP C: Insert into Employees
+    const [employeeResult] = await connection.execute(
+      `INSERT INTO employees (employee_code, partner_id, company_id, branch_id, is_active) 
+       VALUES (?, ?, ?, ?, ?)`,
+      [data.employeeCode, partnerId, data.companyId, data.branchId, true]
+    );
+    const employeeId = (employeeResult as any).insertId;
+
+    // STEP D: Insert into Contracts
+    await connection.execute(
+      `INSERT INTO contracts (employee_id, department_id, job_id, work_email, date_joining, probation_days, status, salary_structure_id) 
+       VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,
+      [employeeId, data.departmentId, data.jobId, data.workEmail, data.dateJoining, data.probationDays, 'ACTIVE', data.salaryStructureId]
+    );
+
+    // 4. Commit the transaction if all steps succeed
+    await connection.commit();
+
+    ctx.response.status = 201;
+    ctx.response.body = { 
+      success: true, 
+      message: "Employee created successfully",
+      employee_id: employeeId
+    };
+
+  } catch (error) {
+    // 5. Rollback everything if any step fails
+    await connection.rollback();
+    ctx.response.status = 500;
+    ctx.response.body = { 
+      success: false, 
+      error: "Transaction failed: " + (error as Error).message 
+    };
+  } finally {
+    // 6. Release the connection back to the pool
+    connection.release();
+  }
+};

ems-service/routes.ts

@@ -1,38 +1,12 @@
 import { Router } from "@oak/oak";
-import pool from "../shared/db.ts";
+import { getEmployees, createEmployee } from "./controllers/employee.controller.ts";
 
 const router = new Router();
 
-// GET all employees with their relational data
+// Route definitions are now clean and easy to read
-router.get("/api/employees", async (ctx) => {
+router.get("/api/v1/employees", getEmployees);
-  try {
+
-    const [rows] = await pool.query(
+// Create a new employee
-      `SELECT 
+router.post("/api/v1/employees", createEmployee);
-        e.employee_code, 
-        p.first_name, 
-        p.last_name, 
-        d.name AS department, 
-        j.title AS designation,
-        c.work_email
-       FROM employees e
-       JOIN partners p ON e.partner_id = p.partner_id
-       JOIN contracts c ON e.employee_id = c.employee_id
-       JOIN departments d ON c.department_id = d.department_id
-       JOIN job_positions j ON c.job_id = j.job_id`
-    );
-    
-    ctx.response.body = { 
-      success: true, 
-      count: (rows as any[]).length,
-      data: rows 
-    };
-  } catch (error) {
-    ctx.response.status = 500;
-    ctx.response.body = { 
-      success: false, 
-      error: (error as Error).message 
-    };
-  }
-});
 
 export default router;