import mysql.connector as mariadb from config import database from scripts import loggorilla import datetime class metaprofile: def __init__(self): self.db_main = mariadb.connect(**database.db_main) self.cursor = self.db_main.cursor(dictionary=True) def add(self, params): APIADDR = "/api/metaprofile/add" response = {} loggorilla.prcss(APIADDR, "Define Models") favicon = params["favicon" ] copyright = params["copyright" ] self.cursor.execute("BEGIN;") try: loggorilla.prcss(APIADDR, "Activity: Insert") self.cursor.execute("INSERT INTO `metaprofile` VALUES (DEFAULT, %s, %s) ;", (favicon, copyright) ) loggorilla.prcss(APIADDR, "Set Response") response["status" ] = "success" response["desc" ] = "data updated" except Exception as e: self.cursor.execute("ROLLBACK;") loggorilla.error(APIADDR, str(e) ) loggorilla.prcss(APIADDR, "Set Response") response["status" ] = "failed" response["desc" ] = "Internal Server Error. Please contact us if you still have an error." finally: self.cursor.execute("COMMIT;") self.cursor.close() self.db_main.close() return response def list(self, params): APIADDR = "/api/metaprofile/list" response = {} self.cursor.execute("BEGIN;") try: self.cursor.execute("select `id`, `favicon`, `copyright` from `metaprofile`;") row = self.cursor.fetchall() loggorilla.prcss(APIADDR, "Set Response") response["status" ] = "success" response["desc" ] = "data collected" response["data" ] = row except Exception as e: self.cursor.execute("ROLLBACK;") loggorilla.error(APIADDR, str(e) ) loggorilla.prcss(APIADDR, "Set Response") response["status" ] = "failed" response["desc" ] = "Internal Server Error. Please contact us if you still have an error." finally: self.cursor.execute("COMMIT;") self.cursor.close() self.db_main.close() return response def detail(self, params): APIADDR = "/api/metaprofile/detail" response = {} loggorilla.prcss(APIADDR, "Define Models") key = params["key" ] self.cursor.execute("BEGIN;") try: self.cursor.execute("select `id`, `favicon`, `copyright` from `metaprofile` where `id` = %s ;", (key,) ) row = self.cursor.fetchone() loggorilla.prcss(APIADDR, "Set Response") response["status" ] = "success" response["desc" ] = "data collected" response["data" ] = row except Exception as e: self.cursor.execute("ROLLBACK;") loggorilla.error(APIADDR, str(e) ) loggorilla.prcss(APIADDR, "Set Response") response["status" ] = "failed" response["desc" ] = "Internal Server Error. Please contact us if you still have an error." finally: self.cursor.execute("COMMIT;") self.cursor.close() self.db_main.close() return response def edit(self, params): APIADDR = "/api/metaprofile/edit" response = {} loggorilla.prcss(APIADDR, "Define Models") key = params["key" ] favicon = params["favicon" ] copyright = params["copyright" ] self.cursor.execute("BEGIN;") try: loggorilla.prcss(APIADDR, "Activity: Update") self.cursor.execute("UPDATE `metaprofile` SET `favicon` = %s, `copyright` = %s WHERE `id` = %s ;", (favicon, copyright, key) ) loggorilla.prcss(APIADDR, "Set Response") response["status" ] = "success" response["desc" ] = "data updated" except Exception as e: self.cursor.execute("ROLLBACK;") loggorilla.error(APIADDR, str(e) ) loggorilla.prcss(APIADDR, "Set Response") response["status" ] = "failed" response["desc" ] = "Internal Server Error. Please contact us if you still have an error." finally: self.cursor.execute("COMMIT;") self.cursor.close() self.db_main.close() return response def remove(self, params): APIADDR = "/api/metaprofile/remove" response = {} loggorilla.prcss(APIADDR, "Define Models") key = params["key" ] self.cursor.execute("BEGIN;") try: loggorilla.prcss(APIADDR, "Activity: Remove") self.cursor.execute("DELETE FROM `metaprofile` WHERE `id` = %s ;", (key,) ) loggorilla.prcss(APIADDR, "Set Response") response["status" ] = "success" response["desc" ] = "data updated" except Exception as e: self.cursor.execute("ROLLBACK;") loggorilla.error(APIADDR, str(e) ) loggorilla.prcss(APIADDR, "Set Response") response["status" ] = "failed" response["desc" ] = "Internal Server Error. Please contact us if you still have an error." finally: self.cursor.execute("COMMIT;") self.cursor.close() self.db_main.close() return response