Add UserAccountChanged event

CHANGELOG

@@ -1,6 +1,7 @@
 vNEXT (in development)
 
  * Added MotdFinished event
+ * Added UserAccountChanged event
  * Improved some documentation
 
 v0.4.0

src/main/kotlin/com/dmdirc/ktirc/events/Events.kt

@@ -50,6 +50,13 @@ class CtcpReceived(time: LocalDateTime, val user: User, val target: String, val
 /** Raised when a user quits. */
 class UserQuit(time: LocalDateTime, val user: User, val reason: String = "") : IrcEvent(time)
 
+/**
+ * Raised when a user's account changes (i.e., they auth'd or deauth'd with services).
+ *
+ * This event is only raised if the server supports the `account-notify` capability.
+ */
+class UserAccountChanged(time: LocalDateTime, val user: User, val newAccount: String?): IrcEvent(time)
+
 /** Raised when available server capabilities are received. More batches may follow. */
 class ServerCapabilitiesReceived(time: LocalDateTime, val capabilities: Map<Capability, String>) : IrcEvent(time)
 

src/main/kotlin/com/dmdirc/ktirc/events/UserStateHandler.kt

@@ -10,6 +10,7 @@ internal class UserStateHandler : EventHandler {
             is ChannelJoined -> handleJoin(client.userState, event)
             is ChannelParted -> handlePart(client, event)
             is ChannelNamesReceived  -> handleNamesReceived(client, event)
+            is UserAccountChanged -> handleAccountChanged(client, event)
             is UserQuit -> handleQuit(client.userState, event)
         }
         return emptyList()
@@ -42,6 +43,10 @@ internal class UserStateHandler : EventHandler {
         }
     }
 
+    private fun handleAccountChanged(client: IrcClient, event: UserAccountChanged) {
+        client.userState[event.user]?.details?.account = event.newAccount
+    }
+
     private fun handleQuit(state: UserState, event: UserQuit) {
         state -= event.user
     }

src/main/kotlin/com/dmdirc/ktirc/messages/AccountProcessor.kt

@@ -0,0 +1,17 @@
+package com.dmdirc.ktirc.messages
+
+import com.dmdirc.ktirc.events.UserAccountChanged
+import com.dmdirc.ktirc.model.IrcMessage
+
+internal class AccountProcessor : MessageProcessor {
+
+    override val commands = arrayOf("ACCOUNT")
+
+    override fun process(message: IrcMessage) = message.sourceUser?.let { user ->
+        listOf(UserAccountChanged(message.time, user, message.accountName))
+    } ?: emptyList()
+
+    private val IrcMessage.accountName
+        get() = with(String(params[0])) { if (this == "*") null else this }
+
+}

src/main/kotlin/com/dmdirc/ktirc/messages/MessageProcessor.kt

@@ -18,6 +18,7 @@ internal interface MessageProcessor {
 }
 
 internal val messageProcessors = setOf(
+        AccountProcessor(),
         CapabilityProcessor(),
         ISupportProcessor(),
         JoinProcessor(),

src/test/kotlin/com/dmdirc/ktirc/events/UserStateHandlerTest.kt

@@ -158,4 +158,16 @@ internal class UserStateHandlerTest {
             assertEquals("root.localhost", details.hostname)
         }
     }
+
+    @Test
+    fun `updates user info on account change`() {
+        runBlocking {
+            userState += User("acidBurn")
+
+            handler.processEvent(ircClient, UserAccountChanged(TestConstants.time, User("acidBurn", "libby", "root.localhost"), "acidBurn"))
+
+            val details = userState["acidBurn"]?.details!!
+            assertEquals("acidBurn", details.account)
+        }
+    }
 }

src/test/kotlin/com/dmdirc/ktirc/messages/AccountProcessorTest.kt

@@ -0,0 +1,47 @@
+package com.dmdirc.ktirc.messages
+
+import com.dmdirc.ktirc.TestConstants
+import com.dmdirc.ktirc.model.IrcMessage
+import com.dmdirc.ktirc.model.User
+import com.dmdirc.ktirc.util.currentTimeProvider
+import org.junit.jupiter.api.Assertions.assertEquals
+import org.junit.jupiter.api.BeforeEach
+import org.junit.jupiter.api.Test
+
+internal class AccountProcessorTest {
+
+    @BeforeEach
+    fun setUp() {
+        currentTimeProvider = { TestConstants.time }
+    }
+
+    @Test
+    fun `AccountProcessor raises account changed event with account name`() {
+        val events = AccountProcessor().process(
+                IrcMessage(emptyMap(), "acidburn!libby@root.localhost".toByteArray(), "ACCOUNT", listOf("acidBurn".toByteArray())))
+        assertEquals(1, events.size)
+
+        assertEquals(TestConstants.time, events[0].time)
+        assertEquals(User("acidburn", "libby", "root.localhost"), events[0].user)
+        assertEquals("acidBurn", events[0].newAccount)
+    }
+
+    @Test
+    fun `AccountProcessor raises account changed event when account removed`() {
+        val events = AccountProcessor().process(
+                IrcMessage(emptyMap(), "acidburn!libby@root.localhost".toByteArray(), "ACCOUNT", listOf("*".toByteArray())))
+        assertEquals(1, events.size)
+
+        assertEquals(TestConstants.time, events[0].time)
+        assertEquals(User("acidburn", "libby", "root.localhost"), events[0].user)
+        assertEquals(null, events[0].newAccount)
+    }
+
+    @Test
+    fun `AccountProcessor does nothing if prefix missing`() {
+        val events = AccountProcessor().process(
+                IrcMessage(emptyMap(), null, "ACCOUNT", listOf("*".toByteArray())))
+        assertEquals(0, events.size)
+    }
+
+}

src/test/kotlin/com/dmdirc/ktirc/messages/PartProcessorTest.kt

@@ -41,7 +41,7 @@ internal class PartProcessorTest {
 
     @Test
     fun `PartProcessor does nothing if prefix missing`() {
-        val events = JoinProcessor().process(
+        val events = PartProcessor().process(
                 IrcMessage(emptyMap(), null, "PART", listOf("#crashandburn".toByteArray())))
         assertEquals(0, events.size)
     }