PK!A7��nvar sql = require("mysql"); var pool = require("../db"); const opts = { errorEventName: "error", logDirectory: "logs", fileNamePattern: "log-.log", dateFormat: "YYYY-MM-DD", }; const log = require("simple-node-logger").createRollingFileLogger(opts); module.exports = { getApiKeysDB: function (userId) { return new Promise((resolve, reject) => { let query = "select id, `identity_token`, type, created_at, updated_at from users where id = ?"; const data = [userId]; pool.query(query, data, (err, results, fields) => { try { if (err) { throw err; } else { if (results.length > 0) return resolve(results); else return resolve(false); } } catch (err) { log.info( "[API KEYS], [MODEL], [getApiKeysDB], [error], [" + err + "]" ); return reject(err); } }); }); }, checkApiKeyDB: function (key) { return new Promise((resolve, reject) => { let query = "select id, `identity_token`, type, created_at, updated_at from users where `identity_token` = ?"; const data = [key]; pool.query(query, data, (err, results, fields) => { try { if (err) { throw err; } else { if (results.length > 0) return resolve(true); else return resolve(false); } } catch (err) { log.info( "[API KEYS], [MODEL], [checkApiKeyDB], [error], [" + err + "]" ); return reject(err); } }); }); }, updateApiKeyDB: function (userId, key) { return new Promise((resolve, reject) => { let query = "update users set `identity_token` = ? , updated_at = now() where id = ?"; const data = [key, userId]; pool.query(query, data, (err, results, fields) => { try { if (err) { throw err; } else { resolve(true); } } catch (err) { log.info( "[API KEYS], [MODEL], [updateApiKeyDB], [error], [" + err + "]" ); return reject(err); } }); }); }, };