// build.gradle.kts (project)
repositories {
   mavenCentral()
}

// build.gradle.kts (shared module)
kotlin {
   sourceSets {
      commonMain.dependencies {
         implementation("uk.co.lidbit:pusher-websocket-kmp:<latest-version>")
      }
   }
}

val options = PusherOptions.Builder()
    .setCluster("YOUR_CLUSTER") // or use .setHost(...)
    .setAutoReconnect(true)
    .setUseTls(true)
    .build()

val pusher = PusherClient(
    apiKey = "YOUR_PUSHER_KEY",
    options = options
)

pusher.connect(
    onConnectionStateChange = { current, previous ->
        println("Connection changed from $previous to $current")
    },
    onError = { message, code, exception ->
        println("Connection error: $message ($code), exception: $exception")
    }
)

pusher.subscribe(
    channel = "my-channel",
    onSuccess = {
        println("Successfully subscribed to my-channel")
    },
    onEvent = { event ->
        println("Received event: ${event.name} with data: ${event.data}")
    },
    "my-event"
)

// or create your own using the ChannelAuthorizer interface
val channelAuthorizer = HttpChannelAuthorizer(
    endpoint = "https://example.domain/broadcasting/auth",
    headers = {
        mapOf(
            "Authorization" to "Bearer {token}",
        )
    },
)

val options = PusherOptions.Builder()
    .setCluster("YOUR_CLUSTER") // or use .setHost(...)
    .setChannelAuthorizer(channelAuthorizer)
    .build()

val pusher = PusherClient("YOUR_PUSHER_KEY", options)

pusher.connect()

pusher.subscribePrivate(
    channel = "private-my-channel",
    onSuccess = {
        println("Subscribed to private channel")
    },
    onAuthenticationFailure = { message, error ->
        println("Auth failed: $message, exception: $error")
    },
    onEvent = { event ->
        println("Event received: ${event.name}")
    },
    "some-private-event"
)

// or create your own using the UserAuthenticator interface
val userAuthenticator = HttpUserAuthenticator(
    endpoint = "https://example.domain/broadcasting/auth",
    headers = {
        mapOf(
            "Authorization" to "Bearer {token}",
        )
    },
)
val options = PusherOptions.Builder()
    .setCluster("YOUR_CLUSTER")
    .setUserAuthenticator(userAuthenticator)
    .build()

val pusher = PusherClient("YOUR_PUSHER_KEY", options)

pusher.connect()

pusher.subscribePresence(
    channel = "presence-my-channel",
    onSuccess = {
        println("Subscribed to presence channel")
    },
    onUsersInformationReceived = { users ->
        // only available for jvm client
        println("Initial users: $users")
    },
    onUserCountChanged = { count ->
        println("User count changed: $count")
    },
    userSubscribed = { user ->
        println("User subscribed: $user")
    },
    userUnsubscribed = { user ->
        println("User unsubscribed: $user")
    },
    onAuthenticationFailure = { message, error ->
        println("Presence auth failed: $message, exception: $error")
    },
    onEvent = { event ->
        println("Presence event: ${event.name}")
    },
    "presence-event"
)

pusher.disconnect()