feat(produser): added the ability to add a prod user by default roles and update if already there

server/services/prodUser/controller/addProdRole.ts

@@ -0,0 +1 @@
+export const addProdRole = async (data: any) => {};

server/services/prodUser/controller/produser.ts

@@ -0,0 +1,150 @@
+import axios from "axios";
+import { db } from "../../../../database/dbclient.js";
+import { prodPermissions } from "../../../../database/schema/prodPermissions.js";
+import { tryCatch } from "../../../globalUtils/tryCatch.js";
+import { query } from "../../sqlServer/prodSqlServer.js";
+import { userCheck } from "../../sqlServer/querys/prodUser/usercheck.js";
+import { prodEndpointCreation } from "../../../globalUtils/createUrl.js";
+export const prodUser = async (data: any) => {
+    // get the prodPermissions so we can make sure we have one in here
+    const { data: prodPerm, error: pe } = await tryCatch(
+        db.select().from(prodPermissions)
+    );
+
+    // create url
+    const grantUrl = await prodEndpointCreation(
+        `/public/v1.0/Administration/User/${data.username}/Grant`
+    );
+
+    const newurl = await prodEndpointCreation(
+        `/public/v1.0/Administration/User`
+    );
+
+    const revoke = await prodEndpointCreation(
+        `/public/v1.0/Administration/User/${data.username}/Revoke`
+    );
+
+    if (pe) {
+        console.log(pe);
+        return {
+            succes: false,
+            message: "There was an error getting the base prod permissions",
+            data: pe,
+        };
+    }
+
+    // check if we sent over a valid permissions fole over
+    const permRoleCheck = prodPerm.filter((n: any) => n.name === data.role);
+
+    if (permRoleCheck.length === 0) {
+        return {
+            succes: false,
+            message: `Role: ${data.role}, dose note exist please check the role you have selected and try again.`,
+            data: [],
+        };
+    }
+
+    // dose this user already exist?
+    const quc = userCheck.replace("[userName]", data.username);
+    const { data: usercheck, error: userError } = (await tryCatch(
+        query(quc, "Checks for existing user")
+    )) as any;
+
+    if (userError) {
+        console.log(userError);
+    }
+
+    if (usercheck?.data.length === 0) {
+        // create the user
+        const newUser: any = {
+            userId: data.username,
+            remark: data.remark,
+            languageCode: "en",
+            active: true,
+            roles: permRoleCheck[0].roles,
+            rolesLegacy: permRoleCheck[0].rolesLegacy,
+        };
+
+        const { data: newU, error: newE } = await tryCatch(
+            axios.post(newurl, newUser, {
+                headers: {
+                    Authorization: `Basic ${btoa(
+                        `matthes01:99Monsters200Scary!`
+                    )}`,
+                    "Content-Type": "application/json",
+                },
+            })
+        );
+
+        if (newE) {
+            console.log(newE);
+        }
+
+        return {
+            succes: true,
+            message: `${data.username} was just created or updated.`,
+            data: [],
+        };
+    } else {
+        // revoke and readd
+
+        const revokePerms: any = {
+            roles:
+                JSON.parse(usercheck.data[0].roles.replaceAll("\\", "\\\\")) ||
+                [],
+            rolesLegacy: JSON.parse(usercheck.data[0].legacyRoles) || [],
+        };
+
+        const { data: newU, error: newE } = (await tryCatch(
+            axios.patch(revoke, revokePerms, {
+                headers: {
+                    Authorization: `Basic ${btoa(
+                        `matthes01:99Monsters200Scary!`
+                    )}`,
+                    "Content-Type": "application/json",
+                },
+            })
+        )) as any;
+
+        if (newE) {
+            console.log(newE.response.data);
+            return {
+                succes: false,
+                message: `${data.username} encountered an error updating..`,
+                data: newE.response.data,
+            };
+        }
+
+        // add the new roles to the user.
+        const grantRole: any = {
+            roles: permRoleCheck[0].roles,
+            rolesLegacy: permRoleCheck[0].rolesLegacy,
+        };
+
+        const { data: grant, error: grante } = (await tryCatch(
+            axios.patch(grantUrl, grantRole, {
+                headers: {
+                    Authorization: `Basic ${btoa(
+                        `matthes01:99Monsters200Scary!`
+                    )}`,
+                    "Content-Type": "application/json",
+                },
+            })
+        )) as any;
+
+        if (grante) {
+            console.log(newE.response.data);
+            return {
+                succes: false,
+                message: `${data.username} encountered an error updating..`,
+                data: newE.response.data,
+            };
+        }
+    }
+
+    return {
+        succes: true,
+        message: `${data.username} was just created or updated.`,
+        data: [],
+    };
+};