diff --git a/TopsortAnalytics/build.gradle b/TopsortAnalytics/build.gradle
index 07529d3..001d315 100644
--- a/TopsortAnalytics/build.gradle
+++ b/TopsortAnalytics/build.gradle
@@ -37,9 +37,11 @@ android {
 dependencies {
 
     implementation 'androidx.core:core-ktx:1.10.1'
+    implementation '.core:core-ktx:1.10.1'
 
     //Work Manager
     implementation "androidx.work:work-runtime-ktx:2.8.1"
+    implementation("androidx.datastore:datastore-preferences:1.1.1")
 
     //JodaTime
     implementation group: 'joda-time', name: 'joda-time', version: '2.12.5'
diff --git a/TopsortAnalytics/src/main/java/com/topsort/analytics/CacheAsync.kt b/TopsortAnalytics/src/main/java/com/topsort/analytics/CacheAsync.kt
new file mode 100644
index 0000000..174df8f
--- /dev/null
+++ b/TopsortAnalytics/src/main/java/com/topsort/analytics/CacheAsync.kt
@@ -0,0 +1,161 @@
+package com.topsort.analytics
+
+import android.content.Context
+import android.content.SharedPreferences
+import android.text.TextUtils
+import androidx.datastore.core.DataStore
+import androidx.datastore.preferences.core.Preferences
+import androidx.datastore.preferences.core.edit
+import androidx.datastore.preferences.core.stringPreferencesKey
+import androidx.datastore.preferences.preferencesDataStore
+import com.topsort.analytics.model.ClickEvent
+import com.topsort.analytics.model.ImpressionEvent
+import com.topsort.analytics.model.PurchaseEvent
+import kotlinx.coroutines.flow.map
+import kotlinx.coroutines.runBlocking
+import java.util.Locale
+
+private const val preferencesName = "TOPSORT_EVENTS_CACHE"
+
+private val KEY_TOKEN = stringPreferencesKey("KEY_TOKEN")
+private val KEY_SESSION_ID = stringPreferencesKey("KEY_SESSION_ID")
+private const val KEY_RECORD = "KEY_RECORD_%d"
+private const val KEY_RECENT_RECORD_ID = "KEY_RECORD_ID"
+
+val Context.dataStore: DataStore<Preferences> by preferencesDataStore(name = "settings")
+
+internal object CacheAsync {
+
+    private lateinit var applicationContext: Context
+
+    private var recentRecordId: Long = 0
+
+    var token: String = ""
+        set(value) {
+            field = value
+            runBlocking {
+                applicationContext.dataStore.edit{ store ->
+                    store[KEY_TOKEN] = value
+                }
+            }
+        }
+
+    var sessionId: String = ""
+        set(value) {
+            field = value
+            runBlocking {
+                applicationContext.dataStore.edit { store ->
+                    store[KEY_SESSION_ID] = value
+                }
+            }
+        }
+
+    fun initialize(context: Context) {
+        applicationContext = context.applicationContext
+
+
+        applicationContext.dataStore.data
+            .map { store ->
+                store[KEY_TOKEN]
+            }
+
+        token = preferences.getString(KEY_TOKEN, "")!!
+        sessionId = preferences.getString(KEY_SESSION_ID, "")!!
+    }
+
+    fun setup(
+        context: Context,
+        sessionId: String,
+        token: String
+    ) {
+        initialize(context)
+
+        recentRecordId = preferences.getLong(KEY_RECENT_RECORD_ID, 0)
+        this.sessionId = sessionId
+        this.token = token
+    }
+
+    fun storeImpression(
+        impressionEvent: ImpressionEvent
+    ): Long {
+        val json = impressionEvent.toJsonObject().toString()
+        preferences
+            .edit()
+            .putString(nextRecordKey(), json)
+            .apply()
+
+        return recentRecordId
+    }
+
+    fun readImpression(recordId: Long): ImpressionEvent? {
+        return ImpressionEvent.fromJson(readEvent(recordId))
+    }
+
+    fun storeClick(
+        clickEvent: ClickEvent
+    ): Long {
+        val json = clickEvent.toJsonObject().toString()
+        preferences
+            .edit()
+            .putString(nextRecordKey(), json)
+            .apply()
+
+        return recentRecordId
+    }
+
+    fun readClick(recordId: Long): ClickEvent? {
+        return ClickEvent.fromJson(readEvent(recordId))
+    }
+
+    fun storePurchase(
+        purchaseEvent: PurchaseEvent
+    ): Long {
+        val json = purchaseEvent.toJsonObject().toString()
+        preferences
+            .edit()
+            .putString(nextRecordKey(), json)
+            .apply()
+
+        return recentRecordId
+    }
+
+    fun readPurchase(recordId: Long): PurchaseEvent? {
+        return PurchaseEvent.fromJson(readEvent(recordId))
+    }
+
+    fun deleteEvent(recordId: Long) {
+        preferences
+            .edit()
+            .remove(recordKey(recordId))
+            .apply()
+    }
+
+    private fun readEvent(recordId: Long): String? {
+        val json = preferences.getString(recordKey(recordId), "")
+        if (TextUtils.isEmpty(json)) {
+            return null
+        }
+
+        return json
+    }
+
+    private fun recordKey(recordId: Long) = String.format(
+        Locale.ENGLISH,
+        KEY_RECORD,
+        recordId
+    )
+
+    private fun nextRecordKey(): String {
+        recentRecordId = if (recentRecordId < Long.MAX_VALUE) {
+            recentRecordId + 1
+        } else {
+            0
+        }
+
+        preferences
+            .edit()
+            .putLong(KEY_RECENT_RECORD_ID, recentRecordId)
+            .apply()
+        return recordKey(recentRecordId)
+    }
+}