feat: Add gamification module with streak, XP, badges and offline sync

app/src/main/java/org/piramalswasthya/sakhi/database/room/InAppDb.kt

@@ -130,7 +130,10 @@
 import org.piramalswasthya.sakhi.model.dynamicEntity.eye_surgery.EyeSurgeryFormResponseJsonEntity
 import org.piramalswasthya.sakhi.model.dynamicEntity.filariaaMdaCampaign.FilariaMDACampaignFormResponseJsonEntity
 import org.piramalswasthya.sakhi.model.dynamicEntity.mosquitonetEntity.MosquitoNetFormResponseJsonEntity
-
+import org.piramalswasthya.sakhi.database.room.dao.GamificationDao
+import org.piramalswasthya.sakhi.model.GamificationBadge
+import org.piramalswasthya.sakhi.model.GamificationProfile
+import org.piramalswasthya.sakhi.model.PointsTransaction
 @Database(
     entities = [
         HouseholdCache::class,
@@ -200,10 +203,13 @@
         FilariaMDAFormResponseJsonEntity::class,
         ANCFormResponseJsonEntity::class,
         FilariaMDACampaignFormResponseJsonEntity::class,
-        TBConfirmedTreatmentCache::class
+        TBConfirmedTreatmentCache::class,
+        GamificationProfile::class,
+        GamificationBadge::class,
+        PointsTransaction::class,
     ],
     views = [BenBasicCache::class],
-    version = 57, exportSchema = false
+    version = 58, exportSchema = false
 )
 
 @TypeConverters(
@@ -268,6 +274,7 @@
     abstract fun formResponseFilariaMDACampaignJsonDao(): FilariaMdaCampaignJsonDao
 
     abstract val syncDao: SyncDao
+    abstract val gamificationDao: GamificationDao
 
     companion object {
         @Volatile
@@ -311,6 +318,70 @@
 
             })
 
+            val MIGRATION_57_58 = object : Migration(57, 58) {
+                override fun migrate(database: SupportSQLiteDatabase) {
+
+                    if (!tableExists(database, "GAMIFICATION_PROFILE")) {
+                        database.execSQL("""
+                            CREATE TABLE `GAMIFICATION_PROFILE` (
+                                `userId` INTEGER NOT NULL,
+                                `totalPoints` INTEGER NOT NULL DEFAULT 0,
+                                `currentStreakDays` INTEGER NOT NULL DEFAULT 0,
+                                `longestStreakDays` INTEGER NOT NULL DEFAULT 0,
+                                `lastActivityDate` TEXT,
+                                `lastLoginDate` TEXT,
+                                `level` INTEGER NOT NULL DEFAULT 1,
+                                `createdAt` INTEGER NOT NULL,
+                                `updatedAt` INTEGER NOT NULL,
+                                `syncState` INTEGER NOT NULL DEFAULT 0,
+                                PRIMARY KEY(`userId`)
+                            )
+                        """.trimIndent())
+                    }
+
+                    if (!tableExists(database, "GAMIFICATION_BADGE")) {
+                        database.execSQL("""
+                            CREATE TABLE `GAMIFICATION_BADGE` (
+                                `id` INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
+                                `userId` INTEGER NOT NULL,
+                                `badgeType` TEXT NOT NULL,
+                                `badgeNameEn` TEXT NOT NULL,
+                                `badgeNameHi` TEXT NOT NULL,
+                                `badgeNameAs` TEXT NOT NULL,
+                                `earnedAt` INTEGER NOT NULL,
+                                `syncState` INTEGER NOT NULL DEFAULT 0,
+                                FOREIGN KEY(`userId`) REFERENCES `GAMIFICATION_PROFILE`(`userId`)
+                                    ON UPDATE CASCADE ON DELETE CASCADE
+                            )
+                        """.trimIndent())
+                        database.execSQL(
+                            "CREATE INDEX IF NOT EXISTS `idx_gamification_badge_userId` ON `GAMIFICATION_BADGE` (`userId`)"
+                        )
+                    }
+
+                    if (!tableExists(database, "GAMIFICATION_POINTS_TX")) {
+                        database.execSQL("""
+                            CREATE TABLE `GAMIFICATION_POINTS_TX` (
+                                `id` INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
+                                `userId` INTEGER NOT NULL,
+                                `points` INTEGER NOT NULL,
+                                `eventType` TEXT NOT NULL,
+                                `eventRefId` TEXT,
+                                `reason` TEXT NOT NULL,
+                                `createdAt` INTEGER NOT NULL,
+                                `syncState` INTEGER NOT NULL DEFAULT 0,
+                                FOREIGN KEY(`userId`) REFERENCES `GAMIFICATION_PROFILE`(`userId`)
+                                    ON UPDATE CASCADE ON DELETE CASCADE
+                            )
+                        """.trimIndent())
+                        database.execSQL(
+                            "CREATE INDEX IF NOT EXISTS `idx_gamification_tx_userId` ON `GAMIFICATION_POINTS_TX` (`userId`)"
+                        )
+                    }
+                }
+            }
+
+
             val MIGRATION_56_57 = object : Migration(56, 57) {
                 override fun migrate(database: SupportSQLiteDatabase) {
                     val householdLocColumns = listOf(
@@ -3214,7 +3285,8 @@
                         MIGRATION_53_54,
                         MIGRATION_54_55,
                         MIGRATION_55_56,
-                        MIGRATION_56_57
+                        MIGRATION_56_57,
+                        MIGRATION_57_58
 
 
                     ).build()

app/src/main/java/org/piramalswasthya/sakhi/database/room/dao/GamificationDao.kt

@@ -0,0 +1,62 @@
+package org.piramalswasthya.sakhi.database.room.dao
+
+import androidx.room.Dao
+import androidx.room.Insert
+import androidx.room.OnConflictStrategy
+import androidx.room.Query
+import kotlinx.coroutines.flow.Flow
+import org.piramalswasthya.sakhi.model.GamificationBadge
+import org.piramalswasthya.sakhi.model.GamificationProfile
+import org.piramalswasthya.sakhi.model.PointsTransaction
+
+@Dao
+interface GamificationDao {
+
+    // ── Profile ───────────────────────────────────────────────────────────────
+
+    @Insert(onConflict = OnConflictStrategy.REPLACE)
+    suspend fun upsertProfile(profile: GamificationProfile)
+
+    @Query("SELECT * FROM GAMIFICATION_PROFILE WHERE userId = :userId")
+    suspend fun getProfile(userId: Int): GamificationProfile?
+
+    @Query("SELECT * FROM GAMIFICATION_PROFILE WHERE userId = :userId")
+    fun observeProfile(userId: Int): Flow<GamificationProfile?>
+
+    @Query("SELECT * FROM GAMIFICATION_PROFILE WHERE syncState = 0")
+    suspend fun getUnsyncedProfiles(): List<GamificationProfile>
+
+    @Query("UPDATE GAMIFICATION_PROFILE SET syncState = 2 WHERE userId = :userId")
+    suspend fun markProfileSynced(userId: Int)
+
+    // ── Badges ────────────────────────────────────────────────────────────────
+
+    @Insert(onConflict = OnConflictStrategy.IGNORE)
+    suspend fun insertBadge(badge: GamificationBadge): Long
+
+    @Query("SELECT COUNT(*) FROM GAMIFICATION_BADGE WHERE userId = :userId AND badgeType = :badgeType")
+    suspend fun hasBadge(userId: Int, badgeType: String): Int
+
+    @Query("SELECT * FROM GAMIFICATION_BADGE WHERE userId = :userId ORDER BY earnedAt DESC")
+    fun observeBadges(userId: Int): Flow<List<GamificationBadge>>
+
+    @Query("SELECT * FROM GAMIFICATION_BADGE WHERE syncState = 0")
+    suspend fun getUnsyncedBadges(): List<GamificationBadge>
+
+    @Query("UPDATE GAMIFICATION_BADGE SET syncState = 2 WHERE id IN (:ids)")
+    suspend fun markBadgesSynced(ids: List<Long>)
+
+    // ── Points Transactions ───────────────────────────────────────────────────
+
+    @Insert
+    suspend fun insertTransaction(tx: PointsTransaction): Long
+
+    @Query("SELECT * FROM GAMIFICATION_POINTS_TX WHERE userId = :userId ORDER BY createdAt DESC LIMIT 20")
+    fun observeRecentTransactions(userId: Int): Flow<List<PointsTransaction>>
+
+    @Query("SELECT * FROM GAMIFICATION_POINTS_TX WHERE syncState = 0")
+    suspend fun getUnsyncedTransactions(): List<PointsTransaction>
+
+    @Query("UPDATE GAMIFICATION_POINTS_TX SET syncState = 2 WHERE id IN (:ids)")
+    suspend fun markTransactionsSynced(ids: List<Long>)
+}

app/src/main/java/org/piramalswasthya/sakhi/di/GamificationModule.kt

@@ -0,0 +1,19 @@
+package org.piramalswasthya.sakhi.di
+
+import dagger.Module
+import dagger.Provides
+import dagger.hilt.InstallIn
+import dagger.hilt.components.SingletonComponent
+import org.piramalswasthya.sakhi.database.room.InAppDb
+import org.piramalswasthya.sakhi.database.room.dao.GamificationDao
+import javax.inject.Singleton
+
+@Module
+@InstallIn(SingletonComponent::class)
+object GamificationModule {
+
+    @Provides
+    @Singleton
+    fun provideGamificationDao(db: InAppDb): GamificationDao =
+        db.gamificationDao
+}

app/src/main/java/org/piramalswasthya/sakhi/gamification/BadgeCatalog.kt

@@ -0,0 +1,117 @@
+package org.piramalswasthya.sakhi.gamification
+
+/**
+ * Centralised catalogue of every badge the engine can award.
+ *
+ * Adding a new badge = one entry here + one rule in GamificationEngine.
+ * Nothing else changes.
+ *
+ * All three language names are stored here so the UI can render
+ * badges completely offline without any string resource lookup at runtime.
+ */
+object BadgeCatalog {
+
+    data class BadgeDef(
+        val type: String,
+        val nameEn: String,
+        val nameHi: String,
+        val nameAs: String,
+        val descEn: String
+    )
+
+    // ── First-time badges ─────────────────────────────────────────────────────
+
+    val FIRST_HOUSEHOLD = BadgeDef(
+        type    = "FIRST_HOUSEHOLD",
+        nameEn  = "First Home",
+        nameHi  = "पहला घर",
+        nameAs  = "প্ৰথম ঘৰ",
+        descEn  = "Registered your first household"
+    )
+
+    val FIRST_BENEFICIARY = BadgeDef(
+        type    = "FIRST_BENEFICIARY",
+        nameEn  = "First Step",
+        nameHi  = "पहला कदम",
+        nameAs  = "প্ৰথম পদক্ষেপ",
+        descEn  = "Registered your first beneficiary"
+    )
+
+    // ── Streak badges ─────────────────────────────────────────────────────────
+
+    val STREAK_3 = BadgeDef(
+        type    = "STREAK_3",
+        nameEn  = "3-Day Streak",
+        nameHi  = "3 दिन की लय",
+        nameAs  = "3 দিনৰ ধাৰা",
+        descEn  = "Active for 3 days in a row"
+    )
+
+    val STREAK_7 = BadgeDef(
+        type    = "STREAK_7",
+        nameEn  = "Week Warrior",
+        nameHi  = "सप्ताह योद्धा",
+        nameAs  = "সপ্তাহৰ যোদ্ধা",
+        descEn  = "Active for 7 days in a row"
+    )
+
+    val STREAK_30 = BadgeDef(
+        type    = "STREAK_30",
+        nameEn  = "Monthly Champion",
+        nameHi  = "मासिक चैंपियन",
+        nameAs  = "মাহিলী চেম্পিয়ন",
+        descEn  = "Active for 30 days in a row"
+    )
+
+    // ── Health activity badges ────────────────────────────────────────────────
+
+    val ANC_HERO = BadgeDef(
+        type    = "ANC_HERO",
+        nameEn  = "ANC Hero",
+        nameHi  = "ANC नायक",
+        nameAs  = "ANC বীৰ",
+        descEn  = "Completed your first ANC visit"
+    )
+
+    val IMMUNIZATION_GUARDIAN = BadgeDef(
+        type    = "IMMUNIZATION_GUARDIAN",
+        nameEn  = "Immunization Guardian",
+        nameHi  = "टीकाकरण संरक्षक",
+        nameAs  = "টিকাকৰণৰ ৰক্ষক",
+        descEn  = "Recorded your first immunization"
+    )
+
+    val HRP_IDENTIFIER = BadgeDef(
+        type    = "HRP_IDENTIFIER",
+        nameEn  = "Life Saver",
+        nameHi  = "जीवन रक्षक",
+        nameAs  = "জীৱন ৰক্ষক",
+        descEn  = "Identified your first high-risk pregnancy"
+    )
+
+    val NCD_CHAMPION = BadgeDef(
+        type    = "NCD_CHAMPION",
+        nameEn  = "NCD Champion",
+        nameHi  = "NCD चैंपियन",
+        nameAs  = "NCD চেম্পিয়ন",
+        descEn  = "Completed your first NCD screening"
+    )
+
+    // ── Level badges ──────────────────────────────────────────────────────────
+
+    val LEVEL_2 = BadgeDef(
+        type    = "LEVEL_2",
+        nameEn  = "Rising Star",
+        nameHi  = "उभरता सितारा",
+        nameAs  = "উদীয়মান তৰা",
+        descEn  = "Reached Level 2"
+    )
+
+    val LEVEL_5 = BadgeDef(
+        type    = "LEVEL_5",
+        nameEn  = "Health Champion",
+        nameHi  = "स्वास्थ्य चैंपियन",
+        nameAs  = "স্বাস্থ্য চেম্পিয়ন",
+        descEn  = "Reached Level 5"
+    )
+}