javascript 用户存储库Mongo db adapter factory

Posted 2021-05-04

//
//  UserRepositoryMongo factory implementing UserRepository interface
//
export default db => {
  const users = db.get('users')
  
  const create = async (user) => {
    const { userId } = user 
    await users.insert(user)
  }
  
  const getById = async (userId) => {
    const user = await users.findOne({userId})
    if (!user) {
      throw new UserNotFoundException() 
    }
    return user
  }
  
  const save = async (user) => {
    const { userId } = user 
    await users.update({
      userId
    }, user)
  }
  
  return {
    create,
    getById,
    save
  }
}