diff --git a/pkgs/api/_dbs.ts b/pkgs/api/_dbs.ts index 5291170..76dc201 100644 --- a/pkgs/api/_dbs.ts +++ b/pkgs/api/_dbs.ts @@ -1,15 +1,16 @@ import { apiContext } from "service-srv"; import { execQuery } from "utils/query"; +const g = global as any; export const _ = { - url: "/_dbs/:dbName/:action", - async api(dbName: any, action?: string) { + url: "/_dbs/:tableName", + async api(tableName: any) { const { req, res } = apiContext(this); - if (typeof db !== "undefined") { + if (typeof g.db !== "undefined") { const body = req.params; try { - const result = await execQuery(body, db); + const result = await execQuery(body, g.db); res.send(result); } catch (e: any) { res.sendStatus(500); diff --git a/pkgs/utils/query.ts b/pkgs/utils/query.ts index 3fe72c7..76d4801 100644 --- a/pkgs/utils/query.ts +++ b/pkgs/utils/query.ts @@ -10,6 +10,8 @@ export type DBArg = { export const execQuery = async (args: DBArg, prisma: any) => { const { table, action, params } = args; + console.log(args); + const tableInstance = prisma[table]; if (tableInstance) {