Skip to content

Commit d0c2a2b

Browse files
author
proggen
committed
handle new subscription_count event
1 parent 2977b5a commit d0c2a2b

File tree

1 file changed

+16
-6
lines changed

1 file changed

+16
-6
lines changed

android/src/main/java/com/pusherwebsocketreactnative/PusherWebsocketReactNativeModule.kt

Lines changed: 16 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -160,8 +160,7 @@ class PusherWebsocketReactNativeModule(reactContext: ReactApplicationContext) :
160160
authorizerMutex[key]!!.acquire()
161161
val authParams = authorizerResult.remove(key)!!
162162
val gson = Gson()
163-
val json = gson.toJson(authParams.toHashMap())
164-
return json
163+
return gson.toJson(authParams.toHashMap())
165164
}
166165

167166
@ReactMethod
@@ -198,12 +197,23 @@ class PusherWebsocketReactNativeModule(reactContext: ReactApplicationContext) :
198197

199198
override fun onEvent(event: PusherEvent) {
200199
// Log.i(TAG, "Received event with data: $event")
200+
// The java sdk transforms some events from pusher_internal
201+
// to pusher:... events, we translate them back.
202+
val finalEvent = if (event.eventName === "pusher:subscription_count") {
203+
PusherEvent(
204+
"pusher_internal:subscription_count",
205+
event.channelName,
206+
event.userId,
207+
event.data)
208+
} else {
209+
event
210+
}
201211
emitEvent(
202212
"onEvent", mapOf(
203-
"channelName" to event.channelName,
204-
"eventName" to event.eventName,
205-
"userId" to event.userId,
206-
"data" to event.data
213+
"channelName" to finalEvent.channelName,
214+
"eventName" to finalEvent.eventName,
215+
"userId" to finalEvent.userId,
216+
"data" to finalEvent.data
207217
)
208218
)
209219
}

0 commit comments

Comments
 (0)