You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

ChannelStateHandler.kt 2.7KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273
  1. package com.dmdirc.ktirc.events
  2. import com.dmdirc.ktirc.IrcClient
  3. import com.dmdirc.ktirc.model.ChannelState
  4. import com.dmdirc.ktirc.model.ChannelUser
  5. import com.dmdirc.ktirc.model.ServerFeature
  6. import com.dmdirc.ktirc.util.logger
  7. class ChannelStateHandler : EventHandler {
  8. private val log by logger()
  9. override suspend fun processEvent(client: IrcClient, event: IrcEvent) {
  10. when (event) {
  11. is ChannelJoined -> handleJoin(client, event)
  12. is ChannelParted -> handlePart(client, event)
  13. is ChannelNamesReceived -> handleNamesReceived(client, event)
  14. is ChannelNamesFinished -> handleNamesFinished(client, event)
  15. is UserQuit -> handleQuit(client, event)
  16. }
  17. }
  18. private fun handleJoin(client: IrcClient, event: ChannelJoined) {
  19. if (client.isLocalUser(event.user)) {
  20. log.info { "Joined new channel: ${event.channel}" }
  21. client.channelState += ChannelState(event.channel) { client.caseMapping }
  22. }
  23. client.channelState[event.channel]?.let { it.users += ChannelUser(event.user.nickname) }
  24. }
  25. private fun handlePart(client: IrcClient, event: ChannelParted) {
  26. if (client.isLocalUser(event.user)) {
  27. log.info { "Left channel: ${event.channel}" }
  28. client.channelState -= event.channel
  29. } else {
  30. client.channelState[event.channel]?.let {
  31. it.users -= event.user.nickname
  32. }
  33. }
  34. }
  35. private fun handleNamesReceived(client: IrcClient, event: ChannelNamesReceived) {
  36. val channel = client.channelState[event.channel] ?: return
  37. if (!channel.receivingUserList) {
  38. log.finer { "Started receiving names list for ${channel.name}" }
  39. channel.users.clear()
  40. channel.receivingUserList = true
  41. }
  42. val modePrefixes = client.serverState.features[ServerFeature.ModePrefixes]!!
  43. for (user in event.names) {
  44. user.takeWhile { modePrefixes.isPrefix(it) }.let { prefix ->
  45. channel.users += ChannelUser(user.nickname(prefix.length), modePrefixes.getModes(prefix))
  46. }
  47. }
  48. }
  49. private fun handleNamesFinished(client: IrcClient, event: ChannelNamesFinished) {
  50. client.channelState[event.channel]?.let {
  51. it.receivingUserList = false
  52. log.finest { "Finished receiving names in ${event.channel}. Users: ${it.users.toList()}" }
  53. }
  54. }
  55. private fun handleQuit(client: IrcClient, event: UserQuit) {
  56. client.channelState.forEach { it.users -= event.user.nickname }
  57. }
  58. private fun String.nickname(prefixLength: Int) = substring(prefixLength).substringBefore('!')
  59. }