diff --git a/src/services/mysql.service.ts b/src/services/mysql.service.ts index 9443d01..cba9aec 100644 --- a/src/services/mysql.service.ts +++ b/src/services/mysql.service.ts @@ -183,24 +183,21 @@ const MySqlService = { */ update(handler: MysqlHandler, data: IUserUpdate): Promise { return new Promise((resolve, reject) => { - if (!data.id) return reject("Id is undefined"); - if (data.id.length !== 36) return reject("Id invalid"); if (data.gdpr && typeof data.gdpr !== typeof Date) { return reject("Invalid gdpr date.") } + if (!data.id) return reject("Id is undefined"); + if (data.id.length !== 36) return reject("Id invalid"); try { - const _values = []; - const _template = ` - ${data.username ? "`username` = ?," && _values.push(data.username) as unknown as void : null} - ${data.firstname ? "`firstname` = ?," : null} - ${data.lastname ? "`lastname` = ?," : null} - ${data.dob ? "`dob` = ?," : null} - ${data.gdpr ? "`gdpr` = ?," : null}` - - const _sql = `UPDATE "users" SET ${_template} WHERE 'id' = ?`; - handler.execute(_sql, _values).then((result) => { - return resolve(result as unknown as IDbStatusResult); - }); + handler.factorize({ + values: data, + actionName: `Update user ID::${data.id}` + }).then((result)=>{ + const _sql = `UPDATE "users" SET ${result._keysTemplate} WHERE 'id' = '${data.id}'`; + handler.execute(_sql, result._valuesArray).then((result) => { + return resolve(result as unknown as IDbStatusResult); + }); + }) } catch (err: unknown) { reject(err as Error); } @@ -359,16 +356,16 @@ const MySqlService = { return new Promise((resolve, reject) => { if (!data.id) return reject("Id is undefined"); if (data.id.length !== 36) return reject("Id invalid"); - try { handler.factorize({ values: data, - actionName: `Update user ID::${data.id}` + actionName: `Update brand ID::${data.id}` + }).then((result)=>{ + const _sql = `UPDATE "brands" SET ${result._keysTemplate} WHERE 'id' = '${data.id}'`; + handler.execute(_sql, result._valuesArray).then((result) => { + return resolve(result as unknown as IDbStatusResult); + }); }) - const _sql = `UPDATE "brands" SET ${_template} WHERE 'id' = ?`; - handler.execute(_sql, _values).then((result) => { - return resolve(result as unknown as IDbStatusResult); - }); } catch (err: unknown) { reject(err as Error); } @@ -581,31 +578,16 @@ const MySqlService = { return new Promise((resolve, reject) => { if (!data.id) return reject("Id is undefined"); if (data.id.length !== 36) return reject("Id invalid"); - try { - const _template = ` - ${data.slug_name ? "`slug_name` = ?," : null} - ${data.display_name ? "`display_name` = ?," : null} - ${data.brand_id ? "`brand_id` = ?," : null} - ${data.category_id ? "`category_id` = ?," : null} - ${data.image_blob ? "`image_blob` = ?," : null} - ${data.is_trending ? "`is_trending` = ?," : null} - ${data.base_price ? "`base_price` = ?," : null}`; - - const _values = [ - data.slug_name, - data.display_name, - data.brand_id, - data.category_id, - data.image_blob, - data.is_trending, - data.base_price, - data.id, - ]; - const _sql = `UPDATE "models" SET ${_template} WHERE 'id' = ?`; - handler.execute(_sql, _values).then((result) => { - return resolve(result as unknown as IDbStatusResult); - }); + handler.factorize({ + values: data, + actionName: `Update users ID::${data.id}` + }).then((result)=>{ + const _sql = `UPDATE "users" SET ${result._keysTemplate} WHERE 'id' = '${data.id}'`; + handler.execute(_sql, result._valuesArray).then((result) => { + return resolve(result as unknown as IDbStatusResult); + }); + }) } catch (err: unknown) { reject(err as Error); } @@ -681,25 +663,16 @@ const MySqlService = { return new Promise((resolve, reject) => { if (!data.id) return reject("Id is undefined"); if (data.id.length !== 36) return reject("Id invalid"); - try { - const _template = ` - ${data.model_id ? "`model_id` = ?," : null} - ${data.plate_number ? "`plate_number` = ?," : null} - ${data.odometer ? "`odometer` = ?," : null} - ${data.health_state ? "`health_state` = ?," : null}`; - - const _values = [ - data.model_id, - data.plate_number, - data.odometer, - data.health_state, - data.id, - ]; - const _sql = `UPDATE "vehicles" SET ${_template} WHERE 'id' = ?`; - handler.execute(_sql, _values).then((result) => { - return resolve(result as unknown as IDbStatusResult); - }); + handler.factorize({ + values: data, + actionName: `Update vehicle ID::${data.id}` + }).then((result)=>{ + const _sql = `UPDATE "vehicles" SET ${result._keysTemplate} WHERE 'id' = '${data.id}'`; + handler.execute(_sql, result._valuesArray).then((result) => { + return resolve(result as unknown as IDbStatusResult); + }); + }) } catch (err: unknown) { reject(err as Error); } @@ -808,17 +781,16 @@ const MySqlService = { return new Promise((resolve, reject) => { if (!data.id) return reject("Id is undefined"); if (data.id.length !== 36) return reject("Id invalid"); - try { - const _template = ` - ${data.slug_name ? "`slug_name` = ?," : null} - ${data.display_name ? "`display_name` = ?," : null}`; - - const _values = [data.slug_name, data.display_name, data.id]; - const _sql = `UPDATE "categories" SET ${_template} WHERE 'id' = ?`; - handler.execute(_sql, _values).then((result) => { - return resolve(result as unknown as IDbStatusResult); - }); + handler.factorize({ + values: data, + actionName: `Update category ID::${data.id}` + }).then((result)=>{ + const _sql = `UPDATE "categories" SET ${result._keysTemplate} WHERE 'id' = '${data.id}'`; + handler.execute(_sql, result._valuesArray).then((result) => { + return resolve(result as unknown as IDbStatusResult); + }); + }) } catch (err: unknown) { reject(err as Error); }