refactor: refactor code for respect style conventions

Author: andrea-acampora

src/main/kotlin/App.kt

@@ -1,11 +1,10 @@
-import entities.events.Event
 import application.presenter.EventConsumer
 import application.presenter.EventPublisher
 import application.services.EventService
+import entities.events.Event
 import infrastructure.kafka.KafkaPublisher
 import infrastructure.signalr.SignalRClient
 
-
 /*
  * Copyright (c) 2023. Smart Operating Block
  *

src/main/kotlin/application/presenter/EventPublisher.kt

@@ -21,5 +21,4 @@ interface EventPublisher<in E : Event<Any>> {
      * @param event the event to publish.
      */
     fun publishEvent(event: E)
-
 }

src/main/kotlin/application/services/EventService.kt

@@ -13,6 +13,7 @@ import application.presenter.EventPublisher
 import entities.events.Event
 import io.reactivex.rxjava3.core.BackpressureStrategy
 import io.reactivex.rxjava3.core.Flowable
+import io.reactivex.rxjava3.disposables.Disposable
 
 /**
  * The Application service responsible to start the consumer and to propagate the events to the publisher.
@@ -25,12 +26,10 @@ class EventService<in C>(
     /**
      * Start the event service.
      */
-    fun start(){
+    fun start(): Disposable =
         Flowable.create({ emitter ->
             eventConsumer.start(emitter)
         }, BackpressureStrategy.BUFFER).subscribe { event ->
             eventPublisher.publishEvent(event)
         }
-    }
-
 }

src/main/kotlin/entities/environment/EnvironmentData.kt

@@ -36,5 +36,4 @@ object EnvironmentData {
      * @param presenceDetected true if is a person detection event, false otherwise.
      */
     data class Presence(val presenceDetected: Boolean)
-
 }

src/main/kotlin/entities/events/ProcessEvent.kt

@@ -22,4 +22,4 @@ data class ProcessEvent<E : Any>(
 
     override val data: E,
 
-): Event<E>
+) : Event<E>

src/main/kotlin/entities/process/ProcessData.kt

@@ -24,5 +24,4 @@ object ProcessData {
      * @param state the current state of the process.
      */
     data class ProcessState(val state: String)
-
 }

src/main/kotlin/infrastructure/digitaltwins/DTEvents.kt

@@ -44,12 +44,12 @@ object DTEvents {
          * The patch section.
          */
         val patch: List<Patch>,
-   )
+    )
 
     /**
      * The event of update of a DT.
      */
-   data class UpdateTwinEvent(
+    data class UpdateTwinEvent(
         /**
          * The data section of the event.
          */
@@ -74,5 +74,5 @@ object DTEvents {
          * The date and time of the event.
          */
         val eventDateTime: String,
-   )
+    )
 }