"use strict"; var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) { function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); } return new (P || (P = Promise))(function (resolve, reject) { function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } } function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } } function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); } step((generator = generator.apply(thisArg, _arguments || [])).next()); }); }; var __importDefault = (this && this.__importDefault) || function (mod) { return (mod && mod.__esModule) ? mod : { "default": mod }; }; Object.defineProperty(exports, "__esModule", { value: true }); const fs_1 = __importDefault(require("fs")); require("dotenv").config({ path: "./../.env" }); const varDatabaseDbHandler_1 = __importDefault(require("../functions/backend/varDatabaseDbHandler")); const DB_HANDLER_1 = __importDefault(require("../utils/backend/global-db/DB_HANDLER")); const userId = process.argv.indexOf("--userId") >= 0 ? process.argv[process.argv.indexOf("--userId") + 1] : null; /** * Grab Schema * * @description Grab Schema */ function recoverMainJsonFromDb() { return __awaiter(this, void 0, void 0, function* () { if (!userId) { console.log("No user Id provided"); return; } const databases = yield (0, DB_HANDLER_1.default)(`SELECT * FROM user_databases WHERE user_id='${userId}'`); const dbWrite = []; for (let i = 0; i < databases.length; i++) { const { id, db_name, db_slug, db_full_name, db_image, db_description } = databases[i]; const dbObject = { dbName: db_name, dbSlug: db_slug, dbFullName: db_full_name, dbDescription: db_description, dbImage: db_image, tables: [], }; const tables = yield (0, DB_HANDLER_1.default)(`SELECT * FROM user_database_tables WHERE user_id='${userId}' AND db_id='${id}'`); for (let j = 0; j < tables.length; j++) { const { table_name, table_slug, table_description } = tables[j]; const tableObject = { tableName: table_slug, tableFullName: table_name, fields: [], indexes: [], }; const tableFields = yield (0, varDatabaseDbHandler_1.default)({ database: db_full_name, queryString: `SHOW COLUMNS FROM ${db_full_name}.${table_slug}`, }); for (let k = 0; k < tableFields.length; k++) { const { Field, Type, Null, Default, Key } = tableFields[k]; const fieldObject = { fieldName: Field, dataType: Type.toUpperCase(), }; if ((Default === null || Default === void 0 ? void 0 : Default.match(/./)) && !(Default === null || Default === void 0 ? void 0 : Default.match(/timestamp/i))) fieldObject["defaultValue"] = Default; if (Key === null || Key === void 0 ? void 0 : Key.match(/pri/i)) { fieldObject["primaryKey"] = true; fieldObject["autoIncrement"] = true; } if (Default === null || Default === void 0 ? void 0 : Default.match(/timestamp/i)) fieldObject["defaultValueLiteral"] = Default; if (Null === null || Null === void 0 ? void 0 : Null.match(/yes/i)) fieldObject["nullValue"] = true; if (Null === null || Null === void 0 ? void 0 : Null.match(/no/i)) fieldObject["notNullValue"] = true; tableObject.fields.push(fieldObject); } dbObject.tables.push(tableObject); } dbWrite.push(dbObject); } fs_1.default.writeFileSync(`${String(process.env.DSQL_USER_DB_SCHEMA_PATH)}/user-${userId}/main.json`, JSON.stringify(dbWrite, null, 4), "utf-8"); process.exit(); }); } recoverMainJsonFromDb();