This commit is contained in:
Benjamin Toby 2025-01-20 07:43:04 +01:00
parent dfe6fb3177
commit 3dd1d08a5b
3 changed files with 14 additions and 11 deletions

View File

@ -27,7 +27,9 @@ const loginSocialUser_1 = __importDefault(require("./loginSocialUser"));
function handleSocialDb(_a) { function handleSocialDb(_a) {
return __awaiter(this, arguments, void 0, function* ({ database, social_id, email, social_platform, payload, invitation, supEmail, additionalFields, useLocal, }) { return __awaiter(this, arguments, void 0, function* ({ database, social_id, email, social_platform, payload, invitation, supEmail, additionalFields, useLocal, }) {
try { try {
const existingSocialIdUserQuery = `SELECT * FROM datasquirel.users WHERE social_id = ? AND social_login='1' AND social_platform = ? `; const finalDbName = database ? database : "datasquirel";
const dbAppend = database ? `${finalDbName}.` : "";
const existingSocialIdUserQuery = `SELECT * FROM ${dbAppend}users WHERE social_id = ? AND social_login='1' AND social_platform = ? `;
const existingSocialIdUserValues = [ const existingSocialIdUserValues = [
social_id.toString(), social_id.toString(),
social_platform, social_platform,
@ -56,7 +58,7 @@ function handleSocialDb(_a) {
msg: "No Email Present", msg: "No Email Present",
}; };
} }
const existingEmailOnlyQuery = `SELECT * FROM datasquirel.users WHERE email='${finalEmail}'`; const existingEmailOnlyQuery = `SELECT * FROM ${dbAppend}users WHERE email='${finalEmail}'`;
let existingEmailOnly = yield (0, varDatabaseDbHandler_1.default)({ let existingEmailOnly = yield (0, varDatabaseDbHandler_1.default)({
database: database ? database : "datasquirel", database: database ? database : "datasquirel",
queryString: existingEmailOnlyQuery, queryString: existingEmailOnlyQuery,
@ -69,7 +71,7 @@ function handleSocialDb(_a) {
msg: "This Email is already taken", msg: "This Email is already taken",
}; };
} }
const foundUserQuery = `SELECT * FROM datasquirel.users WHERE email=? AND social_login='1' AND social_platform=? AND social_id=?`; const foundUserQuery = `SELECT * FROM ${dbAppend}users WHERE email=? AND social_login='1' AND social_platform=? AND social_id=?`;
const foundUserQueryValues = [finalEmail, social_platform, social_id]; const foundUserQueryValues = [finalEmail, social_platform, social_id];
const foundUser = yield (0, varDatabaseDbHandler_1.default)({ const foundUser = yield (0, varDatabaseDbHandler_1.default)({
database: database ? database : "datasquirel", database: database ? database : "datasquirel",
@ -98,7 +100,6 @@ function handleSocialDb(_a) {
Object.keys(payload).forEach((key) => { Object.keys(payload).forEach((key) => {
data[key] = payload[key]; data[key] = payload[key];
}); });
/** @type {any} */
const newUser = yield (0, addDbEntry_1.default)({ const newUser = yield (0, addDbEntry_1.default)({
dbContext: database ? "Dsql User" : undefined, dbContext: database ? "Dsql User" : undefined,
paradigm: database ? "Full Access" : undefined, paradigm: database ? "Full Access" : undefined,
@ -116,7 +117,7 @@ function handleSocialDb(_a) {
*/ */
yield (0, addMariadbUser_1.default)({ userId: newUser.insertId, useLocal }); yield (0, addMariadbUser_1.default)({ userId: newUser.insertId, useLocal });
} }
const newUserQueriedQuery = `SELECT * FROM datasquirel.users WHERE id='${newUser.insertId}'`; const newUserQueriedQuery = `SELECT * FROM ${dbAppend}users WHERE id='${newUser.insertId}'`;
const newUserQueried = yield (0, varDatabaseDbHandler_1.default)({ const newUserQueried = yield (0, varDatabaseDbHandler_1.default)({
database: database ? database : "datasquirel", database: database ? database : "datasquirel",
queryString: newUserQueriedQuery, queryString: newUserQueriedQuery,

View File

@ -26,7 +26,10 @@ export default async function handleSocialDb({
useLocal, useLocal,
}: HandleSocialDbFunctionParams): Promise<APILoginFunctionReturn> { }: HandleSocialDbFunctionParams): Promise<APILoginFunctionReturn> {
try { try {
const existingSocialIdUserQuery = `SELECT * FROM datasquirel.users WHERE social_id = ? AND social_login='1' AND social_platform = ? `; const finalDbName = database ? database : "datasquirel";
const dbAppend = database ? `${finalDbName}.` : "";
const existingSocialIdUserQuery = `SELECT * FROM ${dbAppend}users WHERE social_id = ? AND social_login='1' AND social_platform = ? `;
const existingSocialIdUserValues = [ const existingSocialIdUserValues = [
social_id.toString(), social_id.toString(),
social_platform, social_platform,
@ -60,7 +63,7 @@ export default async function handleSocialDb({
}; };
} }
const existingEmailOnlyQuery = `SELECT * FROM datasquirel.users WHERE email='${finalEmail}'`; const existingEmailOnlyQuery = `SELECT * FROM ${dbAppend}users WHERE email='${finalEmail}'`;
let existingEmailOnly = await varDatabaseDbHandler({ let existingEmailOnly = await varDatabaseDbHandler({
database: database ? database : "datasquirel", database: database ? database : "datasquirel",
@ -76,7 +79,7 @@ export default async function handleSocialDb({
}; };
} }
const foundUserQuery = `SELECT * FROM datasquirel.users WHERE email=? AND social_login='1' AND social_platform=? AND social_id=?`; const foundUserQuery = `SELECT * FROM ${dbAppend}users WHERE email=? AND social_login='1' AND social_platform=? AND social_id=?`;
const foundUserQueryValues = [finalEmail, social_platform, social_id]; const foundUserQueryValues = [finalEmail, social_platform, social_id];
const foundUser = await varDatabaseDbHandler({ const foundUser = await varDatabaseDbHandler({
@ -111,7 +114,6 @@ export default async function handleSocialDb({
data[key] = payload[key]; data[key] = payload[key];
}); });
/** @type {any} */
const newUser = await addDbEntry({ const newUser = await addDbEntry({
dbContext: database ? "Dsql User" : undefined, dbContext: database ? "Dsql User" : undefined,
paradigm: database ? "Full Access" : undefined, paradigm: database ? "Full Access" : undefined,
@ -134,7 +136,7 @@ export default async function handleSocialDb({
await addMariadbUser({ userId: newUser.insertId, useLocal }); await addMariadbUser({ userId: newUser.insertId, useLocal });
} }
const newUserQueriedQuery = `SELECT * FROM datasquirel.users WHERE id='${newUser.insertId}'`; const newUserQueriedQuery = `SELECT * FROM ${dbAppend}users WHERE id='${newUser.insertId}'`;
const newUserQueried = await varDatabaseDbHandler({ const newUserQueried = await varDatabaseDbHandler({
database: database ? database : "datasquirel", database: database ? database : "datasquirel",

View File

@ -1,6 +1,6 @@
{ {
"name": "@moduletrace/datasquirel", "name": "@moduletrace/datasquirel",
"version": "3.7.3", "version": "3.7.4",
"description": "Cloud-based SQL data management tool", "description": "Cloud-based SQL data management tool",
"main": "dist/index.js", "main": "dist/index.js",
"bin": { "bin": {