markchristopherng

val greetingModule = module(createdAtStart = true) {
    single<GreetingService> { GreetingServiceImpl(get()) }
    single<IpAddressService> { IpAddressServiceImpl(get()) }
}

markchristopherng

fun Application.module() {

    val jsonParser = Json {
        ignoreUnknownKeys = true
        isLenient = true
    }
    install(ContentNegotiation) {
        json(jsonParser)
    }
    val client = HttpClient(Apache) {

markchristopherng

fun Application.module() {

    val jsonParser = Json {
        ignoreUnknownKeys = true
        isLenient = true
    }

    install(ContentNegotiation) {
        json(jsonParser)
    }

markchristopherng

val restTemplate = RestTemplate()
restTemplate.messageConverters = mutableListOf<HttpMessageConverter<*>>(
  KotlinSerializationJsonHttpMessageConverter(JsonParser().json)

markchristopherng

@Configuration
open class ConfigureMessageConverters() : WebMvcConfigurer {

    override fun extendMessageConverters(converters: MutableList<HttpMessageConverter<*>>) {
        val converter = KotlinSerializationJsonHttpMessageConverter(JsonParser().json)
        converters.forEachIndexed { index, httpMessageConverter ->
            if (httpMessageConverter is KotlinSerializationJsonHttpMessageConverter) {
                converters[index] = converter
                return
            }

markchristopherng

class JsonParser {
    val json = Json { ignoreUnknownKeys = true; isLenient = true; }
}

markchristopherng

fun <T> Observable<T>.prodTimeout(timeout: Long, timeUnit: TimeUnit): Observable<T> {
    return if (BuildConfig.BUILD_TYPE == "debug" || timeout == 0L) {
        this
    } else {
        this.timeout(timeout, timeUnit)
    }
}

markchristopherng

    private fun loadAppConfig() {
        appConfigManager.getAppConfig(pushNotificationManager.deviceId)
                .prodTimeout(2500, TimeUnit.MILLISECONDS)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .`as`(AutoDispose.autoDisposable(AndroidLifecycleScopeProvider.from(lifecycle, Lifecycle.Event.ON_DESTROY)))
                .subscribe({ appConfig -> processAppConfig(appConfig) }, 
                           { throwable -> Timber.e(throwable) }) 
    }

markchristopherng

    fun getOnboardingInfoAndSmartMessage() {
        viewModelScope.launch {
            try {
                withTimeout(2500) {
                    onBoardingData.loadWith(this) {
                        onBoardDispatchManager.getOnboardingInfoAndSmartMessage()
                    }
                }
            } catch (error: TimeoutCancellationException) {
                onBoardingData.postError(error)

markchristopherng

interface GeoFenceService {

 /**
 * Return a list of [GeofencingResponse] awaiting for collection by given dpid
 */
 @GET("geofencing/v1/articles/{dpid}")
 fun getGeoFenceArticles(@Path("dpid") dpid: String): Single<List<GeofencingResponse>>
}