build.sbt

@@ -34,7 +34,7 @@ lazy val root = project
   .in(file("."))
   .settings(
     name := "keycloak-event-listener-mqtt",
-    version := "0.2.0",
+    version := "0.1.0",
     scalaVersion := scala3Version,
     resolvers += "Akka library repository".at("https://repo.akka.io/maven"),
     libraryDependencies ++= keycloakDeps,

src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/MqttEventListenerProvider.scala

@@ -70,10 +70,11 @@ class MqttEventListenerProvider(
     import concurrent.ExecutionContext.Implicits.global
     import MqttEventListenerProviderFactory.system
 
+    val topic: String = s"${mqttOptions.topic}/${payload.topic}"
     val payloadBytes: Array[Byte] = Json.encode(payload).toByteArray
 
     val msg: MqttMessage =
-      MqttMessage(mqttOptions.topic, ByteString.fromArray(payloadBytes))
+      MqttMessage(topic, ByteString.fromArray(payloadBytes))
         .withRetained(mqttOptions.retained)
     val future: Future[Done] = Source.single(msg).runWith(mqttSink)
 

src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/MqttOptions.scala

@@ -40,7 +40,7 @@ object MqttOptions:
   end fromConfig
 end MqttOptions
 
-final case class MqttOptions(
+private final case class MqttOptions(
     topic: String,
     retained: Boolean,
     qos: MqttQoS

src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/Payload.scala

@@ -65,7 +65,7 @@ object Payload extends FromEvent[Payload]:
   end fromEvent
 end Payload
 
-final case class Payload(
+private final case class Payload(
     admin: Boolean,
     time: Long,
     realm: String,
@@ -76,4 +76,17 @@ final case class Payload(
     resourcePath: Option[String],
     representation: Option[String],
     error: Option[String]
-) derives Codec
+) derives Codec:
+  private def result: String = if error.isDefined then "error" else "success"
+
+  def topic: String =
+    if admin
+    then
+      resourceType match
+        case Some(rType) =>
+          s"admin/${realm}/${result}/${rType.toLowerCase()}/${operationType.toLowerCase()}"
+        case None => throw new IllegalStateException
+    else
+      s"client/${realm}/${result}/${authDetails.clientId}/${operationType.toLowerCase()}"
+  end topic
+end Payload

src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/PayloadAuthDetails.scala

@@ -48,7 +48,7 @@ object PayloadAuthDetails extends FromEvent[PayloadAuthDetails]:
   end fromEvent
 end PayloadAuthDetails
 
-final case class PayloadAuthDetails(
+private final case class PayloadAuthDetails(
     realmId: String,
     clientId: String,
     userId: String,