class RoomRepositoryImpl : RoomRepository {

    private val dao = App.db.roomDao()

    override fun getRoomById(id: Int): Single<Room> {
        return dao.findById(id).map { toDomainRoom(it) }
    }

    override fun getAllRooms(): Single<List<Room>> {
        return dao.getAll().map { it.map { toDomainRoom(it) } }
    }

    override fun saveRooms(vararg rooms: Room): Completable {
        val dataRooms = rooms.map { toDataRoom(it) }.toTypedArray()
        return dao.insertAll(*dataRooms)
    }

    override fun updateRoom(room: Room): Completable {
        return dao.insertAll(toDataRoom(room))
    }

    override fun removeRoom(room: Room): Completable {
        return dao.delete(toDataRoom(room))
    }
}