From 588998bce7eb8a039564c27f12115aee3a5ca489 Mon Sep 17 00:00:00 2001
From: Dominic Grimm <dominic@dergrimm.net>
Date: Sun, 18 Feb 2024 20:34:36 +0100
Subject: [PATCH] Update

---
 .../providers/events/mqtt/MqttEventListenerProvider.scala      | 3 ++-
 .../events/mqtt/MqttEventListenerProviderFactory.scala         | 2 ++
 .../dergrimm/keycloak/providers/events/mqtt/MqttOptions.scala  | 1 +
 .../net/dergrimm/keycloak/providers/events/mqtt/Payload.scala  | 1 +
 .../keycloak/providers/events/mqtt/PayloadAuthDetails.scala    | 1 +
 5 files changed, 7 insertions(+), 1 deletion(-)

diff --git a/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/MqttEventListenerProvider.scala b/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/MqttEventListenerProvider.scala
index b50b89b..0104cf4 100644
--- a/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/MqttEventListenerProvider.scala
+++ b/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/MqttEventListenerProvider.scala
@@ -31,7 +31,6 @@ import akka.util.ByteString
 import akka.stream.scaladsl.Source
 import scala.util.Success
 import scala.util.Failure
-import concurrent.ExecutionContext.Implicits.global
 
 class MqttEventListenerProvider(
     val session: KeycloakSession,
@@ -65,6 +64,7 @@ class MqttEventListenerProvider(
   override def close(): Unit = {}
 
   private def sendMessage(payload: Payload): Unit =
+    import concurrent.ExecutionContext.Implicits.global
     import MqttEventListenerProviderFactory.system
 
     val topic = s"${mqttOptions.topic}/${payload.topic}"
@@ -81,3 +81,4 @@ class MqttEventListenerProvider(
           s"Failed to publish message: ${exception.getMessage()}"
         )
     }
+end MqttEventListenerProvider
diff --git a/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/MqttEventListenerProviderFactory.scala b/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/MqttEventListenerProviderFactory.scala
index 5658491..5f71d1d 100644
--- a/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/MqttEventListenerProviderFactory.scala
+++ b/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/MqttEventListenerProviderFactory.scala
@@ -37,6 +37,7 @@ object MqttEventListenerProviderFactory:
   private val PUBLISHER_ID = "keycloak"
 
   implicit val system: ActorSystem = ActorSystem()
+end MqttEventListenerProviderFactory
 
 class MqttEventListenerProviderFactory(
     var data: MqttEventListenerProviderFactoryData
@@ -118,3 +119,4 @@ class MqttEventListenerProviderFactory(
   override def close(): Unit = {}
 
   override def getId(): String = MqttEventListenerProviderFactory.PLUGIN_ID
+end MqttEventListenerProviderFactory
diff --git a/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/MqttOptions.scala b/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/MqttOptions.scala
index 5b28d8b..b94a725 100644
--- a/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/MqttOptions.scala
+++ b/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/MqttOptions.scala
@@ -38,6 +38,7 @@ object MqttOptions:
       retained,
       qos
     )
+end MqttOptions
 
 private final case class MqttOptions(
     topic: String,
diff --git a/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/Payload.scala b/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/Payload.scala
index 235c9ba..935c14b 100644
--- a/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/Payload.scala
+++ b/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/Payload.scala
@@ -60,6 +60,7 @@ object Payload:
       error,
       resourceTypeAsString = event.getResourceTypeAsString()
     )
+end Payload
 
 private final case class Payload(
     admin: Boolean,
diff --git a/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/PayloadAuthDetails.scala b/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/PayloadAuthDetails.scala
index 607a321..01a67ef 100644
--- a/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/PayloadAuthDetails.scala
+++ b/src/main/scala/net/dergrimm/keycloak/providers/events/mqtt/PayloadAuthDetails.scala
@@ -38,6 +38,7 @@ object PayloadAuthDetails:
       userId = auth.getClientId(),
       ipAddress = auth.getIpAddress()
     )
+end PayloadAuthDetails
 
 private final case class PayloadAuthDetails(
     realmId: String,