Stage

.gitignore

@@ -97,3 +97,6 @@ appsettings.json
 __blobstorage__
 __queuestorage__
 __azurite_db*__.json
+
+# files
+local.settings.json

Credentials/controllers/fetching/Create.ts

@@ -1,58 +1,44 @@
-import { checkIfTypeIsString, checkRequestBodyParamsForCreateOrUpdate } from "../../../_helpers/RequestParamsHelper";
+import { checkIfRequestBodyExists, checkIfTypeIsString } from "../../../_common/utils/Request.utils";
 
 import Credential from '../../../_common/models/Credential.model';
 import { HttpRequest } from "@azure/functions";
 import { Password } from '../../models/Password';
+import { checkFetchingRequestBodyParamsForCreateOrUpdate } from "../../../_common/utils/FetchingRequest.utils";
+import { throwIfDatabaseResourceExists } from "../../../_common/utils/DatabaseResponse.utils";
 
 export const create = async (req: HttpRequest) => {
-    const { id_connection, password } = req.body;
+    // Check if request body exists
+    checkIfRequestBodyExists(req.body);
 
-    try {
-        // Chack body params
-        checkRequestBodyParamsForCreateOrUpdate(id_connection, password);
+    const { id_connection, password } = req.body;
 
-        // Check connection
-        checkIfTypeIsString(id_connection, 'id_connection');
+    // Chack body params
+    checkFetchingRequestBodyParamsForCreateOrUpdate(id_connection, password);
 
-        // Check password
-        checkIfTypeIsString(password, 'password');
+    // Check connection
+    checkIfTypeIsString(id_connection, 'id_connection');
 
-        // Check if row with id_connection already exists
-        const response_from_db = await Credential.get(id_connection);
+    // Check password
+    checkIfTypeIsString(password, 'password');
 
-        if (response_from_db) {
-            return {
-                status: 409,
-                body: {
-                    status: 'Fail',
-                    description: 'Resource with the provided id_connection already exists.'
-                }
-            };
-        }
+    // Check if row with id_connection already exists
+    const response_from_db = await Credential.get(id_connection);
 
-        const encrypt_password = Password.encryptPassword(password);
+    // If exists throw error 409 - Conflict
+    throwIfDatabaseResourceExists(response_from_db, 'id_connection');
 
-        await Credential.create(encrypt_password, id_connection);
-    }
-    catch (error) {
-        if (error.status) {
-            return error;
-        }
+    const encrypt_password = Password.encryptPassword(password);
 
-        return {
-            status: 500,
-            body: {
-                status: 'Error',
-                description: 'An unexpected error occurred. Please try again later.'
-            }
-        };
-    }
+    await Credential.create(encrypt_password, id_connection);
 
     return {
         status: 201,
         body: {
-            status: 'OK',
+            status: 'Created',
             description: 'New resource created successfully.'
+        },
+        headers: {
+            'Content-Type': 'application/json'
         }
     };
 }

Credentials/controllers/fetching/Get.ts

@@ -1,50 +1,30 @@
-import { checkIfTypeIsString, checkRequestQueryParamsForGetOrRemove } from "../../../_helpers/RequestParamsHelper";
+import { checkIfTypeIsString } from "../../../_common/utils/Request.utils";
+import { checkFetchingRequestQueryParamsForGetOrDelete } from "../../../_common/utils/FetchingRequest.utils";
 
 import Credential from '../../../_common/models/Credential.model';
 import { HttpRequest } from "@azure/functions";
+import { throwIfDatabaseResourceNotExists } from "../../../_common/utils/DatabaseResponse.utils";
 
 export const get = async (req: HttpRequest) => {
     const { id_connection } = req.query;
 
-    try {
-        // Chack body params
-        checkRequestQueryParamsForGetOrRemove(id_connection);
+    // Chack body params
+    checkFetchingRequestQueryParamsForGetOrDelete(id_connection);
 
-        // Check connection
-        checkIfTypeIsString(id_connection, 'id_connection');
+    // Check connection
+    checkIfTypeIsString(id_connection, 'id_connection');
 
-        // Check if row with id_connection already exists
-        const response_from_db = await Credential.get(id_connection);
+    // Check if row with id_connection already exists
+    const response_from_db = await Credential.get(id_connection);
 
-        if (!response_from_db) {
-            return {
-                status: 404,
-                body: {
-                    status: 'Fail',
-                    description: 'Resource with the provided id_connection not exists.'
-                }
-            };
-        }
+    // If not exists throw error 404 - Not found
+    throwIfDatabaseResourceNotExists(response_from_db, 'id_connection');
 
-        return {
-            status: 200,
-            body: {
-                status: 'OK',
-                payload: response_from_db
-            }
-        };
-    }
-    catch (error) {
-        if (error.status) {
-            return error;
+    return {
+        status: 200,
+        body: {
+            status: 'OK',
+            payload: response_from_db
         }
-
-        return {
-            status: 500,
-            body: {
-                status: 'Error',
-                description: 'An unexpected error occurred. Please try again later.'
-            }
-        };
-    }
-}
+    };
+}

Credentials/controllers/fetching/Remove.ts

@@ -1,46 +1,29 @@
-import { checkIfTypeIsString, checkRequestQueryParamsForGetOrRemove } from "../../../_helpers/RequestParamsHelper";
+import { checkIfRequestBodyExists, checkIfTypeIsString } from "../../../_common/utils/Request.utils";
+import { checkFetchingRequestBodyParamsForDelete } from "../../../_common/utils/FetchingRequest.utils";
 
 import Credential from '../../../_common/models/Credential.model';
 import { HttpRequest } from "@azure/functions";
+import { throwIfDatabaseResourceNotExists } from "../../../_common/utils/DatabaseResponse.utils";
 
 export const remove = async (req: HttpRequest) => {
-    const { id_connection } = req.body;
+    // Check if request body exists
+    checkIfRequestBodyExists(req.body);
 
-    try {
-        // Chack body params
-        checkRequestQueryParamsForGetOrRemove(id_connection);
+    const { id_connection } = req.body;
 
-        // Check connection
-        checkIfTypeIsString(id_connection, 'id_connection');
+    // Chack body params
+    checkFetchingRequestBodyParamsForDelete(id_connection);
 
-        // Check if row with id_connection already exists
-        let response_from_db = await Credential.get(id_connection.toString());
+    // Check connection
+    checkIfTypeIsString(id_connection, 'id_connection');
 
-        if (!response_from_db) {
-            return {
-                status: 404,
-                body: {
-                    status: 'Fail',
-                    description: 'Resource with the provided id_connection does not exist.'
-                }
-            };
-        }
+    // Check if row with id_connection already exists
+    let response_from_db = await Credential.get(id_connection.toString());
 
-        await Credential.delete(response_from_db);
-    }
-    catch (error) {
-        if (error.status) {
-            return error;
-        }
+    // If not exists throw error 404 - Not found
+    throwIfDatabaseResourceNotExists(response_from_db, 'id_connection');
 
-        return {
-            status: 500,
-            body: {
-                status: 'Error',
-                description: 'An unexpected error occurred. Please try again later.'
-            }
-        };
-    }
+    await Credential.delete(response_from_db);
 
     return {
         status: 200,

Credentials/controllers/fetching/Update.ts

@@ -1,58 +1,39 @@
-import { checkIfTypeIsString, checkRequestBodyParamsForCreateOrUpdate } from "../../../_helpers/RequestParamsHelper";
+import { checkIfRequestBodyExists, checkIfTypeIsString } from "../../../_common/utils/Request.utils";
+import { checkFetchingRequestBodyParamsForCreateOrUpdate } from "../../../_common/utils/FetchingRequest.utils";
 
 import Credential from '../../../_common/models/Credential.model';
 import { HttpRequest } from "@azure/functions";
 import { Password } from "../../models/Password";
+import { throwIfDatabaseResourceNotExists } from "../../../_common/utils/DatabaseResponse.utils";
 
 export const update = async (req: HttpRequest) => {
+    // Check if request body exists
+    checkIfRequestBodyExists(req.body);
+
     const { id_connection, password } = req.body;
 
-    try {
-        // Chack body params
-        checkRequestBodyParamsForCreateOrUpdate(id_connection, password);
+    // Chack body params
+    checkFetchingRequestBodyParamsForCreateOrUpdate(id_connection, password);
 
-        // Check connection
-        checkIfTypeIsString(id_connection, 'id_connection');
+    // Check connection
+    checkIfTypeIsString(id_connection, 'id_connection');
 
-        // Check password
-        checkIfTypeIsString(password, 'password');
+    // Check password
+    checkIfTypeIsString(password, 'password');
 
-        const encrypt_password = Password.encryptPassword(password);
+    const encrypt_password = Password.encryptPassword(password);
 
-        // Check if row with id_connection already exists
-        let response_from_db = await Credential.get(id_connection.toString());
+    // Check if row with id_connection already exists
+    let response_from_db = await Credential.get(id_connection.toString());
 
-        // If not exist create
-        if (!response_from_db) {
-            return {
-                status: 404,
-                body: {
-                    status: 'Fail',
-                    description: 'Resource with the provided ID Credential does not exist.'
-                }
-            };
-        }
-        else {
-            // Update object properties
-            response_from_db.password = encrypt_password;
-            response_from_db.updated_at = new Date().toISOString();
+    // If not exists throw error 404 - Not found
+    throwIfDatabaseResourceNotExists(response_from_db, 'id_connection');
 
-            await Credential.update(response_from_db);
-        }
-    }
-    catch (error) {
-        if (error.status) {
-            return error;
-        }
+    // Update object properties
+    response_from_db.password = encrypt_password;
+    response_from_db.updated_at = new Date().toISOString();
 
-        return {
-            status: 500,
-            body: {
-                status: 'Error',
-                description: 'An unexpected error occurred. Please try again later.'
-            }
-        };
-    }
+    await Credential.update(response_from_db);
 
     return {
         status: 200,

Credentials/controllers/receiving/Create.ts

@@ -0,0 +1,53 @@
+import { checkIfPositiveIntegerNumber, checkIfRequestBodyExists, checkIfTypeIsString } from "../../../_common/utils/Request.utils";
+
+import { HttpRequest } from "@azure/functions";
+import ReceivingCredential from '../../../_common/models/ReceivingCredential.model';
+import { checkReceivingRequestBodyParamsForCreateOrUpdate } from '../../../_common/utils/ReceivingRequest.utils';
+import { throwIfDatabaseResourceExists } from "../../../_common/utils/DatabaseResponse.utils";
+
+export const createReceive = async (req: HttpRequest) => {
+    // Check if request body exists
+    checkIfRequestBodyExists(req.body);
+
+    const { uuid, username, id_account } = req.body;
+
+    // Chack body params
+    checkReceivingRequestBodyParamsForCreateOrUpdate(uuid, username, id_account);
+
+    checkIfPositiveIntegerNumber(id_account, 'id_account');
+
+    checkIfTypeIsString(uuid, 'uuid');
+
+    checkIfTypeIsString(username, 'username');
+
+    // Check if row with id_account already exists
+    let response_from_db = await ReceivingCredential.get(id_account);
+
+    // If exists throw error 409 - Conflict
+    throwIfDatabaseResourceExists(response_from_db, 'id_account');
+
+    // Check if row with uuid already exists
+    response_from_db = await ReceivingCredential.getUUID(uuid);
+
+    // If exists throw error 409 - Conflict
+    throwIfDatabaseResourceExists(response_from_db, 'uuid');
+
+    // Check if row with uuid already exists
+    response_from_db = await ReceivingCredential.getUsername(username);
+
+    // If exists throw error 409 - Conflict
+    throwIfDatabaseResourceExists(response_from_db, 'username');
+
+    await ReceivingCredential.create(id_account, uuid, username);
+
+    return {
+        status: 201,
+        body: {
+            status: 'Created',
+            description: 'New resource created successfully.'
+        },
+        headers: {
+            'Content-Type': 'application/json'
+        }
+    };
+}