User Presence

let repository = AmityUserPresenceRepository()

let presences = try await repository.getUserPresence(userIds: [userId])
for presence in presences {
    let isOnline = presence.isOnline
    let lastHeartbeat = presence.lastHeartbeat
    showSuccessMessage("\(presence.userId): \(isOnline)")
}

val repository = AmityCoreClient.newUserPresenceRepository()

repository.getUserPresence(listOf(userId))
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({ presences ->
        presences.forEach { presence ->
            val isOnline = presence.isOnline()
            val lastHeartbeat = presence.getLastHeartbeat()
            showSuccessMessage("${presence.getUserId()}: $isOnline")
        }
    }, { error ->
        showErrorMessage(error = error)
    })

let repository = AmityUserPresenceRepository()

let cancellable = repository.getSyncingUserPresence()
    .sink(receiveCompletion: { completion in
        if case let .failure(error) = completion {
            handleError(error)
        }
    }, receiveValue: { presences in
        for presence in presences {
            showSuccessMessage("\(presence.userId): \(presence.isOnline)")
        }
    })

repository.syncUserPresence(id: userId)

// Call when the row or screen is no longer visible.
repository.unsyncUserPresence(id: userId)

_ = cancellable

val repository = AmityCoreClient.newUserPresenceRepository()

repository.getSyncingUserPresence()
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({ presences ->
        presences.forEach { presence ->
            showSuccessMessage("${presence.getUserId()}: ${presence.isOnline()}")
        }
    }, { error ->
        showErrorMessage(error = error)
    })

repository.syncUserPresence(userId)

// Call when the row or screen is no longer visible.
repository.unsyncUserPresence(userId)

let repository = AmityUserPresenceRepository()

let count = try await repository.getOnlineUsersCount()
showSuccessMessage(count)

let snapshot = try await repository.getOnlineUsersSnapshot()
let users = snapshot.users

if snapshot.canLoadMore {
    await snapshot.loadMore()
}

val repository = AmityCoreClient.newUserPresenceRepository()

repository.getOnlineUsersCount()
    .subscribe({ count ->
        showSuccessMessage(count)
    }, { error ->
        showErrorMessage(error = error)
    })

repository.getOnlineUsersSnapshot()
    .subscribe({ snapshot ->
        val users = snapshot.getUsers()
        if (snapshot.canLoadMore()) {
            snapshot.loadMore().subscribe()
        }
    }, { error ->
        showErrorMessage(error = error)
    })