* Add subcription count event handling

* Update packages

Author: proggen

README.md

@@ -47,6 +47,7 @@ a minimal application to connect to a channel and send events.
       - [`onSubscriptionSucceeded`](#onsubscriptionsucceeded)
       - [`onSubscriptionError`](#onsubscriptionerror)
       - [`onDecryptionFailure`](#ondecryptionfailure)
+      - [`onSubscriptionCount`](#onsubscriptioncount)
       - [`onMemberAdded`](#onmemberadded)
       - [`onMemberRemoved`](#onmemberremoved)
       - [`onAuthorizer`](#onauthorizer)
@@ -230,6 +231,17 @@ function onDecryptionFailure(event:string, string reason:string) {
 ```
 Used with private channels only. Use this if you want to be notified if any messages fail to decrypt.
 
+#### `onSubscriptionCount`
+
+```typescript
+function onSubscriptionCount(subscriptionCount:number) {
+  console.log(`onSubscriptionSucceeded: ${subscriptionCount}`);
+}
+```
+
+is an event that can be manually enabled on the server to count the number of connections that are currently subscribed to a particular channel. They work with all channel types, except presence channels.
+See [Counting live users at scale with subscription_count events](https://blog.pusher.com/counting-live-users-at-scale-with-subscription-count-events/) for more information.
+
 #### `onMemberAdded`
 
 ```typescript

android/gradle.properties

@@ -1,3 +1,18 @@
-PusherWebsocketReactNative_kotlinVersion=1.3.50
-PusherWebsocketReactNative_compileSdkVersion=29
-PusherWebsocketReactNative_targetSdkVersion=29
+## For more details on how to configure your build environment visit
+# http://www.gradle.org/docs/current/userguide/build_environment.html
+#
+# Specifies the JVM arguments used for the daemon process.
+# The setting is particularly useful for tweaking memory settings.
+# Default value: -Xmx1024m -XX:MaxPermSize=256m
+# org.gradle.jvmargs=-Xmx2048m -XX:MaxPermSize=512m -XX:+HeapDumpOnOutOfMemoryError -Dfile.encoding=UTF-8
+#
+# When configured, Gradle will run in incubating parallel mode.
+# This option should only be used with decoupled projects. More details, visit
+# http://www.gradle.org/docs/current/userguide/multi_project_builds.html#sec:decoupled_projects
+# org.gradle.parallel=true
+#Fri Aug 19 11:19:42 CEST 2022
+PusherWebsocketReactNative_kotlinVersion=1.7.10
+PusherWebsocketReactNative_targetSdkVersion=32
+PusherWebsocketReactNative_compileSdkVersion=32
+android.useAndroidX=true
+android.enableJetifier=true

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

@@ -65,9 +65,9 @@ class PusherWebsocketReactNativeModule(reactContext: ReactApplicationContext) :
         if (arguments.hasKey("useTLS")) options.isUseTLS =
           arguments.getBoolean("useTLS")
         if (arguments.hasKey("activityTimeout")) options.activityTimeout =
-          arguments.getInt("activityTimeout") as Long
+          arguments.getInt("activityTimeout").toLong()
         if (arguments.hasKey("pongTimeout")) options.pongTimeout =
-          arguments.getInt("pongTimeout") as Long
+          arguments.getInt("pongTimeout").toLong()
         if (arguments.hasKey("maxReconnectionAttempts")) options.maxReconnectionAttempts =
           arguments.getInt("maxReconnectionAttempts")
         if (arguments.hasKey("maxReconnectGapInSeconds")) options.maxReconnectGapInSeconds =

example/android/app/build.gradle

@@ -205,7 +205,7 @@ dependencies {
         implementation jscFlavor
     }
 
-    implementation project(':pusherwebsocketreactnative')
+    implementation project(':pusher-websocket-react-native')
 }
 
 // Run this once to be able to run the application with BUCK

example/android/build.gradle

@@ -3,15 +3,15 @@
 buildscript {
     ext {
         minSdkVersion = 21
-        compileSdkVersion = 31
-        targetSdkVersion = 31
+        compileSdkVersion = 32
+        targetSdkVersion = 32
     }
     repositories {
         google()
         mavenCentral()
     }
     dependencies {
-        classpath('com.android.tools.build:gradle:7.2.0')
+        classpath('com.android.tools.build:gradle:7.2.1')
 
         // NOTE: Do not place your application dependencies here; they belong
         // in the individual module build.gradle files

example/android/gradle.properties

@@ -19,4 +19,4 @@
 
 android.useAndroidX=true
 android.enableJetifier=true
-FLIPPER_VERSION=0.142.0
+FLIPPER_VERSION=0.159.0

example/package.json

@@ -9,15 +9,15 @@
     "start": "npx react-native start"
   },
   "dependencies": {
-    "@react-native-async-storage/async-storage": "^1.17.5",
+    "@react-native-async-storage/async-storage": "^1.17.9",
     "crypto-es": "^1.2.7",
     "react": "17.0.2",
-    "react-native": "0.68.2"
+    "react-native": "0.68.3"
   },
   "devDependencies": {
-    "@babel/core": "^7.18.0",
-    "@babel/runtime": "^7.18.0",
+    "@babel/core": "^7.18.10",
+    "@babel/runtime": "^7.18.9",
     "babel-plugin-module-resolver": "^4.1.0",
-    "metro-react-native-babel-preset": "^0.71.0"
+    "metro-react-native-babel-preset": "^0.72.1"
   }
 }

example/src/App.tsx

@@ -75,6 +75,7 @@ export default function App() {
         onEvent,
         onSubscriptionSucceeded,
         onSubscriptionError,
+        onSubscriptionCount,
         onDecryptionFailure,
         onMemberAdded,
         onMemberRemoved,
@@ -114,6 +115,15 @@ export default function App() {
     log(`Me: ${me}`);
   };
 
+  const onSubscriptionCount = (
+    channelName: string,
+    subscriptionCount: Number
+  ) => {
+    log(
+      `onSubscriptionCount: ${subscriptionCount}, channelName: ${channelName}`
+    );
+  };
+
   const onSubscriptionError = (
     channelName: string,
     message: string,