GeBox ALDER modules
This commit is contained in:
parent
b38f4b7893
commit
92306fdb21
143
modules/api/gebox/instance.py
Normal file
143
modules/api/gebox/instance.py
Normal file
@ -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
|
||||||
|
|
139
modules/api/gebox/package.py
Normal file
139
modules/api/gebox/package.py
Normal file
@ -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
|
||||||
|
|
141
modules/api/gebox/version.py
Normal file
141
modules/api/gebox/version.py
Normal file
@ -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
|
||||||
|
|
Loading…
Reference in New Issue
Block a user