add & repair: roles schema,roles service & roles router, roles controller

db/role.db.js

@@ -1,95 +0,0 @@
-const pool = require("../config");
-
-// Get all roles
-const getAllRolesDb = async (filters = {}) => {
-  const { whereConditions, queryParams } = pool.buildFilterQuery([
-    { column: "r.role_name", param: filters.role_name, type: "string" },
-    { column: "r.role_level", param: filters.role_level, type: "number" },
-  ]);
-
-  const whereClause = whereConditions.length ? `AND ${whereConditions.join(" AND ")}` : "";
-
-  const queryText = `
-    SELECT 
-      r.role_id,
-      r.role_name,
-      r.role_description,
-      r.role_level,
-      r.created_at,
-      r.updated_at,
-      r.updated_by,
-      r.deleted_at,
-      r.deleted_by
-    FROM m_roles r
-    WHERE r.deleted_at IS NULL ${whereClause}
-    ORDER BY r.role_id ASC
-  `;
-
-  const result = await pool.query(queryText, queryParams);
-  return result.recordset;
-};
-
-// Get role by ID
-const getRoleByIdDb = async (id) => {
-  const queryText = `
-    SELECT 
-      role_id,
-      role_name,
-      role_description,
-      role_level,
-      created_at,
-      updated_at,
-      updated_by,
-      deleted_at,
-      deleted_by
-    FROM m_roles
-    WHERE role_id = $1 AND deleted_at IS NULL
-  `;
-  const result = await pool.query(queryText, [id]);
-  return result.recordset;
-};
-
-// Create role
-const createRoleDb = async (data) => {
-  const roles = { ...data };
-
-  const { query, values } = pool.buildDynamicInsert("m_roles", {
-    ...roles,
-  });
-
-  const result = await pool.query(query, values);
-  return result.recordset[0]?.inserted_id || null;
-};
-
-
-
-// Update role
-const updateRoleDb = async (id, data) => {
-  const { query, values } = pool.buildDynamicUpdate(
-    "m_roles",
-    { ...data },
-    { role_id: id }
-  );
-  await pool.query(query, values);
-  return true;
-};
-
-// Soft delete role
-const deleteRoleDb = async (id, deletedBy) => {
-  const queryText = `
-    UPDATE m_roles
-    SET deleted_at = GETDATE(),
-        deleted_by = $1
-    WHERE role_id = $2
-  `;
-  await pool.query(queryText, [deletedBy, id]);
-  return true;
-};
-
-module.exports = {
-  getAllRolesDb,
-  getRoleByIdDb,
-  createRoleDb,
-  updateRoleDb,
-  deleteRoleDb,
-};

db/roles.db.js

@@ -0,0 +1,114 @@
+const pool = require("../config");
+
+// Get all roles
+const getAllRolesDb = async (searchParams = {}) => {
+  let queryParams = [];
+
+  // Pagination
+  if (searchParams.limit) {
+    const page = Number(searchParams.page ?? 1) - 1;
+    queryParams = [Number(searchParams.limit ?? 10), page];
+  }
+
+  // Filtering
+  const { whereConditions, whereParamAnd } = pool.buildFilterQuery(
+    [
+      { column: "r.role_name", param: searchParams.role_name, type: "string" },
+      { column: "r.role_level", param: searchParams.role_level, type: "number" },
+    ],
+    queryParams
+  );
+
+  queryParams = whereParamAnd ? whereParamAnd : queryParams;
+
+  const queryText = `
+    SELECT 
+      COUNT(*) OVER() AS total_data,
+      r.role_id,
+      r.role_name,
+      r.role_description,
+      r.role_level,
+      r.created_at,
+      r.updated_at,
+      r.updated_by,
+      r.deleted_at,
+      r.deleted_by,
+      r.created_by
+    FROM m_roles r
+    WHERE r.deleted_at IS NULL
+    ${whereConditions.length > 0 ? `AND ${whereConditions.join(" AND ")}` : ""}
+    ORDER BY r.role_id ASC
+    ${searchParams.limit ? `OFFSET $2 ROWS FETCH NEXT $1 ROWS ONLY` : ''};
+  `;
+
+  const result = await pool.query(queryText, queryParams);
+
+  const total = result?.recordset.length > 0 
+    ? parseInt(result.recordset[0].total_data, 10) 
+    : 0;
+
+  return { data: result.recordset, total };
+};
+
+// Get role by ID
+const getRolesByIdDb = async (id) => {
+  const queryText = `
+    SELECT 
+      r.role_id,
+      r.role_name,
+      r.role_description,
+      r.role_level,
+      r.created_at,
+      r.updated_at,
+      r.updated_by,
+      r.deleted_at,
+      r.deleted_by,
+      r.created_by
+    FROM m_roles r
+    WHERE r.role_id = $1 AND r.deleted_at IS NULL
+  `;
+  const result = await pool.query(queryText, [id]);
+  return result.recordset;
+};
+
+// Create role
+const createRolesDB = async (data) => {
+  const store = { ...data };
+
+  const { query: queryText, values } = pool.buildDynamicInsert("m_roles", store);
+  const result = await pool.query(queryText, values);
+
+  const insertedId = result.recordset[0]?.inserted_id;
+  return insertedId ? await getRolesByIdDb(insertedId) : null;
+};
+
+// Update role
+const updateRolesDb = async (id, data) => {
+  const store = { ...data };
+  const whereData = { role_id: id };
+
+  const { query: queryText, values } = pool.buildDynamicUpdate("m_roles", store, whereData);
+  await pool.query(`${queryText} AND deleted_at IS NULL`, values);
+
+  return getRolesByIdDb(id);
+};
+
+// Soft delete role
+const deleteRolesDb = async (id, deletedBy) => {
+  const queryText = `
+    UPDATE m_roles
+    SET deleted_at = CURRENT_TIMESTAMP,
+        deleted_by = $1
+    WHERE role_id = $2 AND deleted_at IS NULL
+  `;
+  await pool.query(queryText, [deletedBy, id]);
+  return true;
+};
+
+module.exports = {
+  getAllRolesDb,
+  getRolesByIdDb,
+  createRolesDB,
+  updateRolesDb,
+  deleteRolesDb,
+};