1c92641833
* feat(chalice): upgrades & refacotered image * feat(alerts): upgrades & refacotered image * feat(crons): upgrades & refacotered image * feat(crons): changed build script * feat(alerts): changed build script * feat(crons): changed Dockerfile * feat(alerts): changed shell interpreter * feat(chalice): changed shell interpreter * feat(crons): changed shell interpreter * feat(alerts): changed Dockerfile * feat(chalice): changed Dockerfile * feat(crons): changed Dockerfile * feat(chalice): include tenant_key * feat(chalice): less imports
107 lines
3.7 KiB
Python
107 lines
3.7 KiB
Python
from chalicelib.core import users, license
|
|
from chalicelib.utils import helper
|
|
from chalicelib.utils import pg_client
|
|
|
|
|
|
def get_by_tenant_key(tenant_key):
|
|
with pg_client.PostgresClient() as cur:
|
|
cur.execute(
|
|
cur.mogrify(
|
|
f"""SELECT
|
|
t.tenant_id,
|
|
t.name,
|
|
t.api_key,
|
|
t.created_at,
|
|
'{license.EDITION}' AS edition,
|
|
t.version_number,
|
|
t.opt_out
|
|
FROM public.tenants AS t
|
|
WHERE t.tenant_key = %(tenant_key)s AND t.deleted_at ISNULL
|
|
LIMIT 1;""",
|
|
{"tenant_key": tenant_key})
|
|
)
|
|
return helper.dict_to_camel_case(cur.fetchone())
|
|
|
|
|
|
def get_by_tenant_id(tenant_id):
|
|
with pg_client.PostgresClient() as cur:
|
|
cur.execute(
|
|
cur.mogrify(
|
|
f"""SELECT
|
|
t.tenant_id,
|
|
t.name,
|
|
t.api_key,
|
|
t.created_at,
|
|
'{license.EDITION}' AS edition,
|
|
t.version_number,
|
|
t.opt_out,
|
|
t.tenant_key
|
|
FROM public.tenants AS t
|
|
WHERE t.tenant_id = %(tenantId)s AND t.deleted_at ISNULL
|
|
LIMIT 1;""",
|
|
{"tenantId": tenant_id})
|
|
)
|
|
return helper.dict_to_camel_case(cur.fetchone())
|
|
|
|
|
|
def get_by_api_key(api_key):
|
|
with pg_client.PostgresClient() as cur:
|
|
cur.execute(
|
|
cur.mogrify(
|
|
f"""SELECT
|
|
t.tenant_id,
|
|
t.name,
|
|
t.created_at
|
|
FROM public.tenants AS t
|
|
WHERE t.api_key = %(api_key)s AND t.deleted_at ISNULL
|
|
LIMIT 1;""",
|
|
{"api_key": api_key})
|
|
)
|
|
return helper.dict_to_camel_case(cur.fetchone())
|
|
|
|
|
|
def generate_new_api_key(tenant_id):
|
|
with pg_client.PostgresClient() as cur:
|
|
cur.execute(
|
|
cur.mogrify(
|
|
f"""UPDATE public.tenants
|
|
SET api_key=generate_api_key(20)
|
|
WHERE tenant_id= %(tenant_id)s AND deleted_at ISNULL
|
|
RETURNING api_key;""",
|
|
{"tenant_id": tenant_id})
|
|
)
|
|
return helper.dict_to_camel_case(cur.fetchone())
|
|
|
|
|
|
def edit_client(tenant_id, changes):
|
|
with pg_client.PostgresClient() as cur:
|
|
cur.execute(
|
|
cur.mogrify(f"""\
|
|
UPDATE public.tenants
|
|
SET {", ".join([f"{helper.key_to_snake_case(k)} = %({k})s" for k in changes.keys()])}
|
|
WHERE tenant_id= %(tenant_id)s AND deleted_at ISNULL
|
|
RETURNING name, opt_out;""",
|
|
{"tenantId": tenant_id, **changes})
|
|
)
|
|
return helper.dict_to_camel_case(cur.fetchone())
|
|
|
|
|
|
def update(tenant_id, user_id, data):
|
|
admin = users.get(user_id=user_id, tenant_id=tenant_id)
|
|
|
|
if not admin["admin"] and not admin["superAdmin"]:
|
|
return {"errors": ["unauthorized, needs admin or owner"]}
|
|
if "name" not in data and "optOut" not in data:
|
|
return {"errors": ["please provide 'name' of 'optOut' attribute for update"]}
|
|
changes = {}
|
|
if "name" in data:
|
|
changes["name"] = data["name"]
|
|
if "optOut" in data:
|
|
changes["optOut"] = data["optOut"]
|
|
return edit_client(tenant_id=tenant_id, changes=changes)
|
|
|
|
|
|
def tenants_exists():
|
|
with pg_client.PostgresClient() as cur:
|
|
cur.execute(f"SELECT EXISTS(SELECT 1 FROM public.tenants)")
|
|
return cur.fetchone()["exists"]
|