diff --git a/demo-app/src/androidTest/java/com/personalization/demo/LoyaltyIntegrationTest.kt b/demo-app/src/androidTest/java/com/personalization/demo/LoyaltyIntegrationTest.kt
new file mode 100644
index 00000000..1cbdc049
--- /dev/null
+++ b/demo-app/src/androidTest/java/com/personalization/demo/LoyaltyIntegrationTest.kt
@@ -0,0 +1,37 @@
+package com.personalization.demo
+
+import androidx.test.espresso.Espresso.onView
+import androidx.test.espresso.action.ViewActions.click
+import androidx.test.espresso.action.ViewActions.scrollTo
+import androidx.test.espresso.matcher.ViewMatchers.withId
+import androidx.test.ext.junit.rules.ActivityScenarioRule
+import androidx.test.ext.junit.runners.AndroidJUnit4
+import org.junit.Rule
+import org.junit.Test
+import org.junit.runner.RunWith
+
+/**
+ * On-device E2E for the loyalty demo buttons. Launches [MainActivity] (which performs the real
+ * production Firebase + SDK initialization) and taps the loyalty buttons, exercising
+ * `loyaltyManager.join` / `loyaltyManager.getStatus` against the live REES46 API on the emulator.
+ *
+ * Mirrors [OrdersDemoE2ETest]: asserts the real on-device code path runs without crashing.
+ */
+@RunWith(AndroidJUnit4::class)
+class LoyaltyIntegrationTest {
+
+    @get:Rule
+    val activityRule = ActivityScenarioRule(MainActivity::class.java)
+
+    @Test
+    fun loyaltyJoin_tapButton_noCrash() {
+        onView(withId(R.id.btnLoyaltyJoin)).perform(scrollTo(), click())
+        Thread.sleep(3000)
+    }
+
+    @Test
+    fun loyaltyStatus_tapButton_noCrash() {
+        onView(withId(R.id.btnLoyaltyStatus)).perform(scrollTo(), click())
+        Thread.sleep(3000)
+    }
+}
diff --git a/demo-app/src/main/java/com/personalization/demo/MainActivity.kt b/demo-app/src/main/java/com/personalization/demo/MainActivity.kt
index b24991d9..9131b62c 100644
--- a/demo-app/src/main/java/com/personalization/demo/MainActivity.kt
+++ b/demo-app/src/main/java/com/personalization/demo/MainActivity.kt
@@ -46,6 +46,13 @@ class MainActivity : AppCompatActivity() {
         val SHOP_SECRET = BuildConfig.SHOP_SECRET
     }
 
+    private object DemoLoyaltyConstants {
+        const val PHONE = "79991234567"
+        const val EMAIL = "demo@rees46.ru"
+        const val FIRST_NAME = "Demo"
+        const val LAST_NAME = "User"
+    }
+
     private object DemoProductViewConstants {
         const val PRODUCT_ID = "demo-product-view-001"
         const val DEMO_PRICE = 2499.99
@@ -137,6 +144,70 @@ class MainActivity : AppCompatActivity() {
         findViewById<Button>(R.id.btnGetUserOrders).setOnClickListener {
             getUserOrders()
         }
+
+        findViewById<Button>(R.id.btnLoyaltyJoin).setOnClickListener {
+            loyaltyJoin()
+        }
+
+        findViewById<Button>(R.id.btnLoyaltyStatus).setOnClickListener {
+            loyaltyStatus()
+        }
+    }
+
+    private fun loyaltyJoin() {
+        sdk.loyaltyManager.join(
+            phone = DemoLoyaltyConstants.PHONE,
+            email = DemoLoyaltyConstants.EMAIL,
+            firstName = DemoLoyaltyConstants.FIRST_NAME,
+            lastName = DemoLoyaltyConstants.LAST_NAME,
+            onSuccess = { response ->
+                runOnUiThread {
+                    Toast.makeText(
+                        this,
+                        getString(R.string.loyalty_join_ok, response.status ?: "—"),
+                        Toast.LENGTH_LONG,
+                    ).show()
+                }
+            },
+            onError = { code, msg ->
+                runOnUiThread {
+                    Toast.makeText(
+                        this,
+                        "${getString(R.string.loyalty_join_fail)}: $code $msg",
+                        Toast.LENGTH_LONG,
+                    ).show()
+                }
+            },
+        )
+    }
+
+    private fun loyaltyStatus() {
+        sdk.loyaltyManager.getStatus(
+            identifier = DemoLoyaltyConstants.PHONE,
+            onSuccess = { response ->
+                runOnUiThread {
+                    val member = response.payload?.member
+                    val level = response.payload?.level?.name
+                    Toast.makeText(
+                        this,
+                        getString(
+                            R.string.loyalty_status_ok,
+                            "${response.status ?: "—"} (member=$member, level=$level)",
+                        ),
+                        Toast.LENGTH_LONG,
+                    ).show()
+                }
+            },
+            onError = { code, msg ->
+                runOnUiThread {
+                    Toast.makeText(
+                        this,
+                        "${getString(R.string.loyalty_status_fail)}: $code $msg",
+                        Toast.LENGTH_LONG,
+                    ).show()
+                }
+            },
+        )
     }
 
     private fun getUserOrders() {
diff --git a/demo-app/src/main/res/layout/activity_main.xml b/demo-app/src/main/res/layout/activity_main.xml
index 1843126f..bb0b042c 100644
--- a/demo-app/src/main/res/layout/activity_main.xml
+++ b/demo-app/src/main/res/layout/activity_main.xml
@@ -1,10 +1,15 @@
 <?xml version="1.0" encoding="utf-8"?>
-<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
+<ScrollView xmlns:android="http://schemas.android.com/apk/res/android"
     android:layout_width="match_parent"
     android:layout_height="match_parent"
-    android:orientation="vertical"
-    android:padding="16dp"
-    android:gravity="center">
+    android:fillViewport="true">
+
+    <LinearLayout
+        android:layout_width="match_parent"
+        android:layout_height="wrap_content"
+        android:orientation="vertical"
+        android:padding="16dp"
+        android:gravity="center">
 
     <Button
         android:id="@+id/btnShowTestPopup"
@@ -83,6 +88,22 @@
         android:text="@string/get_user_orders"
         android:layout_marginTop="16dp" />
 
-</LinearLayout>
+    <Button
+        android:id="@+id/btnLoyaltyJoin"
+        android:layout_width="wrap_content"
+        android:layout_height="wrap_content"
+        android:text="@string/loyalty_join"
+        android:layout_marginTop="24dp" />
+
+    <Button
+        android:id="@+id/btnLoyaltyStatus"
+        android:layout_width="wrap_content"
+        android:layout_height="wrap_content"
+        android:text="@string/loyalty_status"
+        android:layout_marginTop="16dp" />
+
+    </LinearLayout>
+
+</ScrollView>
 
 
diff --git a/demo-app/src/main/res/values/strings.xml b/demo-app/src/main/res/values/strings.xml
index f62be95a..0b5960b2 100644
--- a/demo-app/src/main/res/values/strings.xml
+++ b/demo-app/src/main/res/values/strings.xml
@@ -28,6 +28,12 @@
     <string name="get_user_orders">Get user orders</string>
     <string name="get_user_orders_ok">getUserOrders: %1$d order(s)</string>
     <string name="get_user_orders_fail">getUserOrders failed</string>
+    <string name="loyalty_join">Loyalty: join</string>
+    <string name="loyalty_join_ok">loyalty join: %1$s</string>
+    <string name="loyalty_join_fail">loyalty join failed</string>
+    <string name="loyalty_status">Loyalty: status</string>
+    <string name="loyalty_status_ok">loyalty status: %1$s</string>
+    <string name="loyalty_status_fail">loyalty status failed</string>
 </resources>
 
 
diff --git a/personalization-sdk/src/main/kotlin/com/personalization/SDK.kt b/personalization-sdk/src/main/kotlin/com/personalization/SDK.kt
index 04b66543..08380f7b 100644
--- a/personalization-sdk/src/main/kotlin/com/personalization/SDK.kt
+++ b/personalization-sdk/src/main/kotlin/com/personalization/SDK.kt
@@ -12,6 +12,7 @@ import com.personalization.api.OnApiCallbackListener
 import com.personalization.api.models.purchase.PurchaseTrackingRequest
 import com.personalization.api.managers.CartManager
 import com.personalization.api.managers.InAppNotificationManager
+import com.personalization.api.managers.LoyaltyManager
 import com.personalization.api.managers.OrdersManager
 import com.personalization.api.managers.ProductsManager
 import com.personalization.api.managers.PredictManager
@@ -88,6 +89,9 @@ open class SDK {
     @Inject
     lateinit var ordersManager: OrdersManager
 
+    @Inject
+    lateinit var loyaltyManager: LoyaltyManager
+
     @Inject
     lateinit var inAppNotificationManager: InAppNotificationManager
 
diff --git a/personalization-sdk/src/main/kotlin/com/personalization/api/managers/LoyaltyManager.kt b/personalization-sdk/src/main/kotlin/com/personalization/api/managers/LoyaltyManager.kt
new file mode 100644
index 00000000..2eaa2268
--- /dev/null
+++ b/personalization-sdk/src/main/kotlin/com/personalization/api/managers/LoyaltyManager.kt
@@ -0,0 +1,44 @@
+package com.personalization.api.managers
+
+import com.personalization.api.responses.loyalty.LoyaltyJoinResponse
+import com.personalization.api.responses.loyalty.LoyaltyStatusResponse
+
+interface LoyaltyManager {
+
+    /**
+     * Join the loyalty program (`loyalty/members/join`).
+     *
+     * The shop is identified automatically by the SDK's configured `shop_id`; only the member
+     * fields are passed here. [phone] is required by the endpoint.
+     *
+     * @param phone Member phone number (required)
+     * @param email Member email (optional)
+     * @param firstName Member first name (optional)
+     * @param lastName Member last name (optional)
+     * @param onSuccess Callback with the parsed join response
+     * @param onError Callback for error
+     */
+    fun join(
+        phone: String,
+        email: String? = null,
+        firstName: String? = null,
+        lastName: String? = null,
+        onSuccess: (LoyaltyJoinResponse) -> Unit,
+        onError: (Int, String?) -> Unit = { _: Int, _: String? -> }
+    )
+
+    /**
+     * Request the loyalty membership status (`loyalty/members/status`).
+     *
+     * The shop is identified automatically by the SDK's configured `shop_id`.
+     *
+     * @param identifier Member identifier (phone)
+     * @param onSuccess Callback with the parsed status response
+     * @param onError Callback for error
+     */
+    fun getStatus(
+        identifier: String,
+        onSuccess: (LoyaltyStatusResponse) -> Unit,
+        onError: (Int, String?) -> Unit = { _: Int, _: String? -> }
+    )
+}
diff --git a/personalization-sdk/src/main/kotlin/com/personalization/api/responses/loyalty/LoyaltyJoinResponse.kt b/personalization-sdk/src/main/kotlin/com/personalization/api/responses/loyalty/LoyaltyJoinResponse.kt
new file mode 100644
index 00000000..af999f93
--- /dev/null
+++ b/personalization-sdk/src/main/kotlin/com/personalization/api/responses/loyalty/LoyaltyJoinResponse.kt
@@ -0,0 +1,18 @@
+package com.personalization.api.responses.loyalty
+
+import com.google.gson.JsonObject
+import com.google.gson.annotations.SerializedName
+
+/**
+ * Response for the `loyalty/members/join` request.
+ *
+ * The endpoint returns an envelope `{ "status": "success" | "fail", "payload": { ... } }`.
+ * [payload] is intentionally kept as a raw [JsonObject] because its shape differs between
+ * success and failure responses.
+ */
+data class LoyaltyJoinResponse(
+    @SerializedName("status")
+    val status: String? = null,
+    @SerializedName("payload")
+    val payload: JsonObject? = null
+)
diff --git a/personalization-sdk/src/main/kotlin/com/personalization/api/responses/loyalty/LoyaltyStatusResponse.kt b/personalization-sdk/src/main/kotlin/com/personalization/api/responses/loyalty/LoyaltyStatusResponse.kt
new file mode 100644
index 00000000..0a5e319a
--- /dev/null
+++ b/personalization-sdk/src/main/kotlin/com/personalization/api/responses/loyalty/LoyaltyStatusResponse.kt
@@ -0,0 +1,31 @@
+package com.personalization.api.responses.loyalty
+
+import com.google.gson.annotations.SerializedName
+
+/**
+ * Response for the `loyalty/members/status` request.
+ *
+ * Envelope: `{ "status": "success" | "fail", "payload": { "member": ..., "level": { ... } } }`.
+ */
+data class LoyaltyStatusResponse(
+    @SerializedName("status")
+    val status: String? = null,
+    @SerializedName("payload")
+    val payload: LoyaltyStatusPayload? = null
+)
+
+data class LoyaltyStatusPayload(
+    @SerializedName("member")
+    val member: Boolean? = null,
+    @SerializedName("level")
+    val level: LoyaltyLevel? = null
+)
+
+data class LoyaltyLevel(
+    @SerializedName("name")
+    val name: String? = null,
+    @SerializedName("code")
+    val code: String? = null,
+    @SerializedName("expiration_date")
+    val expirationDate: String? = null
+)
diff --git a/personalization-sdk/src/main/kotlin/com/personalization/di/SdkModule.kt b/personalization-sdk/src/main/kotlin/com/personalization/di/SdkModule.kt
index 1cfd907a..39e8003e 100644
--- a/personalization-sdk/src/main/kotlin/com/personalization/di/SdkModule.kt
+++ b/personalization-sdk/src/main/kotlin/com/personalization/di/SdkModule.kt
@@ -4,6 +4,7 @@ import android.content.Context
 import com.personalization.RegisterManager
 import com.personalization.api.managers.CartManager
 import com.personalization.api.managers.InAppNotificationManager
+import com.personalization.api.managers.LoyaltyManager
 import com.personalization.api.managers.OrdersManager
 import com.personalization.api.managers.ProductsManager
 import com.personalization.api.managers.RecommendationManager
@@ -13,6 +14,7 @@ import com.personalization.api.managers.TrackEventManager
 import com.personalization.features.cart.CartManagerImpl
 import com.personalization.features.inAppNotification.impl.InAppNotificationManagerImpl
 import com.personalization.features.notification.domain.data.NotificationDataExtractor
+import com.personalization.features.loyalty.impl.LoyaltyManagerImpl
 import com.personalization.features.orders.impl.OrdersManagerImpl
 import com.personalization.features.predict.impl.PredictManagerImpl
 import com.personalization.features.products.impl.ProductsManagerImpl
@@ -129,6 +131,14 @@ class SdkModule {
         sendNetworkMethodUseCase = sendNetworkMethodUseCase
     )
 
+    @Singleton
+    @Provides
+    fun provideLoyaltyManager(
+        sendNetworkMethodUseCase: SendNetworkMethodUseCase
+    ): LoyaltyManager = LoyaltyManagerImpl(
+        sendNetworkMethodUseCase = sendNetworkMethodUseCase
+    )
+
     @Singleton
     @Provides
     fun provideInAppNotificationManager(
diff --git a/personalization-sdk/src/main/kotlin/com/personalization/features/loyalty/impl/LoyaltyManagerImpl.kt b/personalization-sdk/src/main/kotlin/com/personalization/features/loyalty/impl/LoyaltyManagerImpl.kt
new file mode 100644
index 00000000..2f3ddda8
--- /dev/null
+++ b/personalization-sdk/src/main/kotlin/com/personalization/features/loyalty/impl/LoyaltyManagerImpl.kt
@@ -0,0 +1,87 @@
+package com.personalization.features.loyalty.impl
+
+import com.google.gson.Gson
+import com.personalization.Params
+import com.personalization.api.OnApiCallbackListener
+import com.personalization.api.managers.LoyaltyManager
+import com.personalization.api.responses.loyalty.LoyaltyJoinResponse
+import com.personalization.api.responses.loyalty.LoyaltyStatusResponse
+import com.personalization.sdk.domain.usecases.network.SendNetworkMethodUseCase
+import javax.inject.Inject
+import org.json.JSONObject
+
+internal class LoyaltyManagerImpl @Inject constructor(
+    private val sendNetworkMethodUseCase: SendNetworkMethodUseCase
+) : LoyaltyManager {
+
+    override fun join(
+        phone: String,
+        email: String?,
+        firstName: String?,
+        lastName: String?,
+        onSuccess: (LoyaltyJoinResponse) -> Unit,
+        onError: (Int, String?) -> Unit
+    ) {
+        val params = Params()
+        params.put(PHONE_PARAM, phone)
+        email?.let { params.put(EMAIL_PARAM, it) }
+        firstName?.let { params.put(FIRST_NAME_PARAM, it) }
+        lastName?.let { params.put(LAST_NAME_PARAM, it) }
+
+        sendNetworkMethodUseCase.postAsync(
+            JOIN_REQUEST,
+            params.build(),
+            object : OnApiCallbackListener() {
+                override fun onSuccess(response: JSONObject?) {
+                    val parsed = Gson().fromJson(
+                        response.toString(),
+                        LoyaltyJoinResponse::class.java
+                    )
+                    onSuccess(parsed ?: LoyaltyJoinResponse())
+                }
+
+                override fun onError(code: Int, msg: String?) {
+                    onError(code, msg)
+                }
+            }
+        )
+    }
+
+    override fun getStatus(
+        identifier: String,
+        onSuccess: (LoyaltyStatusResponse) -> Unit,
+        onError: (Int, String?) -> Unit
+    ) {
+        val params = Params()
+        params.put(IDENTIFIER_PARAM, identifier)
+
+        sendNetworkMethodUseCase.getAsync(
+            STATUS_REQUEST,
+            params.build(),
+            object : OnApiCallbackListener() {
+                override fun onSuccess(response: JSONObject?) {
+                    val parsed = Gson().fromJson(
+                        response.toString(),
+                        LoyaltyStatusResponse::class.java
+                    )
+                    onSuccess(parsed ?: LoyaltyStatusResponse())
+                }
+
+                override fun onError(code: Int, msg: String?) {
+                    onError(code, msg)
+                }
+            }
+        )
+    }
+
+    companion object {
+        const val JOIN_REQUEST = "loyalty/members/join"
+        const val STATUS_REQUEST = "loyalty/members/status"
+
+        private const val PHONE_PARAM = "phone"
+        private const val EMAIL_PARAM = "email"
+        private const val FIRST_NAME_PARAM = "first_name"
+        private const val LAST_NAME_PARAM = "last_name"
+        private const val IDENTIFIER_PARAM = "identifier"
+    }
+}
diff --git a/personalization-sdk/src/test/kotlin/com/personalization/features/loyalty/impl/LoyaltyManagerImplTest.kt b/personalization-sdk/src/test/kotlin/com/personalization/features/loyalty/impl/LoyaltyManagerImplTest.kt
new file mode 100644
index 00000000..c653eba8
--- /dev/null
+++ b/personalization-sdk/src/test/kotlin/com/personalization/features/loyalty/impl/LoyaltyManagerImplTest.kt
@@ -0,0 +1,162 @@
+package com.personalization.features.loyalty.impl
+
+import com.personalization.api.OnApiCallbackListener
+import com.personalization.api.responses.loyalty.LoyaltyJoinResponse
+import com.personalization.api.responses.loyalty.LoyaltyStatusResponse
+import com.personalization.sdk.domain.usecases.network.SendNetworkMethodUseCase
+import io.mockk.Runs
+import io.mockk.every
+import io.mockk.just
+import io.mockk.mockk
+import io.mockk.slot
+import io.mockk.verify
+import org.json.JSONObject
+import org.junit.Assert.assertEquals
+import org.junit.Assert.assertFalse
+import org.junit.Assert.assertNull
+import org.junit.Assert.assertTrue
+import org.junit.Before
+import org.junit.Test
+import org.junit.runner.RunWith
+import org.robolectric.RobolectricTestRunner
+import org.robolectric.annotation.Config
+
+@RunWith(RobolectricTestRunner::class)
+@Config(sdk = [28])
+class LoyaltyManagerImplTest {
+
+    private lateinit var sendNetworkMethodUseCase: SendNetworkMethodUseCase
+    private lateinit var impl: LoyaltyManagerImpl
+
+    @Before
+    fun setUp() {
+        sendNetworkMethodUseCase = mockk(relaxed = true)
+        impl = LoyaltyManagerImpl(sendNetworkMethodUseCase)
+    }
+
+    @Test
+    fun join_postsToJoinEndpoint_withAllProvidedFields() {
+        val paramsSlot = slot<JSONObject>()
+        every {
+            sendNetworkMethodUseCase.postAsync(any(), capture(paramsSlot), any())
+        } just Runs
+
+        impl.join(
+            phone = "79991234567",
+            email = "en@rees46.ru",
+            firstName = "Ivan",
+            lastName = "Petrov",
+            onSuccess = {},
+        )
+
+        verify(exactly = 1) {
+            sendNetworkMethodUseCase.postAsync(
+                LoyaltyManagerImpl.JOIN_REQUEST,
+                any(),
+                any()
+            )
+        }
+        val body = paramsSlot.captured
+        assertEquals("79991234567", body.getString("phone"))
+        assertEquals("en@rees46.ru", body.getString("email"))
+        assertEquals("Ivan", body.getString("first_name"))
+        assertEquals("Petrov", body.getString("last_name"))
+    }
+
+    @Test
+    fun join_omitsOptionalFields_whenNull() {
+        val paramsSlot = slot<JSONObject>()
+        every {
+            sendNetworkMethodUseCase.postAsync(any(), capture(paramsSlot), any())
+        } just Runs
+
+        impl.join(phone = "79991234567", onSuccess = {})
+
+        val body = paramsSlot.captured
+        assertEquals("79991234567", body.getString("phone"))
+        assertFalse(body.has("email"))
+        assertFalse(body.has("first_name"))
+        assertFalse(body.has("last_name"))
+        // shop_id is appended later by the network layer, not here.
+        assertFalse(body.has("shop_id"))
+    }
+
+    @Test
+    fun join_parsesEnvelopeResponse_andInvokesOnSuccess() {
+        val listenerSlot = slot<OnApiCallbackListener>()
+        every {
+            sendNetworkMethodUseCase.postAsync(any(), any(), capture(listenerSlot))
+        } just Runs
+
+        var result: LoyaltyJoinResponse? = null
+        impl.join(phone = "79991234567", onSuccess = { result = it })
+
+        listenerSlot.captured.onSuccess(JSONObject("""{"status":"success","payload":{"member_id":42}}"""))
+
+        assertEquals("success", result?.status)
+        assertEquals(42, result?.payload?.get("member_id")?.asInt)
+    }
+
+    @Test
+    fun getStatus_getsFromStatusEndpoint_withIdentifier() {
+        val paramsSlot = slot<JSONObject>()
+        every {
+            sendNetworkMethodUseCase.getAsync(any(), capture(paramsSlot), any())
+        } just Runs
+
+        impl.getStatus(identifier = "79991234567", onSuccess = {})
+
+        verify(exactly = 1) {
+            sendNetworkMethodUseCase.getAsync(
+                LoyaltyManagerImpl.STATUS_REQUEST,
+                any(),
+                any()
+            )
+        }
+        assertEquals("79991234567", paramsSlot.captured.getString("identifier"))
+    }
+
+    @Test
+    fun getStatus_parsesPayloadWithLevel_andInvokesOnSuccess() {
+        val listenerSlot = slot<OnApiCallbackListener>()
+        every {
+            sendNetworkMethodUseCase.getAsync(any(), any(), capture(listenerSlot))
+        } just Runs
+
+        var result: LoyaltyStatusResponse? = null
+        impl.getStatus(identifier = "79991234567", onSuccess = { result = it })
+
+        listenerSlot.captured.onSuccess(
+            JSONObject(
+                """{"status":"success","payload":{"member":true,"level":{"name":"Gold","code":"gold","expiration_date":null}}}"""
+            )
+        )
+
+        assertEquals("success", result?.status)
+        assertEquals(true, result?.payload?.member)
+        assertEquals("Gold", result?.payload?.level?.name)
+        assertEquals("gold", result?.payload?.level?.code)
+        assertNull(result?.payload?.level?.expirationDate)
+    }
+
+    @Test
+    fun getStatus_forwardsError() {
+        val listenerSlot = slot<OnApiCallbackListener>()
+        every {
+            sendNetworkMethodUseCase.getAsync(any(), any(), capture(listenerSlot))
+        } just Runs
+
+        var code = 0
+        var msg: String? = null
+        impl.getStatus(
+            identifier = "79991234567",
+            onSuccess = {},
+            onError = { c, m -> code = c; msg = m }
+        )
+
+        listenerSlot.captured.onError(404, "not found")
+
+        assertEquals(404, code)
+        assertTrue(msg!!.contains("not found"))
+    }
+}