diff --git a/modules/api/gebox/instance.py b/modules/api/gebox/instance.py new file mode 100644 index 0000000..c99205c --- /dev/null +++ b/modules/api/gebox/instance.py @@ -0,0 +1,143 @@ +import mysql.connector as mariadb + +from bottle import request +from config import database +from scripts import loggorilla + +import datetime + +class instance: + + 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/gebox/instance/add" + response = {} + loggorilla.prcss(APIADDR, "Define Models") + instance = params["instance" ] + domain = params["domain" ] + product = params["product" ] + status = params["status" ] + self.cursor.execute("BEGIN;") + try: + loggorilla.prcss(APIADDR, "Activity: Insert") + self.cursor.execute("INSERT INTO `gebox_instance` VALUES (DEFAULT, %s, %s, %s, %s ) ;", (instance, domain, product, status) ) + loggorilla.prcss(APIADDR, "Set Response") + response["status" ] = "success" + response["desc" ] = "data added" + 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/gebox/instance/list" + response = {} + self.cursor.execute("BEGIN;") + try: + self.cursor.execute("select * from gebox_instance;") + ls = self.cursor.fetchall() + loggorilla.prcss(APIADDR, "Set Response") + response["status" ] = "success" + response["desc" ] = "data collected" + response["data" ] = ls + 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/gebox/instance/detail" + response = {} + loggorilla.prcss(APIADDR, "Define Models") + key = params["key" ] + self.cursor.execute("BEGIN;") + try: + self.cursor.execute("select * from gebox_instance 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/gebox/instance/edit" + response = {} + loggorilla.prcss(APIADDR, "Define Models") + key = params["key" ] + instance = params["instance" ] + domain = params["domain" ] + product = params["product" ] + status = params["status" ] + self.cursor.execute("BEGIN;") + try: + loggorilla.prcss(APIADDR, "Update") + self.cursor.execute("update gebox_instance set `instance` = %s, `domain` = %s, `product` = %s, `status` = %s where `id` = %s ;", (instance, domain, product, status, key) ) + row = self.cursor.fetchone() + loggorilla.prcss(APIADDR, "Set Response") + response["status" ] = "success" + response["desc" ] = "data edited" + 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/gebox/instance/remove" + response = {} + loggorilla.prcss(APIADDR, "Define Models") + key = params["key" ] + self.cursor.execute("BEGIN;") + try: + loggorilla.prcss(APIADDR, "Delete") + self.cursor.execute("delete from gebox_instance where `id` = %s ;", (key,) ) + row = self.cursor.fetchone() + loggorilla.prcss(APIADDR, "Set Response") + response["status" ] = "success" + response["desc" ] = "data edited" + 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 + diff --git a/modules/api/gebox/package.py b/modules/api/gebox/package.py new file mode 100644 index 0000000..a9a0b0a --- /dev/null +++ b/modules/api/gebox/package.py @@ -0,0 +1,139 @@ +import mysql.connector as mariadb + +from bottle import request +from config import database +from scripts import loggorilla + +import datetime + +class package: + + 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/gebox/package/add" + response = {} + loggorilla.prcss(APIADDR, "Define Models") + name = params["name" ] + desc = params["desc" ] + self.cursor.execute("BEGIN;") + try: + loggorilla.prcss(APIADDR, "Activity: Insert") + self.cursor.execute("INSERT INTO `gebox_package` VALUES (DEFAULT, %s, %s ) ;", (name, desc) ) + loggorilla.prcss(APIADDR, "Set Response") + response["status" ] = "success" + response["desc" ] = "data added" + 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/gebox/package/list" + response = {} + self.cursor.execute("BEGIN;") + try: + self.cursor.execute("select * from gebox_package;") + ls = self.cursor.fetchall() + loggorilla.prcss(APIADDR, "Set Response") + response["status" ] = "success" + response["desc" ] = "data collected" + response["data" ] = ls + 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/gebox/package/detail" + response = {} + loggorilla.prcss(APIADDR, "Define Models") + key = params["key" ] + self.cursor.execute("BEGIN;") + try: + self.cursor.execute("select * from gebox_package 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/gebox/package/edit" + response = {} + loggorilla.prcss(APIADDR, "Define Models") + key = params["key" ] + name = params["name" ] + desc = params["desc" ] + self.cursor.execute("BEGIN;") + try: + loggorilla.prcss(APIADDR, "Update") + self.cursor.execute("update gebox_package set `name` = %s, `desc` = %s where `id` = %s ;", (name, desc, key) ) + row = self.cursor.fetchone() + loggorilla.prcss(APIADDR, "Set Response") + response["status" ] = "success" + response["desc" ] = "data edited" + 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/gebox/package/remove" + response = {} + loggorilla.prcss(APIADDR, "Define Models") + key = params["key" ] + self.cursor.execute("BEGIN;") + try: + loggorilla.prcss(APIADDR, "Delete") + self.cursor.execute("delete from gebox_package where `id` = %s ;", (key,) ) + row = self.cursor.fetchone() + loggorilla.prcss(APIADDR, "Set Response") + response["status" ] = "success" + response["desc" ] = "data edited" + 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 + diff --git a/modules/api/gebox/version.py b/modules/api/gebox/version.py new file mode 100644 index 0000000..2ce6aec --- /dev/null +++ b/modules/api/gebox/version.py @@ -0,0 +1,141 @@ +import mysql.connector as mariadb + +from bottle import request +from config import database +from scripts import loggorilla + +import datetime + +class version: + + 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/gebox/version/add" + response = {} + loggorilla.prcss(APIADDR, "Define Models") + package = params["package" ] + version = params["version" ] + release = params["release" ] + self.cursor.execute("BEGIN;") + try: + loggorilla.prcss(APIADDR, "Insert") + self.cursor.execute("INSERT INTO `gebox_package_version` VALUES (DEFAULT, %s, %s, %s ) ;", (package, version, release) ) + loggorilla.prcss(APIADDR, "Set Response") + response["status" ] = "success" + response["desc" ] = "data added" + 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/gebox/version/list" + response = {} + self.cursor.execute("BEGIN;") + try: + self.cursor.execute("select * from gebox_package_version;") + ls = self.cursor.fetchall() + loggorilla.prcss(APIADDR, "Set Response") + response["status" ] = "success" + response["desc" ] = "data collected" + response["data" ] = ls + 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/gebox/version/detail" + response = {} + loggorilla.prcss(APIADDR, "Define Models") + key = params["key" ] + self.cursor.execute("BEGIN;") + try: + self.cursor.execute("select * from gebox_package_version 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/gebox/version/edit" + response = {} + loggorilla.prcss(APIADDR, "Define Models") + key = params["key" ] + package = params["package" ] + version = params["version" ] + release = params["release" ] + self.cursor.execute("BEGIN;") + try: + loggorilla.prcss(APIADDR, "Update") + self.cursor.execute("update gebox_package_version set `package` = %s, `version` = %s, `release` = %s where `id` = %s ;", (package, version, release, key) ) + row = self.cursor.fetchone() + loggorilla.prcss(APIADDR, "Set Response") + response["status" ] = "success" + response["desc" ] = "data edited" + 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/gebox/version/remove" + response = {} + loggorilla.prcss(APIADDR, "Define Models") + key = params["key" ] + self.cursor.execute("BEGIN;") + try: + loggorilla.prcss(APIADDR, "Delete") + self.cursor.execute("delete from gebox_package_version where `id` = %s ;", (key,) ) + row = self.cursor.fetchone() + loggorilla.prcss(APIADDR, "Set Response") + response["status" ] = "success" + response["desc" ] = "data edited" + 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 +