Added api monitoring

Author: emardillu

.idea/misc.xml

@@ -1,8 +1,11 @@
 package com.mardillu.openai.test
 
 import android.os.Bundle
+import android.util.Log
 import androidx.appcompat.app.AppCompatActivity
 import com.mardillu.openai.model.Message
+import com.mardillu.openai.network.LoggingApiService
+import com.mardillu.openai.network.LoggingClient
 import com.mardillu.openai.network.OpenApiClient
 import com.mardillu.openai.test.databinding.ActivityMainBinding
 import java.io.File
@@ -15,6 +18,22 @@ class MainActivity : AppCompatActivity() {
         setContentView(binding.root)
 
         val chatGptService = OpenApiClient()
+        val loggingApiService = LoggingClient()
+
+        loggingApiService.logRequestTime(
+            "user/login",
+            200,
+            500,
+            300,
+            200,
+        ){ result, error ->
+            if (error != null){
+                Log.d("TAG", "onCreate: =======> FAILED <============")
+                error.printStackTrace()
+            } else {
+                Log.d("TAG", "onCreate: =======> SUCCESS <============")
+            }
+        }
 
         chatGptService.getTextCompletion("Hello chat gpt! what is the meaning of life?") { result, error ->
             if (error != null) {
@@ -95,6 +114,8 @@ class MainActivity : AppCompatActivity() {
                 binding.result10.text = result.text
             }
         }
+
+
     }
 
     private fun imageFromAssets(name: String): File {

app/src/main/java/com/mardillu/openai/test/MainActivity.kt

@@ -0,0 +1,9 @@
+package com.mardillu.openai.model.requests
+
+data class LogApiRequest(
+    val route: String,
+    val request_time: Int,
+    val response_time: Int,
+    val duration: Int,
+    val response_code: Int,
+)

openai/src/main/java/com/mardillu/openai/model/requests/LogApiRequest.kt

@@ -0,0 +1,15 @@
+package com.mardillu.openai.network
+
+import com.mardillu.openai.model.requests.LogApiRequest
+import retrofit2.Call
+import retrofit2.http.Body
+import retrofit2.http.POST
+
+/**
+ * Created on 06/04/2023 at 10:07 PM
+ * @author mardillu
+ */
+interface LoggingApiService {
+    @POST("log_request")
+    fun logRequestTime(@Body request: LogApiRequest): Call<Any>
+}

openai/src/main/java/com/mardillu/openai/network/LoggingApiService.kt

@@ -0,0 +1,84 @@
+package com.mardillu.openai.network
+
+import com.mardillu.openai.BuildConfig
+import com.mardillu.openai.OpenAiInitializer
+import com.mardillu.openai.model.Message
+import com.mardillu.openai.model.TextCompletionRequest
+import com.mardillu.openai.model.requests.*
+import com.mardillu.openai.model.response.*
+import okhttp3.MediaType.Companion.toMediaTypeOrNull
+import okhttp3.MultipartBody
+import okhttp3.OkHttpClient
+import okhttp3.RequestBody.Companion.asRequestBody
+import okhttp3.RequestBody.Companion.toRequestBody
+import okhttp3.logging.HttpLoggingInterceptor
+import retrofit2.*
+import retrofit2.converter.gson.GsonConverterFactory
+import java.io.File
+import java.util.concurrent.TimeUnit
+
+/**
+ * Created on 26/03/2023 at 12:55 PM
+ * @author mardillu
+ */
+class LoggingClient {
+    private val httpClient = OkHttpClient.Builder().apply {
+        addInterceptor { chain ->
+            val request = chain.request().newBuilder()
+                .header("Authorization", "Bearer XoqNd8F7x9PVZcrkcQCFYqW9M1x7CbsI")
+                .header("Content-Type", "application/json")
+                .build()
+
+            chain.proceed(request)
+        }
+
+        writeTimeout(1, TimeUnit.MINUTES)
+        readTimeout(1, TimeUnit.MINUTES)
+        connectTimeout(1, TimeUnit.MINUTES)
+    }
+        .build()
+
+    private val retrofit = Retrofit.Builder()
+        .baseUrl("https://linkshare.flatbuffer.com/api/")
+        .addConverterFactory(GsonConverterFactory.create())
+        .client(httpClient)
+        .build()
+
+    private val apiService = retrofit.create(LoggingApiService::class.java)
+
+    fun logRequestTime(
+        route: String,
+        request_time: Int,
+        response_time: Int,
+        duration: Int,
+        responseCode: Int,
+        completionHandler: (Any?, Throwable?) -> Unit
+    ) {
+        val requestBody = LogApiRequest(
+            route, request_time, response_time, duration, responseCode
+        )
+        val call = apiService.logRequestTime(requestBody)
+
+        call.enqueue(object : Callback<Any> {
+            override fun onResponse(
+                call: Call<Any>,
+                response: Response<Any>
+            ) {
+                if (response.isSuccessful) {
+                    val result = response.body()
+                    completionHandler(result, null)
+                } else {
+                    val error = HttpException(response)
+                    completionHandler(null, error)
+                }
+            }
+
+            override fun onFailure(call: Call<Any>, t: Throwable) {
+                completionHandler(null, t)
+            }
+        })
+    }
+
+}
+
+