smallcase · dporwal-shipit · May 30, 2025 · Jul 20, 2025 · Jul 20, 2025 · Jul 20, 2025
diff --git a/android/build.gradle b/android/build.gradle
@@ -149,8 +149,8 @@ def kotlin_version = getExtOrDefault('kotlinVersion')
 dependencies {
    //noinspection GradleDynamicVersion
     implementation 'com.facebook.react:react-native:+'  // From node_modules
-    implementation 'com.smallcase.gateway:sdk:4.3.0'
-    implementation 'com.smallcase.loans:sdk:3.1.1'
+    implementation "com.smallcase.gateway:sdk-release-scg-v5-0-0-loans-v4-0-0-1df0c05:4.3.0-3183-release"
+    implementation "com.smallcase.loans:sdk-release-scg-v5-0-0-loans-v4-0-0-1df0c05:3.1.1-81-release"
     implementation "androidx.core:core-ktx:1.3.1"
     implementation "org.jetbrains.kotlin:kotlin-stdlib-jdk7:$kotlin_version"
 }

diff --git a/android/src/main/java/com/reactnativesmallcasegateway/SCGatewayBridgeEmitter.kt b/android/src/main/java/com/reactnativesmallcasegateway/SCGatewayBridgeEmitter.kt
@@ -0,0 +1,112 @@
+
+// SCGatewayBridgeEmitter.kt
+package com.reactnativesmallcasegateway
+
+import android.util.Log
+import com.facebook.react.bridge.*
+import com.facebook.react.bridge.UiThreadUtil
+import com.facebook.react.modules.core.DeviceEventManagerModule
+import com.smallcase.gateway.data.listeners.Notification
+import com.smallcase.gateway.data.listeners.NotificationCenter
+import com.smallcase.gateway.portal.ScgNotification
+import com.smallcase.gateway.portal.SmallcaseGatewaySdk
+
+class SCGatewayBridgeEmitter(private val reactContext: ReactApplicationContext) :
+    ReactContextBaseJavaModule(reactContext) {
+
+    companion object {
+        const val TAG = "SCGatewayBridgeEmitter"
+    }
+
+    private var notificationObserver: ((Notification) -> Unit)? = null
+
+    private val isListening: Boolean
+        get() = notificationObserver != null
+
+    init {
+        UiThreadUtil.runOnUiThread { startListening() }
+    }
+
+    override fun getName(): String = "SCGatewayBridgeEmitter"
+
+    override fun onCatalystInstanceDestroy() {
+        super.onCatalystInstanceDestroy()
+        if (isListening) {
+            notificationObserver?.let { observer ->
+                NotificationCenter.removeObserver(observer)
+            }
+            notificationObserver = null
+            Log.d(TAG, "Successfully cleaned up notification observer")
+        }
+    }
+
+    @ReactMethod
+    fun startListening(promise: Promise? = null) {
+        Log.d(TAG, "startListening called")
+
+        if (isListening) {
+            Log.d(TAG, "Already listening to events")
+            promise?.resolve("Already listening")
+            return
+        }
+
+        UiThreadUtil.runOnUiThread {
+            Log.d(TAG, "Starting listener on thread: ${Thread.currentThread().name}")
+
+            notificationObserver = { notification ->
+                Log.d(TAG, "Received notification: ${notification.name}")
+                processScgNotification(notification)
+            }
+
+            notificationObserver?.let { observer ->
+                NotificationCenter.addObserver(observer)
+                Log.d(TAG, "Successfully started listening for notifications")
+                promise?.resolve("Started listening successfully")
+            } ?: run {
+                promise?.reject("START_LISTENING_ERROR", "Failed to create observer")
+            }
+        }
+    }
+
+    @ReactMethod
+    fun stopListening(promise: Promise) {
+        if (!isListening) {
+            promise.resolve("Not listening")
+            return
+        }
+
+        UiThreadUtil.runOnUiThread {
+            notificationObserver?.let { observer ->
+                NotificationCenter.removeObserver(observer)
+                notificationObserver = null
+                promise.resolve("Stopped listening successfully")
+            } ?: run {
+                promise.resolve("No observer to remove")
+            }
+        }
+    }
+
+    private fun processScgNotification(notification: Notification) {
+        val jsonString = notification.userInfo?.get(ScgNotification.STRINGIFIED_PAYLOAD_KEY) as? String
+        if (jsonString == null) {
+            Log.e(TAG, "SCGatewayBridgeEmitter: Invalid notification object - expected JSON string")
+            return
+        }
+
+        sendEvent(SmallcaseGatewaySdk.SCG_NOTIFICATION_NAME, jsonString)
+    }
+
+    private fun sendEvent(eventName: String, jsonString: String) {
+        try {
+            if (reactContext.hasActiveCatalystInstance()) {
+                reactContext
+                    .getJSModule(DeviceEventManagerModule.RCTDeviceEventEmitter::class.java)
+                    .emit(eventName, jsonString)
+            } else {
+                Log.w(TAG, "React context not active, cannot send event: $eventName")
+            }
+        } catch (e: Exception) {
+            Log.e(TAG, "Failed to send event: $eventName", e)
+        }
+    }
+}
diff --git a/android/src/main/java/com/reactnativesmallcasegateway/SCLoansBridgeEmitter.kt b/android/src/main/java/com/reactnativesmallcasegateway/SCLoansBridgeEmitter.kt
@@ -0,0 +1,117 @@
+// SCLoansBridgeEmitter.kt
+package com.reactnativesmallcasegateway
+
+import android.util.Log
+import com.facebook.react.bridge.*
+import com.facebook.react.bridge.UiThreadUtil
+import com.facebook.react.modules.core.DeviceEventManagerModule
+import com.smallcase.loans.core.external.ScLoan
+import com.smallcase.loans.core.external.ScLoanNotification
+import com.smallcase.loans.data.listeners.Notification
+import com.smallcase.loans.data.listeners.NotificationCenter
+
+class SCLoansBridgeEmitter(private val reactContext: ReactApplicationContext):
+    ReactContextBaseJavaModule(reactContext) {
+
+        companion object {
+            const val TAG = "SCLoansBridgeEmitter"
+        }
+
+        private var notificationObserver: ((Notification) -> Unit)? = null
+
+        private val isListening: Boolean
+        get() = notificationObserver != null
+
+        init {
+            UiThreadUtil.runOnUiThread {
+                startListening()
+            }
+        }
+
+        override fun getName(): String = "SCLoansBridgeEmitter"
+
+        override fun onCatalystInstanceDestroy() {
+            super.onCatalystInstanceDestroy()
+            if (isListening) {
+                notificationObserver?.let { observer ->
+                    NotificationCenter.removeObserver(observer)
+                }
+                notificationObserver = null
+                Log.d(TAG, "Successfully cleaned up notification observer")
+            }
+        }
+
+        @ReactMethod
+        fun startListening(promise: Promise ? = null) {
+            Log.d(TAG, "startListening called")
+
+            if (isListening) {
+                Log.d(TAG, "Already listening to events")
+                promise?.resolve("Already listening")
+                return
+            }
+
+            UiThreadUtil.runOnUiThread {
+                Log.d(TAG, "Starting listener on thread: ${Thread.currentThread().name}")
+
+                notificationObserver = { notification ->
+                    Log.d(TAG, "Received notification: ${notification.name}")
+                    processScLoansNotification(notification)
+                }
+
+                notificationObserver?.let { observer ->
+                    NotificationCenter.addObserver(observer)
+                    Log.d(TAG, "Successfully started listening for notifications")
+                    promise?.resolve("Started listening successfully")
+                } ?: run {
+                    promise?.reject("START_LISTENING_ERROR", "Failed to create observer")
+                }
+            }
+        }
+
+        @ReactMethod
+        fun stopListening(promise: Promise) {
+            if (!isListening) {
+                promise.resolve("Not listening")
+                return
+            }
+
+            UiThreadUtil.runOnUiThread {
+                notificationObserver?.let { observer ->
+                    NotificationCenter.removeObserver(observer)
+                    notificationObserver = null
+                    promise.resolve("Stopped listening successfully")
+                } ?: run {
+                    promise.resolve("No observer to remove")
+                }
+            }
+        }
+
+        private fun processScLoansNotification(notification: Notification) {
+            val jsonString =
+                notification.userInfo?.get(ScLoanNotification.STRINGIFIED_PAYLOAD_KEY) as? String
+            if (jsonString == null) {
+                Log.e(
+                    TAG,
+                    "SCLoansBridgeEmitter: Invalid notification object - expected JSON string"
+                )
+                return
+            }
+
+            sendEvent(ScLoan.SCLOANS_NOTIFICATION_NAME, jsonString)
+        }
+
+        private fun sendEvent(eventName: String, jsonString: String) {
+            try {
+                if (reactContext.hasActiveCatalystInstance()) {
+                    reactContext
+                        .getJSModule(DeviceEventManagerModule.RCTDeviceEventEmitter::class.java)
+                        .emit(eventName, jsonString)
+                } else {
+                    Log.w(TAG, "React context not active, cannot send event: $eventName")
+                }
+            } catch (e: Exception) {
+                Log.e(TAG, "Failed to send event: $eventName", e)
+            }
+        }
+    }
diff --git a/android/src/main/java/com/reactnativesmallcasegateway/SmallcaseGatewayModule.kt b/android/src/main/java/com/reactnativesmallcasegateway/SmallcaseGatewayModule.kt
@@ -67,7 +67,6 @@ class SmallcaseGatewayModule(reactContext: ReactApplicationContext) : ReactConte
 
     @ReactMethod
     fun init(sdkToken: String, promise: Promise) {
-        Log.d(TAG, "init: start")
 
         val initReq = InitRequest(sdkToken)
         SmallcaseGatewaySdk.init(authRequest = initReq, gatewayInitialisationListener = object : DataListener<InitialisationResponse> {
@@ -85,7 +84,6 @@ class SmallcaseGatewayModule(reactContext: ReactApplicationContext) : ReactConte
 
     @ReactMethod
     fun triggerTransaction(transactionId: String, utmParams: ReadableMap?, brokerList: ReadableArray?, promise: Promise) {
-        Log.d(TAG, "triggerTransaction: start")
 
         var safeBrokerList = listOf<String>()
 
@@ -161,7 +159,6 @@ class SmallcaseGatewayModule(reactContext: ReactApplicationContext) : ReactConte
 
     @ReactMethod
     fun launchSmallplug(targetEndpoint: String, params: String, promise: Promise) {
-        Log.d(TAG, "launchSmallplug: start")
 
         SmallcaseGatewaySdk.launchSmallPlug(currentActivity!!, SmallplugData(targetEndpoint, params), object : SmallPlugResponseListener {
             override fun onFailure(errorCode: Int, errorMessage: String) {
@@ -191,7 +188,6 @@ class SmallcaseGatewayModule(reactContext: ReactApplicationContext) : ReactConte
                 }
             }
         }
-        Log.d(TAG, "launchSmallplugWithBranding: start")
 
         var partnerProps: SmallplugPartnerProps? = SmallplugPartnerProps(headerColor = "#2F363F", backIconColor = "ffffff")
 
@@ -224,7 +220,6 @@ class SmallcaseGatewayModule(reactContext: ReactApplicationContext) : ReactConte
 
     @ReactMethod
     fun archiveSmallcase(iscid: String, promise: Promise) {
-        Log.d(TAG, "markSmallcaseArchive: start")
 
         SmallcaseGatewaySdk.markSmallcaseArchived(iscid, object : DataListener<SmallcaseGatewayDataResponse> {
 

diff --git a/android/src/main/java/com/reactnativesmallcasegateway/SmallcaseGatewayPackage.kt b/android/src/main/java/com/reactnativesmallcasegateway/SmallcaseGatewayPackage.kt
@@ -7,7 +7,11 @@ import com.facebook.react.uimanager.ViewManager
 
 class SmallcaseGatewayPackage : ReactPackage {
     override fun createNativeModules(reactContext: ReactApplicationContext): List<NativeModule> {
-        return listOf(SmallcaseGatewayModule(reactContext))
+        return listOf(
+            SmallcaseGatewayModule(reactContext),
+            SCGatewayBridgeEmitter(reactContext),
+            SCLoansBridgeEmitter(reactContext)
+        )
     }
 
     override fun createViewManagers(reactContext: ReactApplicationContext): List<ViewManager<*, *>> {

diff --git a/ios/SCGatewayBridgeEmitter.m b/ios/SCGatewayBridgeEmitter.m
@@ -0,0 +1,20 @@
+//
+//  SCGatewayBridgeEmitter.m
+//  SCGateway
+//
+//  Created by Dhruv Porwal
+//  Copyright © 2025 smallcase. All rights reserved.
+//
+
+#import <React/RCTBridgeModule.h>
+#import "SmallcaseGateway-Bridging-Header.h"
+
+@interface RCT_EXTERN_REMAP_MODULE(SCGatewayBridgeEmitter, SCGatewayEmitter, NSObject)
+
+RCT_EXTERN_METHOD(startListening:(RCTPromiseResolveBlock)resolve
+                  rejecter:(RCTPromiseRejectBlock)reject)
+
+RCT_EXTERN_METHOD(stopListening:(RCTPromiseResolveBlock)resolve
+                  rejecter:(RCTPromiseRejectBlock)reject)
+
+@end