Merge pull request #2 from EbenezerGH/add-basic-networking

Add basic networking

Author: EbenezerGH

app/src/main/AndroidManifest.xml

@@ -21,4 +21,6 @@
         </activity>
     </application>
 
+    <uses-permission android:name="android.permission.INTERNET" />
+
 </manifest>

app/src/main/java/jfyg/etherscan/helloetherescan/MainActivity.kt

@@ -1,26 +1,52 @@
 package jfyg.etherscan.helloetherescan
 
 import android.os.Bundle
-import android.support.design.widget.Snackbar
 import android.support.v7.app.AppCompatActivity
+import android.util.Log
 import android.view.Menu
 import android.view.MenuItem
+import io.reactivex.android.schedulers.AndroidSchedulers
+import io.reactivex.schedulers.Schedulers
+import jfyg.etherscan.helloetherescan.network.responses.BaseResponse
+import jfyg.etherscan.helloetherescan.network.RestClient
 
 import kotlinx.android.synthetic.main.activity_main.*
 
 class MainActivity : AppCompatActivity() {
-
+    private val TAG = javaClass.name!!
     override fun onCreate(savedInstanceState: Bundle?) {
         super.onCreate(savedInstanceState)
         setContentView(R.layout.activity_main)
         setSupportActionBar(toolbar)
 
-        fab.setOnClickListener { view ->
-            Snackbar.make(view, "Replace with your own action", Snackbar.LENGTH_LONG)
-                    .setAction("Action", null).show()
+
+        fab.setOnClickListener {
+            queryPrice("1I7CRNU2QIU253UBPFVB5UV2C2PBDURAIY")
         }
     }
 
+    private fun queryPrice(apiKey: String) {
+        RestClient().getQuery()
+                .getEtherStats("stats", "ethprice", apiKey)
+                .observeOn(AndroidSchedulers.mainThread())
+                .subscribeOn(Schedulers.io())
+                .subscribe(this::handleResponse, this::handleError)
+    }
+
+    private fun handleResponse(retrieveQuery: BaseResponse) {
+        Log.d(TAG, "status: " + retrieveQuery.status)
+        Log.d(TAG, "message: " + retrieveQuery.message)
+        Log.d(TAG, "Eth in Btc: " + retrieveQuery.etherPriceresult?.ethBtc)
+        Log.d(TAG, "Eth in Btc Timestamp: " + retrieveQuery.etherPriceresult?.ethBtcTimestamp)
+        Log.d(TAG, "Eth in Usd: " + retrieveQuery.etherPriceresult?.ethUsd)
+        Log.d(TAG, "Eth in Usd Timestamp: " + retrieveQuery.etherPriceresult?.ethUsdTimestamp)
+        //Log.d(TAG, "Eth supply: " + retrieveQuery.etherSupplyResult)
+    }
+
+    private fun handleError(error: Throwable) {
+        Log.d(TAG, "The error " + error.message)
+    }
+
     override fun onCreateOptionsMenu(menu: Menu): Boolean {
         // Inflate the menu; this adds items to the action bar if it is present.
         menuInflater.inflate(R.menu.menu_main, menu)

app/src/main/java/jfyg/etherscan/helloetherescan/network/NetworkService.kt

@@ -0,0 +1,17 @@
+package jfyg.etherscan.helloetherescan.network
+
+import io.reactivex.Observable
+import jfyg.etherscan.helloetherescan.network.responses.BaseResponse
+import retrofit2.http.GET
+import retrofit2.http.Query
+
+/**
+ * Etherscan request endpoints
+ */
+interface NetworkService {
+
+    @GET("api")
+    fun getEtherStats(@Query("module") module: String,
+                      @Query("action") action: String,
+                      @Query("apikey") apikey: String): Observable<BaseResponse>
+}

app/src/main/java/jfyg/etherscan/helloetherescan/network/RestClient.kt

@@ -0,0 +1,35 @@
+package jfyg.etherscan.helloetherescan.network
+
+import retrofit2.Retrofit
+import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory
+import retrofit2.converter.gson.GsonConverterFactory
+import com.google.gson.GsonBuilder
+
+/**
+ * Client used to create the network call
+ */
+class RestClient {
+
+    //TODO: Retrieve baseUrl from string resources
+    private var baseUrl: String = "http://api.etherscan.io/"
+    private var networkService: NetworkService
+
+    init {
+        val gson = GsonBuilder()
+                .setLenient()
+                .create()
+
+        val retrofit = Retrofit.Builder()
+                .baseUrl(baseUrl)
+                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
+                .addConverterFactory(GsonConverterFactory.create(gson))
+                .build()
+
+        networkService = retrofit.create(NetworkService::class.java)
+    }
+
+    fun getQuery(): NetworkService {
+        return networkService
+    }
+
+}

app/src/main/java/jfyg/etherscan/helloetherescan/network/responses/BaseResponse.kt

@@ -0,0 +1,22 @@
+package jfyg.etherscan.helloetherescan.network.responses
+
+import com.google.gson.annotations.SerializedName
+
+/**
+ * Base response that all queries will utilize
+ */
+open class BaseResponse {
+
+    @SerializedName("status")
+    var status: String = ""
+
+    @SerializedName("message")
+    var message: String = ""
+
+    @SerializedName("result")
+    open var etherPriceresult: EtherPriceResponse? = null
+
+    //TODO: Figure out how to handle the same response name coming in from different queries
+    //@SerializedName("result")
+    //open var etherSupplyResult: String = ""
+}

app/src/main/java/jfyg/etherscan/helloetherescan/network/responses/EtherPriceResponse.kt

@@ -0,0 +1,21 @@
+package jfyg.etherscan.helloetherescan.network.responses
+
+import com.google.gson.annotations.SerializedName
+
+/**
+ * Response for Ether prices
+ */
+class EtherPriceResponse {
+
+    @SerializedName("ethbtc")
+    var ethBtc: String = ""
+
+    @SerializedName("ethbtc_timestamp")
+    var ethBtcTimestamp: String = ""
+
+    @SerializedName("ethusd")
+    var ethUsd: String = ""
+
+    @SerializedName("ethusd_timestamp")
+    var ethUsdTimestamp: String = ""
+}

app/src/main/res/values/strings.xml

@@ -1,4 +1,9 @@
 <resources>
     <string name="app_name">Hello Ethere Scan</string>
     <string name="action_settings">Settings</string>
+
+    <string name="base_url">http://api.etherscan.io/</string>
+
+    <!--TODO: Remove Before Publishing-->
+    <string name="my_api_key">1I7CRNU2QIU253UBPFVB5UV2C2PBDURAIY</string>
 </resources>