//
//  UserRepositoryMySQL factory implementing UserRepository interface
//
export default conn => {
  const create = user => {
    const { userId, userName, userEmail } = user
    return new Promise((resolve, reject) => {
      conn.query(`INSERT INTO users (userId, userName, userEmail) VALUES (${userId}, '${userName}', '${userEmail}')`, function (error) {
        if (error) {
          return reject(error)
        }
        resolve()
      })
    })
  }
  const getById = userId => {
    return new Promise((resolve, reject) => {
      conn.query(`SELECT userId, userName, userEmail FROM users WHERE userId=${userId}`, function (error, results, fields) {
        if (error) {
          return reject(error)
        }
        if (!results.length) {
          reject(new UserNotFoundException())
        }
        resolve(results[0])
      })
    })
  }
  const save = user => {
    const { userId, userName, userEmail } = user
    return new Promise((resolve, reject) => {
      conn.query(`UPDATE users SET userName='${userName}', userEmail='${userEmail}' WHERE userId='${userId}'`, function (error) {
        if (error) {
          return reject(error)
        }
        resolve()
      })
    })
  }
  return {
    create,
    getById,
    save
  }
}