nanlabsweb

import { ageSelector, regionSelector, isEligibleSelector} from './CoolModuleSelectors.js';

(...)

const mapStateToProps = state => ({
  age: ageSelector(state),
  region: regionSelector(state),
  isEligible: isEligibleSelector(state),
});

nanlabsweb

(...)
import { createSelector } from 'reselect';

const birthDateSelector = state => state.user.birthdate;
const countrySelector = state => state.user.location.country;

export const ageSelector = createSelector(
  birthDateSelector,
  dateString => moment().year() - moment(dateString).year(),
);

nanlabsweb

const mapStateToProps = state => ({
  birthDate: state.user.birthdate,
  country: state.user.location.country,
});

nanlabsweb

suspend fun <T> Task<T>.await(): T = suspendCoroutine { continuation ->
  addOnCompleteListener { task ->
    when {
      (task.result as QuerySnapshot).metadata.isFromCache ->
        continuation.resumeWithException(Exception("without internet"))
      task.isSuccessful -> continuation.resume(task.result)
      else -> continuation.resumeWithException(task.exception!!)
    }
  }
}

nanlabsweb

suspend fun getAllPets(): List<Pet> {
  val result = firestoreDataBase.collection("pets").get().await()
  return setPetsFromSnapshotIntoMutableList(result)
}

nanlabsweb

fun getAllPets(): LiveData<List<Pet>>  {
  var pets: MutableLiveData<List<Pet>> = MutableLiveData()
  firestoreDataBase.collection("pets").get().addOnSuccessListener {
    pets.value = setPetsFromSnapshotIntoMutableList(it)
  }
  return pets
}

nanlabsweb

suspend fun syncPets() {
  val pets = firestoreWrapper.getAllPets()
  appDataBase.petDao().deleteAllPets()
  pets.forEach {
    appDataBase.petDao().insert(it)
  }
}

nanlabsweb

fun syncPets(): LiveData<List<Pet>> {
  liveDataMerger.addSource(firestoreWrapper.getAllPets()) {
    value -> liveDataMerger.value = value
    appDataBase.petDao().deleteAllPets()
    value?.forEach {
      appDataBase.petDao().insert(it)
    }
  }
  return liveDataMerger
}

nanlabsweb

suspend fun syncPets(): String {
  var message = "Congratulations!!"
  try {
    async { repository.syncPets() }.await()
  } catch (e: Exception) {
    message = e.message!!
  }
  return message
}

nanlabsweb

suspend fun syncPets() = repository.syncPets()