diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..ed13968 --- /dev/null +++ b/.gitignore @@ -0,0 +1,36 @@ +# Built application files +*.apk +*.ap_ + +# Files for the Dalvik VM +*.dex + +# Java class files +*.class + +# Generated files +bin/ +gen/ + +# Gradle files +.gradle/ +build/ + +# Local configuration file (sdk path, etc) +local.properties + +# Proguard folder generated by Eclipse +proguard/ + +# Log Files +*.log + +# Android Studio Navigation editor temp files +.navigation/ + +# Android Studio captures folder +captures/ + +.idea/ +*.iml +.DS_Store \ No newline at end of file diff --git a/README.md b/README.md new file mode 100644 index 0000000..cee7fec --- /dev/null +++ b/README.md @@ -0,0 +1 @@ +Code example for the conference talk: [Pragmatic Kotlin on Android](https://speakerdeck.com/mutexkid/pragmatic-kotlin-on-android) diff --git a/app/.gitignore b/app/.gitignore new file mode 100644 index 0000000..796b96d --- /dev/null +++ b/app/.gitignore @@ -0,0 +1 @@ +/build diff --git a/app/build.gradle b/app/build.gradle new file mode 100644 index 0000000..4266750 --- /dev/null +++ b/app/build.gradle @@ -0,0 +1,55 @@ +apply plugin: 'com.android.application' +apply plugin: 'kotlin-android' + +android { + compileSdkVersion 26 + buildToolsVersion "26.0.1" + defaultConfig { + applicationId "com.example.joshskeen.stockwatcher" + minSdkVersion 22 + targetSdkVersion 26 + versionCode 1 + versionName "1.0" + testInstrumentationRunner "android.support.test.runner.AndroidJUnitRunner" + } + buildTypes { + release { + minifyEnabled false + proguardFiles getDefaultProguardFile('proguard-android.txt'), 'proguard-rules.pro' + } + } + compileOptions { + sourceCompatibility JavaVersion.VERSION_1_8 + targetCompatibility JavaVersion.VERSION_1_8 + } + dataBinding.enabled = true + kapt.generateStubs = true +} + +dependencies { + implementation fileTree(dir: 'libs', include: ['*.jar']) + androidTestImplementation('com.android.support.test.espresso:espresso-core:3.0.0', { + exclude group: 'com.android.support', module: 'support-annotations' + }) + implementation 'com.android.support:appcompat-v7:26.0.1' + implementation 'com.android.support:design:26.0.1' + implementation 'com.google.dagger:dagger:2.11' + kapt 'com.google.dagger:dagger-compiler:2.11' + kapt "com.android.databinding:compiler:3.0.0-beta2" + implementation 'com.jakewharton.retrofit:retrofit2-rxjava2-adapter:1.0.0' + implementation 'com.android.support.constraint:constraint-layout:1.0.2' + api 'org.glassfish:javax.annotation:10.0-b28' + implementation 'io.reactivex.rxjava2:rxandroid:2.0.1' + implementation 'com.squareup.okhttp3:logging-interceptor:3.4.2' + implementation 'com.squareup.retrofit2:converter-gson:2.3.0' + implementation 'com.squareup.retrofit2:converter-gson:2.3.0' + implementation 'com.jakewharton.timber:timber:4.5.1' + testImplementation 'junit:junit:4.12' + + compile "org.jetbrains.kotlin:kotlin-stdlib-jre7:$kotlin_version" +} +repositories { + maven { + url 'http://dl.bintray.com/kotlin/kotlin-eap-1.2' + } +} diff --git a/app/proguard-rules.pro b/app/proguard-rules.pro new file mode 100644 index 0000000..ca0ea5b --- /dev/null +++ b/app/proguard-rules.pro @@ -0,0 +1,25 @@ +# Add project specific ProGuard rules here. +# By default, the flags in this file are appended to flags specified +# in /Users/joshskeen/Library/Android/sdk/tools/proguard/proguard-android.txt +# You can edit the include path and order by changing the proguardFiles +# directive in build.gradle. +# +# For more details, see +# http://developer.android.com/guide/developing/tools/proguard.html + +# Add any project specific keep options here: + +# If your project uses WebView with JS, uncomment the following +# and specify the fully qualified class name to the JavaScript interface +# class: +#-keepclassmembers class fqcn.of.javascript.interface.for.webview { +# public *; +#} + +# Uncomment this to preserve the line number information for +# debugging stack traces. +#-keepattributes SourceFile,LineNumberTable + +# If you keep the line number information, uncomment this to +# hide the original source file name. +#-renamesourcefileattribute SourceFile diff --git a/app/src/androidTest/java/com/example/joshskeen/stockwatcher/ExampleInstrumentedTest.java b/app/src/androidTest/java/com/example/joshskeen/stockwatcher/ExampleInstrumentedTest.java new file mode 100644 index 0000000..6ae5d6c --- /dev/null +++ b/app/src/androidTest/java/com/example/joshskeen/stockwatcher/ExampleInstrumentedTest.java @@ -0,0 +1,26 @@ +package com.example.joshskeen.stockwatcher; + +import android.content.Context; +import android.support.test.InstrumentationRegistry; +import android.support.test.runner.AndroidJUnit4; + +import org.junit.Test; +import org.junit.runner.RunWith; + +import static org.junit.Assert.*; + +/** + * Instrumented test, which will execute on an Android device. + * + * @see Testing documentation + */ +@RunWith(AndroidJUnit4.class) +public class ExampleInstrumentedTest { + @Test + public void useAppContext() throws Exception { + // Context of the app under test. + Context appContext = InstrumentationRegistry.getTargetContext(); + + assertEquals("com.example.joshskeen.kointracker", appContext.getPackageName()); + } +} diff --git a/app/src/main/AndroidManifest.xml b/app/src/main/AndroidManifest.xml new file mode 100644 index 0000000..38abb8a --- /dev/null +++ b/app/src/main/AndroidManifest.xml @@ -0,0 +1,27 @@ + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/AppComponent.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/AppComponent.kt new file mode 100644 index 0000000..ccf710d --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/AppComponent.kt @@ -0,0 +1,12 @@ +package com.example.joshskeen.stockwatcher + +import javax.inject.Singleton + +import dagger.Component +import com.example.joshskeen.stockwatcher.ui.StockInfoFragment + +@Singleton +@Component(modules = arrayOf(AppModule::class)) +interface AppComponent { + fun inject(fragment: StockInfoFragment) +} diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/AppModule.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/AppModule.kt new file mode 100644 index 0000000..5bf9672 --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/AppModule.kt @@ -0,0 +1,58 @@ +package com.example.joshskeen.stockwatcher + +import com.jakewharton.retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory + +import java.util.concurrent.TimeUnit + +import javax.inject.Singleton + +import dagger.Module +import dagger.Provides +import okhttp3.OkHttpClient +import okhttp3.logging.HttpLoggingInterceptor +import retrofit2.Retrofit +import retrofit2.converter.gson.GsonConverterFactory +import com.example.joshskeen.stockwatcher.service.ContentTypeHeaderInterceptor +import com.example.joshskeen.stockwatcher.service.ServiceConfig +import com.example.joshskeen.stockwatcher.service.StockService +import com.example.joshskeen.stockwatcher.service.repository.StockDataRepository + + +private const val STOCK_SERVICE_ENDPOINT = "http://dev.markitondemand.com/MODApis/Api/v2/" +private const val HTTP_READ_TIMEOUT = 60 +private const val HTTP_CONNECT_TIMEOUT = 60 + +@Module +internal class AppModule { + + @Provides + @Singleton + fun provideStockDataRepository(stockService: StockService): StockDataRepository = + StockDataRepository(stockService) + + @Provides + fun provideStockService(retrofit: Retrofit): StockService = StockService(retrofit) + + @Provides + fun provideServiceConfig() = ServiceConfig(STOCK_SERVICE_ENDPOINT) + + @Provides + fun provideRetrofit(client: OkHttpClient, serviceConfig: ServiceConfig) = + Retrofit.Builder() + .baseUrl(serviceConfig.baseServiceUrl) + .addCallAdapterFactory(RxJava2CallAdapterFactory.create()) + .client(client) + .addConverterFactory(GsonConverterFactory.create()) + .build()!! + + @Provides + fun provideOkHttpClient(loggingInterceptor: HttpLoggingInterceptor) = OkHttpClient.Builder() + .readTimeout(HTTP_READ_TIMEOUT.toLong(), TimeUnit.SECONDS) + .connectTimeout(HTTP_CONNECT_TIMEOUT.toLong(), TimeUnit.SECONDS) + .addInterceptor(loggingInterceptor) + .addInterceptor(ContentTypeHeaderInterceptor()) + .build() + + @Provides + fun provideLoggingInterceptor() = HttpLoggingInterceptor().setLevel(HttpLoggingInterceptor.Level.BODY) +} diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/StockWatcherApplication.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/StockWatcherApplication.kt new file mode 100644 index 0000000..6bf843f --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/StockWatcherApplication.kt @@ -0,0 +1,11 @@ +package com.example.joshskeen.stockwatcher + +import android.app.Application + +class StockWatcherApplication : Application() { + + val appComponent: AppComponent by lazy { + DaggerAppComponent.builder().appModule(AppModule()).build() + } + +} diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/extensions/ContextExt.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/extensions/ContextExt.kt new file mode 100644 index 0000000..d192625 --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/extensions/ContextExt.kt @@ -0,0 +1,12 @@ +package com.example.joshskeen.stockwatcher.extensions + +import android.content.Context +import android.support.v4.app.Fragment +import com.example.joshskeen.stockwatcher.AppComponent +import com.example.joshskeen.stockwatcher.StockWatcherApplication + +val Context.component: AppComponent + get() = (applicationContext as StockWatcherApplication).appComponent + +val Fragment.component: AppComponent + get() = activity.component \ No newline at end of file diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/extensions/FragmentExt.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/extensions/FragmentExt.kt new file mode 100644 index 0000000..acd58bd --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/extensions/FragmentExt.kt @@ -0,0 +1,2 @@ +package com.example.joshskeen.stockwatcher.extensions + diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/service/ContentTypeHeaderInterceptor.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/service/ContentTypeHeaderInterceptor.kt new file mode 100644 index 0000000..9672360 --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/service/ContentTypeHeaderInterceptor.kt @@ -0,0 +1,21 @@ +package com.example.joshskeen.stockwatcher.service + +import okhttp3.Interceptor +import okhttp3.Response + + +private const val CONTENT_TYPE = "Content-Type" +private const val APPLICATION_JSON = "application/json" + +class ContentTypeHeaderInterceptor : Interceptor { + + override fun intercept(chain: Interceptor.Chain): Response { + val request = chain + .request() + .newBuilder() + .addHeader(CONTENT_TYPE, APPLICATION_JSON) + .build() + return chain.proceed(request) + } + +} diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/service/ServiceConfig.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/service/ServiceConfig.kt new file mode 100644 index 0000000..0427fd3 --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/service/ServiceConfig.kt @@ -0,0 +1,4 @@ +package com.example.joshskeen.stockwatcher.service + + +data class ServiceConfig(val baseServiceUrl: String) \ No newline at end of file diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/service/StockInfoForSymbol.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/service/StockInfoForSymbol.kt new file mode 100644 index 0000000..ea15e2a --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/service/StockInfoForSymbol.kt @@ -0,0 +1,5 @@ +package com.example.joshskeen.stockwatcher.service + + +data class StockInfoForSymbol(val stockSymbol: StockSymbol, + val stockInfoResponse: StockInfoResponse) diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/service/StockInfoResponse.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/service/StockInfoResponse.kt new file mode 100644 index 0000000..56dbd86 --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/service/StockInfoResponse.kt @@ -0,0 +1,29 @@ +package com.example.joshskeen.stockwatcher.service + +import com.google.gson.annotations.SerializedName + +data class StockInfoResponse( + @SerializedName("Status") + private val status: String, + @SerializedName("Name") + private val name: String, + @SerializedName("LastPrice") + private val lastPrice: Double, + @SerializedName("Change") + private val change: Double, + @SerializedName("ChangePercent") + private val changePercent: Double, + @SerializedName("MarketCap") + private val marketCap: Long, + @SerializedName("Volume") + private val volume: Long, + @SerializedName("ChangeYTD") + private val changeYTD: Double, + @SerializedName("ChangePercentYTD") + private val changePercentYTD: Double, + @SerializedName("High") + private val high: Double, + @SerializedName("Low") + private val low: Double, + @SerializedName("Open") + private val open: Double) diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/service/StockService.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/service/StockService.kt new file mode 100644 index 0000000..f465fd9 --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/service/StockService.kt @@ -0,0 +1,23 @@ +package com.example.joshskeen.stockwatcher.service + + +import io.reactivex.Observable +import retrofit2.Retrofit +import retrofit2.http.GET +import retrofit2.http.Query + +class StockService(retrofit: Retrofit) { + + private val service by lazy { retrofit.create(StockServiceInterface::class.java) } + + internal interface StockServiceInterface { + @GET("Quote/json") + fun stockInfo(@Query("symbol") symbol: String): Observable + + @GET("Lookup/json") + fun lookupStock(@Query("input") symbol: String): Observable> + } + + fun stockInfo(symbol: String): Observable = service.stockInfo(symbol) + fun lookupStock(symbol: String): Observable> = service.lookupStock(symbol) +} diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/service/StockSymbol.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/service/StockSymbol.kt new file mode 100644 index 0000000..b0a902b --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/service/StockSymbol.kt @@ -0,0 +1,9 @@ +package com.example.joshskeen.stockwatcher.service + +import com.google.gson.annotations.SerializedName + +data class StockSymbol( + @SerializedName("Symbol") + val symbol: String, + @SerializedName("Name") + val name: String) \ No newline at end of file diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/service/StockSymbolError.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/service/StockSymbolError.kt new file mode 100644 index 0000000..5425365 --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/service/StockSymbolError.kt @@ -0,0 +1,3 @@ +package com.example.joshskeen.stockwatcher.service + +data class StockSymbolError(override val message: String) : Exception() diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/service/repository/BaseRepository.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/service/repository/BaseRepository.kt new file mode 100644 index 0000000..37fc1e3 --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/service/repository/BaseRepository.kt @@ -0,0 +1,23 @@ +package com.example.joshskeen.stockwatcher.service.repository + +import android.util.LruCache +import io.reactivex.Observable + +abstract class BaseRepository { + + private val lruCache: LruCache> = LruCache(50) + internal val symbols = mutableSetOf() + + fun cacheObservable(symbol: String, observable: Observable): Observable = + lruCache.get(symbol) as Observable? ?: let { + updateCache(symbol, observable) + observable + } + + private fun updateCache(stockSymbol: String, observable: Observable?) { + lruCache.put(stockSymbol, observable!!) + } + + fun clearCache() = lruCache.evictAll() + +} diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/service/repository/StockDataRepository.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/service/repository/StockDataRepository.kt new file mode 100644 index 0000000..aacaa37 --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/service/repository/StockDataRepository.kt @@ -0,0 +1,55 @@ +package com.example.joshskeen.stockwatcher.service.repository + +import java.util.concurrent.TimeUnit + +import io.reactivex.Observable + +import com.example.joshskeen.stockwatcher.service.StockInfoForSymbol +import com.example.joshskeen.stockwatcher.service.StockInfoResponse +import com.example.joshskeen.stockwatcher.service.StockService +import com.example.joshskeen.stockwatcher.service.StockSymbol +import com.example.joshskeen.stockwatcher.service.StockSymbolError +import io.reactivex.functions.BiFunction + +import timber.log.Timber + +private const val CACHE_PREFIX_GET_STOCK_INFO = "stockInfo" +private const val CACHE_PREFIX_GET_STOCK_INFO_FOR_SYMBOL = "getStockInfoForSymbol" +private const val CACHE_PREFIX_GET_STOCK_SYMBOLS = "lookupStockSymbols" + + +class StockDataRepository(private val service: StockService) : BaseRepository() { + + fun getStockInfoForSymbol(symbol: String): Observable? { + Timber.i("method: %s, symbol: %s", CACHE_PREFIX_GET_STOCK_INFO_FOR_SYMBOL, symbol) + val stockInfoForSymbolObservable = Observable.combineLatest( + lookupStockSymbol(symbol), + fetchStockInfoFromSymbol(symbol), + BiFunction { stockSymbol, stockInfoResponse -> + StockInfoForSymbol(stockSymbol, stockInfoResponse) + }) + return cacheObservable(CACHE_PREFIX_GET_STOCK_INFO_FOR_SYMBOL + symbol, stockInfoForSymbolObservable) + } + + private fun fetchStockInfoFromSymbol(symbol: String): Observable { + return lookupStockSymbol(symbol) + .flatMap { (symbol1) -> getStockInfo(symbol1) } + } + + private fun lookupStockSymbol(symbol: String) = lookupStockSymbols(symbol) + .doOnNext { if (it.isEmpty()) throw StockSymbolError("$symbol not found!") } + .doOnNext { symbols.add(symbol) } + .flatMap { t -> Observable.fromIterable(t) } + .take(1) + + private fun lookupStockSymbols(symbol: String) = + cacheObservable(CACHE_PREFIX_GET_STOCK_SYMBOLS + symbol, service.lookupStock(symbol).cache()) + + private fun getStockInfo(symbol: String): Observable? { + Timber.i("method: %s, symbol: %s", CACHE_PREFIX_GET_STOCK_INFO, symbol) + //simulates the service taking a while to respond with data! + val observableToCache = service.stockInfo(symbol).delay(3, TimeUnit.SECONDS).cache() + return cacheObservable(CACHE_PREFIX_GET_STOCK_INFO + symbol, observableToCache) + } + +} diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/ui/RxFragment.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/ui/RxFragment.kt new file mode 100644 index 0000000..ad46ca7 --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/ui/RxFragment.kt @@ -0,0 +1,44 @@ +package com.example.joshskeen.stockwatcher.ui + +import android.os.Bundle +import android.support.v4.app.Fragment + +import io.reactivex.disposables.CompositeDisposable + +const val EXTRA_RX_REQUEST_IN_PROGRESS = "EXTRA_RX_REQUEST_IN_PROGRESS" + +abstract class RxFragment : Fragment() { + + private var Bundle.requestInProgress: Boolean + get() = getBoolean(EXTRA_RX_REQUEST_IN_PROGRESS, false) + set(inProgress) = putBoolean(EXTRA_RX_REQUEST_IN_PROGRESS, inProgress) + + var requestInProgress = false + + var compositeDisposable: CompositeDisposable = CompositeDisposable() + + override fun onCreate(savedInstanceState: Bundle?) { + super.onCreate(savedInstanceState) + savedInstanceState?.let { + requestInProgress = savedInstanceState.requestInProgress + } + } + + override fun onSaveInstanceState(outState: Bundle) { + super.onSaveInstanceState(outState) + outState.requestInProgress = requestInProgress + } + + override fun onResume() { + super.onResume() + if (requestInProgress) loadRxData() + } + + override fun onPause() { + super.onPause() + compositeDisposable.clear() + } + + abstract fun loadRxData() + +} diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/ui/SingleFragmentActivity.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/ui/SingleFragmentActivity.kt new file mode 100644 index 0000000..4e5e926 --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/ui/SingleFragmentActivity.kt @@ -0,0 +1,27 @@ +package com.example.joshskeen.stockwatcher.ui + +import android.databinding.DataBindingUtil +import android.os.Bundle +import android.support.v4.app.Fragment +import android.support.v4.app.FragmentManager +import android.support.v7.app.AppCompatActivity + +import com.example.joshskeen.stockwatcher.R +import com.example.joshskeen.stockwatcher.databinding.ActivitySingleFragmentBinding + + +abstract class SingleFragmentActivity : AppCompatActivity() { + + protected abstract fun createFragment(): Fragment + private lateinit var viewDataBinding: ActivitySingleFragmentBinding + + public override fun onCreate(savedInstanceState: Bundle?) { + super.onCreate(savedInstanceState) + viewDataBinding = DataBindingUtil.setContentView(this, R.layout.activity_single_fragment) + savedInstanceState ?: supportFragmentManager.addFragment() + } + + private fun FragmentManager.addFragment() = + beginTransaction().add(viewDataBinding.fragmentContainer.id, createFragment()).commit() + +} diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/ui/StockInfoActivity.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/ui/StockInfoActivity.kt new file mode 100644 index 0000000..73925c7 --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/ui/StockInfoActivity.kt @@ -0,0 +1,6 @@ +package com.example.joshskeen.stockwatcher.ui + + +class StockInfoActivity : SingleFragmentActivity() { + override fun createFragment(): StockInfoFragment = StockInfoFragment() +} \ No newline at end of file diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/ui/StockInfoFragment.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/ui/StockInfoFragment.kt new file mode 100644 index 0000000..f5d0434 --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/ui/StockInfoFragment.kt @@ -0,0 +1,68 @@ +package com.example.joshskeen.stockwatcher.ui + +import android.databinding.DataBindingUtil +import android.os.Bundle +import android.view.LayoutInflater +import android.view.View +import android.view.ViewGroup +import android.widget.Toast + +import com.example.joshskeen.stockwatcher.R +import com.example.joshskeen.stockwatcher.databinding.FragmentStockInfoBinding +import com.example.joshskeen.stockwatcher.extensions.component + +import javax.inject.Inject + +import io.reactivex.Observable + +import com.example.joshskeen.stockwatcher.service.StockInfoForSymbol +import com.example.joshskeen.stockwatcher.service.repository.StockDataRepository +import com.example.joshskeen.stockwatcher.util.* + +class StockInfoFragment : RxFragment() { + + @Inject + lateinit var stockDataRepository: StockDataRepository + private lateinit var binding: FragmentStockInfoBinding + + override fun onCreate(savedInstanceState: Bundle?) { + super.onCreate(savedInstanceState) + component.inject(this) + } + + override fun onCreateView(inflater: LayoutInflater, container: ViewGroup?, savedInstanceState: Bundle?): View? { + super.onCreateView(inflater, container, savedInstanceState) + binding = DataBindingUtil.inflate(inflater, R.layout.fragment_stock_info, container, false) + return binding.apply { + fetchDataButton.setOnClickListener { + errorMessage.visibility = View.GONE + loadRxData() + } + clearCacheButton.setOnClickListener { + stockDataRepository.clearCache() + Toast.makeText(context, "observable cache cleared!", Toast.LENGTH_LONG).show() + } + }.root + } + + override fun loadRxData() { + Observable.just(binding.tickerSymbol.text.toString()) + .filter(String::isNotEmpty) + .singleOrError() + .toObservable() + .flatMap(stockDataRepository::getStockInfoForSymbol) + .applyUIDefaults(this) + .subscribe(this::displayStockResults, this::displayErrors) + } + + private fun displayErrors(throwable: Throwable) { + binding.errorMessage.apply { + visibility = View.VISIBLE + text = throwable.message + } + } + + private fun displayStockResults(stockInfoForSymbol: StockInfoForSymbol) { + binding.stockValue.text = stockInfoForSymbol.toString() + } +} diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/util/DialogUtils.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/util/DialogUtils.kt new file mode 100644 index 0000000..ab2822a --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/util/DialogUtils.kt @@ -0,0 +1,17 @@ +package com.example.joshskeen.stockwatcher.util + +import android.support.v4.app.FragmentManager + +private const val TAG_DIALOG_PROGRESS = "dialog_progress" + +private val FragmentManager.dialog: ProgressDialogFragment? + get() = findFragmentByTag(TAG_DIALOG_PROGRESS) as? ProgressDialogFragment + +fun FragmentManager.showProgressDialog(message: String) { + hideProgressDialog() + ProgressDialogFragment.newInstance(message).apply { + isCancelable = false + }.show(this, TAG_DIALOG_PROGRESS) +} + +fun FragmentManager.hideProgressDialog() = dialog?.dismissAllowingStateLoss() \ No newline at end of file diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/util/ProgressDialogFragment.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/util/ProgressDialogFragment.kt new file mode 100644 index 0000000..4decfc0 --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/util/ProgressDialogFragment.kt @@ -0,0 +1,30 @@ +package com.example.joshskeen.stockwatcher.util + +import android.app.Dialog +import android.app.ProgressDialog +import android.os.Bundle +import android.support.v4.app.DialogFragment + +class ProgressDialogFragment : DialogFragment() { + + override fun onCreateDialog(savedInstanceState: Bundle?): Dialog { + val dialog = ProgressDialog(context) + val message = arguments.getString(ARG_MESSAGE) + dialog.setMessage(message) + dialog.setProgressStyle(ProgressDialog.STYLE_SPINNER) + return dialog + } + + companion object { + + private val ARG_MESSAGE = "message" + + fun newInstance(message: String): ProgressDialogFragment { + val args = Bundle() + args.putString(ARG_MESSAGE, message) + val fragment = ProgressDialogFragment() + fragment.arguments = args + return fragment + } + } +} diff --git a/app/src/main/java/com/example/joshskeen/stockwatcher/util/RxUtil.kt b/app/src/main/java/com/example/joshskeen/stockwatcher/util/RxUtil.kt new file mode 100644 index 0000000..12b9c05 --- /dev/null +++ b/app/src/main/java/com/example/joshskeen/stockwatcher/util/RxUtil.kt @@ -0,0 +1,32 @@ +package com.example.joshskeen.stockwatcher.util + +import android.support.v4.app.FragmentManager +import io.reactivex.android.schedulers.AndroidSchedulers +import io.reactivex.schedulers.Schedulers +import com.example.joshskeen.stockwatcher.ui.RxFragment +import io.reactivex.Observable + +const val LOADING_MESSAGE = "Loading" + + +fun Observable.applyUIDefaults(rxFragment: RxFragment): Observable = + addToCompositeDisposable(rxFragment) + .applySchedulers() + .applyRequestStatus(rxFragment) + .showLoadingDialog(rxFragment.fragmentManager) + +private fun Observable.addToCompositeDisposable(fragment: RxFragment): Observable = + doOnSubscribe({ fragment.compositeDisposable.add(it) }) + +private fun Observable.applySchedulers() = + subscribeOn(Schedulers.io()) + .observeOn(AndroidSchedulers.mainThread()) + +private fun Observable.applyRequestStatus(rxFragment: RxFragment) = + doOnSubscribe({ rxFragment.requestInProgress = true }) + .doOnTerminate({ rxFragment.requestInProgress = false }) + +private fun Observable.showLoadingDialog(fragmentManager: FragmentManager) = + doOnSubscribe({ fragmentManager.showProgressDialog(LOADING_MESSAGE) }) + .doOnTerminate({ fragmentManager.hideProgressDialog() }) + diff --git a/app/src/main/res/drawable/ic_launcher_background.xml b/app/src/main/res/drawable/ic_launcher_background.xml new file mode 100644 index 0000000..1cd2a36 --- /dev/null +++ b/app/src/main/res/drawable/ic_launcher_background.xml @@ -0,0 +1,113 @@ + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/app/src/main/res/layout/activity_single_fragment.xml b/app/src/main/res/layout/activity_single_fragment.xml new file mode 100644 index 0000000..be61e73 --- /dev/null +++ b/app/src/main/res/layout/activity_single_fragment.xml @@ -0,0 +1,8 @@ + + + + + diff --git a/app/src/main/res/layout/fragment_stock_info.xml b/app/src/main/res/layout/fragment_stock_info.xml new file mode 100644 index 0000000..91a85a1 --- /dev/null +++ b/app/src/main/res/layout/fragment_stock_info.xml @@ -0,0 +1,60 @@ + + + + + + + + + + + + + + + +