fix(logger): handled logs pushed before initialisation of plugin (#249)

* fix(logger): handled logs pushed before initialisation of plugin

* fix(logger): minor refactor

* fix(logger): minor refactor

Author: srtvprateek

pluto-plugins/plugins/logger/lib/src/main/java/com/pluto/plugins/logger/PlutoLog.kt

@@ -12,37 +12,44 @@ class PlutoLog private constructor() {
     companion object {
 
         @JvmStatic
+        @JvmOverloads
         fun v(tag: String, message: String, tr: Throwable? = null) {
             process(Log.VERBOSE, tag, message, tr, Thread.currentThread().getStackTraceElement())
         }
 
         @JvmStatic
+        @JvmOverloads
         fun d(tag: String, message: String, tr: Throwable? = null) {
             process(Log.DEBUG, tag, message, tr, Thread.currentThread().getStackTraceElement())
         }
 
         @JvmStatic
+        @JvmOverloads
         fun i(tag: String, message: String, tr: Throwable? = null) {
             process(Log.INFO, tag, message, tr, Thread.currentThread().getStackTraceElement())
         }
 
         @JvmStatic
+        @JvmOverloads
         fun w(tag: String, message: String, tr: Throwable? = null) {
             process(Log.WARN, tag, message, tr, Thread.currentThread().getStackTraceElement())
         }
 
         @JvmStatic
+        @JvmOverloads
         fun e(tag: String, message: String, tr: Throwable? = null) {
             process(Log.ERROR, tag, message, tr, Thread.currentThread().getStackTraceElement())
         }
 
         @JvmStatic
+        @JvmOverloads
         fun wtf(tag: String, message: String, tr: Throwable? = null) {
             process(Log.ASSERT, tag, message, tr, Thread.currentThread().getStackTraceElement())
         }
 
         @JvmStatic
-        fun event(tag: String, event: String, attributes: HashMap<String, Any?>?) {
+        @JvmOverloads
+        fun event(tag: String, event: String, attributes: HashMap<String, Any?>? = null) {
             processEvent(tag, event, attributes, Thread.currentThread().getStackTraceElement())
         }
 

pluto-plugins/plugins/logger/lib/src/main/java/com/pluto/plugins/logger/internal/LogsProcessor.kt

@@ -14,15 +14,15 @@ internal class LogsProcessor private constructor() {
 
         fun process(priority: Int, tag: String, message: String, tr: Throwable?, stackTraceElement: StackTraceElement) {
             val stackTrace = stackTraceElement.stackTrace()
-            LogDBHandler.persist(priority2Level(priority), tag, message, tr, stackTrace)
+            LogDBHandler.persistLog(priority2Level(priority), tag, message, tr, stackTrace)
             consolePrint(priority2Level(priority), tag, message, tr, stackTrace)
         }
 
         fun processEvent(tag: String, event: String, attr: HashMap<String, Any?>?, stackTraceElement: StackTraceElement) {
             val moshi = Moshi.Builder().build()
             val moshiAdapter: JsonAdapter<Map<String, Any?>?> = moshi.adapter(Types.newParameterizedType(Map::class.java, String::class.java, Any::class.java))
             val stackTrace = stackTraceElement.stackTrace()
-            LogDBHandler.persist(Level.Event, tag, event, attr, stackTrace)
+            LogDBHandler.persistEvent(Level.Event, tag, event, attr, stackTrace)
             consolePrint(Level.Event, tag, "$event => ${moshiAdapter.toJson(attr)}", null, stackTrace)
         }
 

pluto-plugins/plugins/logger/lib/src/main/java/com/pluto/plugins/logger/internal/persistence/LogDBHandler.kt

@@ -13,42 +13,57 @@ import kotlinx.coroutines.launch
 
 internal object LogDBHandler {
 
-    private lateinit var logDao: LogDao
+    private var logDao: LogDao? = null
     private val coroutineScope = CoroutineScope(Dispatchers.IO)
 
+    /**
+     * Store log temporarily till the LogDBHandler is not initialised.
+     */
+    private val tempList = arrayListOf<LogEntity>()
+
     fun initialize(context: Context) {
         logDao = DatabaseManager(context).db.exceptionDao()
+        processTempList()
     }
 
-    fun persist(level: Level, tag: String, message: String?, tr: Throwable?, ele: StackTrace) {
+    fun persistLog(level: Level, tag: String, message: String?, tr: Throwable?, ele: StackTrace) {
         coroutineScope.launch {
-            logDao.save(
-                LogEntity(
-                    timestamp = System.currentTimeMillis(),
-                    data = LogData(level, tag, message ?: "", tr?.asExceptionData(), ele)
-                ),
+            val logEntity = LogEntity(
+                timestamp = System.currentTimeMillis(),
+                data = LogData(level, tag, message ?: "", tr?.asExceptionData(), ele)
             )
+            logDao?.save(logEntity) ?: run { pushToTempList(logEntity) }
         }
     }
 
-    fun persist(level: Level, tag: String, event: String, attr: HashMap<String, Any?>?, ele: StackTrace) {
+    fun persistEvent(level: Level, tag: String, event: String, attr: HashMap<String, Any?>?, ele: StackTrace) {
         coroutineScope.launch {
-            logDao.save(
-                LogEntity(
-                    timestamp = System.currentTimeMillis(),
-                    data = LogData(level, tag, event ?: "", null, ele, attr)
-                ),
+            val logEntity = LogEntity(
+                timestamp = System.currentTimeMillis(),
+                data = LogData(level, tag, event, null, ele, attr)
             )
+            logDao?.save(logEntity) ?: run { pushToTempList(logEntity) }
         }
     }
 
     suspend fun fetchAll(): List<LogEntity>? {
-        return logDao.fetchAll()
+        return logDao?.fetchAll()
     }
 
     fun flush() {
         coroutineScope.launch {
-            logDao.deleteAll()
+            logDao?.deleteAll()
+        }
+    }
+
+    private fun pushToTempList(logEntity: LogEntity) {
+        tempList.add(logEntity)
+    }
+
+    private fun processTempList() {
+        coroutineScope.launch {
+            logDao?.saveAll(tempList)
+            tempList.clear()
         }
     }
 }

pluto-plugins/plugins/logger/lib/src/main/java/com/pluto/plugins/logger/internal/persistence/LogDao.kt

@@ -11,6 +11,9 @@ internal interface LogDao {
     @Insert(onConflict = OnConflictStrategy.REPLACE)
     suspend fun save(entity: LogEntity)
 
+    @Insert(onConflict = OnConflictStrategy.REPLACE)
+    suspend fun saveAll(entities: List<LogEntity>)
+
     @Query("SELECT * FROM logs where id is :id")
     suspend fun fetch(id: Int): LogEntity?