Improve code formatting across modules

Author: jreynard-code

dataset/src/main/kotlin/com/cosmotech/dataset/DatasetApiServiceInterface.kt

@@ -23,6 +23,7 @@ interface DatasetApiServiceInterface : DatasetApiService {
   /**
    * Find Dataset by Organization Id and Dataset Id (checking ONLY READ_PERMISSION on targeted
    * organization)
+   *
    * @param organizationId an organization Id
    * @param datasetId a dataset Id
    * @return a Dataset or null
@@ -31,6 +32,7 @@ interface DatasetApiServiceInterface : DatasetApiService {
 
   /**
    * Add a new entry (ou update existing one) on dataset passed in parameter
+   *
    * @param organizationId an organization id
    * @param dataset a dataset to update
    * @param identity a user/application identity

dataset/src/main/kotlin/com/cosmotech/dataset/bulk/BulkQuery.kt

@@ -21,21 +21,25 @@ private constructor(
       private var typedBinaryEdges: Map<String, BinaryEntities> = mapOf()
   ) {
     fun graphName(name: String) = apply { this.graphName = name }
+
     fun first() = apply { this.begin = true }
 
     fun addNodeTypeGroup(type: String, binaryEntities: BinaryEntities) = apply {
       if (type !in typedBinaryNodes) this.typedBinaryNodes += type to binaryEntities
     }
+
     fun addNodeToNodeTypeGroup(type: String, node: Node) = apply {
       if (type in this.typedBinaryNodes) this.typedBinaryNodes[type]?.addEntity(node)
     }
 
     fun addEdgeTypeGroup(type: String, typeEdge: BinaryEntities) = apply {
       if (type !in typedBinaryEdges) this.typedBinaryEdges += type to typeEdge
     }
+
     fun addEdgeToEdgeTypeGroup(type: String, edge: Edge) = apply {
       if (type in this.typedBinaryEdges) this.typedBinaryEdges[type]?.addEntity(edge)
     }
+
     // For ease, those sizes are not calculated as there are very small
     //   GRAPH.BULK     string to byteArray size
     //   graphName      string to byteArray size
@@ -73,6 +77,7 @@ private constructor(
 
   private fun ByteArray.toHex(): String =
       joinToString(separator = "") { eachByte -> "%02x".format(eachByte) }
+
   override fun toString(): String {
     return generateQueryArgs().joinToString(separator = " - ") { bytes -> bytes.toHex() }
   }

dataset/src/main/kotlin/com/cosmotech/dataset/bulk/QueryBuffer.kt

@@ -27,6 +27,7 @@ class QueryBuffer(val unifiedJedis: UnifiedJedis, val graphName: String) {
 
   private val nodeSet: HashSet<String> = hashSetOf()
   private val edgeSet: HashSet<String> = hashSetOf()
+
   fun addNode(type: String, id: String, properties: Map<String, Any?>) {
     addEntity(type, properties) {
       if (id in nodeSet) return@addEntity null

dataset/src/main/kotlin/com/cosmotech/dataset/utils/Twingraph.ext.kt

@@ -28,6 +28,7 @@ enum class CsmGraphEntityType {
   RELATION,
   NODE
 }
+
 // To support simple quoted jsonstring from ADT
 val jsonObjectMapper: ObjectMapper =
     objectMapper().configure(JsonParser.Feature.ALLOW_SINGLE_QUOTES, true)
@@ -41,7 +42,8 @@ fun GraphEntity.toCsmGraphEntity(type: CsmGraphEntityType): CsmGraphEntity {
   val label =
       when (type) {
         CsmGraphEntityType.RELATION -> (this as Edge).relationshipType
-        CsmGraphEntityType.NODE -> (this as Node).takeIf { it.numberOfLabels > 0 }?.getLabel(0)
+        CsmGraphEntityType.NODE ->
+            (this as Node).takeIf { it.numberOfLabels > 0 }?.getLabel(0)
                 ?: throw IndexOutOfBoundsException("Node has no label: $entityId")
       }
 

metrics/src/main/kotlin/com/cosmotech/metrics/MetricsService.kt

@@ -7,6 +7,7 @@ import com.cosmotech.api.metrics.PersistentMetric
 interface MetricsService {
   /**
    * Store a metric in the persistent database.
+   *
    * @param metric The metric to store.
    */
   fun storeMetric(metric: PersistentMetric)

run/src/main/kotlin/com/cosmotech/run/RunContainerFactory.kt

@@ -338,6 +338,7 @@ class RunContainerFactory(
 
 /**
  * Get scopes used by containers
+ *
  * @return all scopes defined join by ","
  */
 internal fun getContainerScopes(csmPlatformProperties: CsmPlatformProperties): String {

run/src/main/kotlin/com/cosmotech/run/RunEventServiceInterface.kt

@@ -8,5 +8,6 @@ import org.springframework.context.event.EventListener
 
 interface RunEventServiceInterface {
   @EventListener(AskRunStatusEvent::class) fun getRunStatus(askRunStatusEvent: AskRunStatusEvent)
+
   @EventListener(HasRunningRuns::class) fun hasRunningRuns(hasRunningRuns: HasRunningRuns)
 }

run/src/main/kotlin/com/cosmotech/run/service/amqp/AmqpClientServiceInterface.kt

@@ -5,5 +5,6 @@ package com.cosmotech.run.service.amqp
 interface AmqpClientServiceInterface {
 
   fun addNewQueue(exchangeName: String, queueName: String)
+
   fun removeQueue(exchangeName: String, queueName: String)
 }

runner/src/main/kotlin/com/cosmotech/runner/service/RunnerService.kt

@@ -187,7 +187,7 @@ class RunnerService(
   fun listInstances(pageRequest: PageRequest): List<Runner> {
     val isPlatformAdmin =
         getCurrentAuthenticatedRoles(this.csmPlatformProperties).contains(ROLE_PLATFORM_ADMIN)
-    var runners = listOf<Runner>()
+    var runners: List<Runner>
     if (!this.csmPlatformProperties.rbac.enabled || isPlatformAdmin) {
       runners =
           runnerRepository
@@ -324,8 +324,7 @@ class RunnerService(
               runnerRepository
                   .findBy(organization!!.id!!, workspace!!.id!!, it)
                   .orElseThrow { IllegalArgumentException("Parent runner not found: ${it}") }
-                  .rootId
-                  ?: this.runner.parentId
+                  .rootId ?: this.runner.parentId
         }
       }
     }
@@ -434,8 +433,7 @@ class RunnerService(
           runner.security
               ?.accessControlList
               ?.map { RbacAccessControl(it.id, it.role) }
-              ?.toMutableList()
-              ?: mutableListOf())
+              ?.toMutableList() ?: mutableListOf())
     }
 
     @Suppress("NestedBlockDepth")