Code cleanup

dataforge-context/src/commonMain/kotlin/hep/dataforge/context/Context.kt

@@ -11,7 +11,6 @@ import kotlinx.coroutines.Dispatchers
 import mu.KLogger
 import mu.KotlinLogging
 import kotlin.coroutines.CoroutineContext
-import kotlin.reflect.KClass
 
 /**
  * The local environment for anything being done in DataForge framework. Contexts are organized into tree structure with [Global] at the top.
@@ -107,7 +106,6 @@ expect object Global : Context{
 }
 
 
-
 /**
  * The interface for something that encapsulated in context
  *

dataforge-context/src/commonMain/kotlin/hep/dataforge/context/PluginManager.kt

@@ -59,7 +59,8 @@ class PluginManager(override val context: Context) : ContextAware, Iterable<Plug
      * @return
      */
     @Suppress("UNCHECKED_CAST")
-    operator fun <T : Plugin> get(type: KClass<T>, recursive: Boolean = true): T? = get(recursive) { type.isInstance(it) } as T?
+    operator fun <T : Plugin> get(type: KClass<T>, recursive: Boolean = true): T? =
+        get(recursive) { type.isInstance(it) } as T?
 
     inline fun <reified T : Plugin> get(recursive: Boolean = true): T? = get(T::class, recursive)
 

dataforge-context/src/commonMain/kotlin/hep/dataforge/context/PluginRepository.kt

@@ -24,5 +24,6 @@ expect object PluginRepository {
 /**
  * Fetch specific plugin and instantiate it with given meta
  */
-fun PluginRepository.fetch(tag: PluginTag, meta: Meta): Plugin = PluginRepository.list().find { it.tag.matches(tag) }?.build(meta)
+fun PluginRepository.fetch(tag: PluginTag, meta: Meta): Plugin =
+    PluginRepository.list().find { it.tag.matches(tag) }?.build(meta)
         ?: error("Plugin with tag $tag not found in the repository")

dataforge-context/src/jvmMain/kotlin/hep/dataforge/context/JVMContext.kt

@@ -16,7 +16,6 @@
 package hep.dataforge.context
 
 import hep.dataforge.meta.*
-import kotlinx.coroutines.Dispatchers
 import mu.KLogger
 import mu.KotlinLogging
 import java.lang.ref.WeakReference
@@ -24,7 +23,6 @@ import java.util.*
 import java.util.concurrent.ExecutorService
 import java.util.concurrent.Executors
 import kotlin.collections.HashSet
-import kotlin.coroutines.CoroutineContext
 import kotlin.reflect.KClass
 import kotlin.reflect.full.cast
 
@@ -75,7 +73,8 @@ open class JVMContext(
     private val serviceCache: MutableMap<Class<*>, ServiceLoader<*>> = HashMap()
 
     fun <T : Any> services(type: KClass<T>): Sequence<T> {
-        return serviceCache.getOrPut(type.java) { ServiceLoader.load(type.java, classLoader) }.asSequence().map { type.cast(it) }
+        return serviceCache.getOrPut(type.java) { ServiceLoader.load(type.java, classLoader) }.asSequence()
+            .map { type.cast(it) }
     }
 
     /**

dataforge-data/src/commonMain/kotlin/hep/dataforge/data/Action.kt

@@ -50,7 +50,8 @@ class PipeAction<in T : Any, out R : Any>(val transform: (Name, Data<T>, Meta) -
         /**
          * A simple pipe that performs transformation on the data and copies input meta into the output
          */
-        inline fun <T : Any, reified R : Any> simple(noinline transform: suspend (Name, T, Meta) -> R) = PipeAction { name, data: Data<T>, meta ->
+        inline fun <T : Any, reified R : Any> simple(noinline transform: suspend (Name, T, Meta) -> R) =
+            PipeAction { name, data: Data<T>, meta ->
                 val goal = data.goal.pipe { transform(name, it, meta) }
                 return@PipeAction Data.of(goal, data.meta)
             }

dataforge-data/src/commonMain/kotlin/hep/dataforge/data/Goal.kt

@@ -20,7 +20,8 @@ interface Goal<out T> : Deferred<T>, CoroutineScope {
         /**
          * Create goal wrapping static value. This goal is always completed
          */
-        fun <T> static(context: CoroutineContext, value: T): Goal<T> = StaticGoalImpl(context, CompletableDeferred(value))
+        fun <T> static(context: CoroutineContext, value: T): Goal<T> =
+            StaticGoalImpl(context, CompletableDeferred(value))
     }
 }
 
@@ -50,14 +51,16 @@ class GoalMonitor {
 private class GoalImpl<T>(
     override val dependencies: Collection<Goal<*>>,
     val monitor: GoalMonitor,
-        deferred: Deferred<T>) : Goal<T>, Deferred<T> by deferred {
+    deferred: Deferred<T>
+) : Goal<T>, Deferred<T> by deferred {
     override val coroutineContext: CoroutineContext get() = this
     override val totalWork: Double get() = dependencies.sumByDouble { totalWork } + monitor.totalWork
     override val workDone: Double get() = dependencies.sumByDouble { workDone } + monitor.workDone
     override val status: String get() = monitor.status
 }
 
-private class StaticGoalImpl<T>(val context: CoroutineContext, deferred: CompletableDeferred<T>) : Goal<T>, Deferred<T> by deferred {
+private class StaticGoalImpl<T>(val context: CoroutineContext, deferred: CompletableDeferred<T>) : Goal<T>,
+    Deferred<T> by deferred {
     override val dependencies: Collection<Goal<*>> get() = emptyList()
     override val status: String get() = ""
     override val totalWork: Double get() = 0.0
@@ -94,7 +97,10 @@ fun <T, R> Goal<T>.pipe(block: suspend GoalMonitor.(T) -> R): Goal<R> = createGo
  * Create a joining goal.
  * @param scope the scope for resulting goal. By default use first goal in list
  */
-fun <T, R> Collection<Goal<T>>.join(scope: CoroutineScope = first(), block: suspend GoalMonitor.(Collection<T>) -> R): Goal<R> =
+fun <T, R> Collection<Goal<T>>.join(
+    scope: CoroutineScope = first(),
+    block: suspend GoalMonitor.(Collection<T>) -> R
+): Goal<R> =
     scope.createGoal(this) {
         block(map { it.await() })
     }

dataforge-io/src/commonMain/kotlin/hep/dataforge/io/OutputManager.kt

@@ -31,6 +31,10 @@ interface OutputManager : Plugin {
 /**
  * Get an output with given [name], [stage] and reified content type
  */
-inline fun <reified T : Any> OutputManager.typed(name: Name, stage: Name = EmptyName, meta: Meta = EmptyMeta): Output<T> {
+inline fun <reified T : Any> OutputManager.typed(
+    name: Name,
+    stage: Name = EmptyName,
+    meta: Meta = EmptyMeta
+): Output<T> {
     return typed(T::class, name, stage, meta)
 }

dataforge-meta/src/commonMain/kotlin/hep/dataforge/meta/Delegates.kt

@@ -11,25 +11,29 @@ import kotlin.reflect.KProperty
 
 //TODO add caching for sealed nodes
 
-class ValueDelegate(private val key: String? = null, private val default: Value? = null) : ReadOnlyProperty<Metoid, Value?> {
+class ValueDelegate(private val key: String? = null, private val default: Value? = null) :
+    ReadOnlyProperty<Metoid, Value?> {
     override fun getValue(thisRef: Metoid, property: KProperty<*>): Value? {
         return thisRef.meta[key ?: property.name]?.value ?: default
     }
 }
 
-class StringDelegate(private val key: String? = null, private val default: String? = null) : ReadOnlyProperty<Metoid, String?> {
+class StringDelegate(private val key: String? = null, private val default: String? = null) :
+    ReadOnlyProperty<Metoid, String?> {
     override fun getValue(thisRef: Metoid, property: KProperty<*>): String? {
         return thisRef.meta[key ?: property.name]?.string ?: default
     }
 }
 
-class BooleanDelegate(private val key: String? = null, private val default: Boolean? = null) : ReadOnlyProperty<Metoid, Boolean?> {
+class BooleanDelegate(private val key: String? = null, private val default: Boolean? = null) :
+    ReadOnlyProperty<Metoid, Boolean?> {
     override fun getValue(thisRef: Metoid, property: KProperty<*>): Boolean? {
         return thisRef.meta[key ?: property.name]?.boolean ?: default
     }
 }
 
-class NumberDelegate(private val key: String? = null, private val default: Number? = null) : ReadOnlyProperty<Metoid, Number?> {
+class NumberDelegate(private val key: String? = null, private val default: Number? = null) :
+    ReadOnlyProperty<Metoid, Number?> {
     override fun getValue(thisRef: Metoid, property: KProperty<*>): Number? {
         return thisRef.meta[key ?: property.name]?.number ?: default
     }
@@ -37,25 +41,32 @@ class NumberDelegate(private val key: String? = null, private val default: Numbe
 
 //Delegates with non-null values
 
-class SafeStringDelegate(private val key: String? = null, private val default: String) : ReadOnlyProperty<Metoid, String> {
+class SafeStringDelegate(private val key: String? = null, private val default: String) :
+    ReadOnlyProperty<Metoid, String> {
     override fun getValue(thisRef: Metoid, property: KProperty<*>): String {
         return thisRef.meta[key ?: property.name]?.string ?: default
     }
 }
 
-class SafeBooleanDelegate(private val key: String? = null, private val default: Boolean) : ReadOnlyProperty<Metoid, Boolean> {
+class SafeBooleanDelegate(private val key: String? = null, private val default: Boolean) :
+    ReadOnlyProperty<Metoid, Boolean> {
     override fun getValue(thisRef: Metoid, property: KProperty<*>): Boolean {
         return thisRef.meta[key ?: property.name]?.boolean ?: default
     }
 }
 
-class SafeNumberDelegate(private val key: String? = null, private val default: Number) : ReadOnlyProperty<Metoid, Number> {
+class SafeNumberDelegate(private val key: String? = null, private val default: Number) :
+    ReadOnlyProperty<Metoid, Number> {
     override fun getValue(thisRef: Metoid, property: KProperty<*>): Number {
         return thisRef.meta[key ?: property.name]?.number ?: default
     }
 }
 
-class SafeEnumDelegate<E : Enum<E>>(private val key: String? = null, private val default: E, private val resolver: (String) -> E) : ReadOnlyProperty<Metoid, E> {
+class SafeEnumDelegate<E : Enum<E>>(
+    private val key: String? = null,
+    private val default: E,
+    private val resolver: (String) -> E
+) : ReadOnlyProperty<Metoid, E> {
     override fun getValue(thisRef: Metoid, property: KProperty<*>): E {
         return (thisRef.meta[key ?: property.name]?.string)?.let { resolver(it) } ?: default
     }
@@ -63,7 +74,8 @@ class SafeEnumDelegate<E : Enum<E>>(private val key: String? = null, private val
 
 //Child node delegate
 
-class ChildDelegate<T>(private val key: String? = null, private val converter: (Meta) -> T) : ReadOnlyProperty<Metoid, T?> {
+class ChildDelegate<T>(private val key: String? = null, private val converter: (Meta) -> T) :
+    ReadOnlyProperty<Metoid, T?> {
     override fun getValue(thisRef: Metoid, property: KProperty<*>): T? {
         return thisRef.meta[key ?: property.name]?.node?.let { converter(it) }
     }
@@ -95,11 +107,13 @@ fun Metoid.boolean(default: Boolean, key: String? = null) = SafeBooleanDelegate(
 @JvmName("safeNumber")
 fun Metoid.number(default: Number, key: String? = null) = SafeNumberDelegate(key, default)
 
-inline fun <reified E : Enum<E>> Metoid.enum(default: E, key: String? = null) = SafeEnumDelegate(key, default) { enumValueOf(it) }
+inline fun <reified E : Enum<E>> Metoid.enum(default: E, key: String? = null) =
+    SafeEnumDelegate(key, default) { enumValueOf(it) }
 
 /* Config delegates */
 
-class ValueConfigDelegate(private val key: String? = null, private val default: Value? = null) : ReadWriteProperty<Configurable, Value?> {
+class ValueConfigDelegate(private val key: String? = null, private val default: Value? = null) :
+    ReadWriteProperty<Configurable, Value?> {
     override fun getValue(thisRef: Configurable, property: KProperty<*>): Value? {
         return thisRef.config[key ?: property.name]?.value ?: default
     }
@@ -114,7 +128,8 @@ class ValueConfigDelegate(private val key: String? = null, private val default:
     }
 }
 
-class StringConfigDelegate(private val key: String? = null, private val default: String? = null) : ReadWriteProperty<Configurable, String?> {
+class StringConfigDelegate(private val key: String? = null, private val default: String? = null) :
+    ReadWriteProperty<Configurable, String?> {
     override fun getValue(thisRef: Configurable, property: KProperty<*>): String? {
         return thisRef.config[key ?: property.name]?.string ?: default
     }
@@ -124,7 +139,8 @@ class StringConfigDelegate(private val key: String? = null, private val default:
     }
 }
 
-class BooleanConfigDelegate(private val key: String? = null, private val default: Boolean? = null) : ReadWriteProperty<Configurable, Boolean?> {
+class BooleanConfigDelegate(private val key: String? = null, private val default: Boolean? = null) :
+    ReadWriteProperty<Configurable, Boolean?> {
     override fun getValue(thisRef: Configurable, property: KProperty<*>): Boolean? {
         return thisRef.config[key ?: property.name]?.boolean ?: default
     }
@@ -134,7 +150,8 @@ class BooleanConfigDelegate(private val key: String? = null, private val default
     }
 }
 
-class NumberConfigDelegate(private val key: String? = null, private val default: Number? = null) : ReadWriteProperty<Configurable, Number?> {
+class NumberConfigDelegate(private val key: String? = null, private val default: Number? = null) :
+    ReadWriteProperty<Configurable, Number?> {
     override fun getValue(thisRef: Configurable, property: KProperty<*>): Number? {
         return thisRef.config[key ?: property.name]?.number ?: default
     }
@@ -146,7 +163,8 @@ class NumberConfigDelegate(private val key: String? = null, private val default:
 
 //Delegates with non-null values
 
-class SafeStringConfigDelegate(private val key: String? = null, private val default: String) : ReadWriteProperty<Configurable, String> {
+class SafeStringConfigDelegate(private val key: String? = null, private val default: String) :
+    ReadWriteProperty<Configurable, String> {
     override fun getValue(thisRef: Configurable, property: KProperty<*>): String {
         return thisRef.config[key ?: property.name]?.string ?: default
     }
@@ -156,7 +174,8 @@ class SafeStringConfigDelegate(private val key: String? = null, private val defa
     }
 }
 
-class SafeBooleanConfigDelegate(private val key: String? = null, private val default: Boolean) : ReadWriteProperty<Configurable, Boolean> {
+class SafeBooleanConfigDelegate(private val key: String? = null, private val default: Boolean) :
+    ReadWriteProperty<Configurable, Boolean> {
     override fun getValue(thisRef: Configurable, property: KProperty<*>): Boolean {
         return thisRef.config[key ?: property.name]?.boolean ?: default
     }
@@ -166,7 +185,8 @@ class SafeBooleanConfigDelegate(private val key: String? = null, private val def
     }
 }
 
-class SafeNumberConfigDelegate(private val key: String? = null, private val default: Number) : ReadWriteProperty<Configurable, Number> {
+class SafeNumberConfigDelegate(private val key: String? = null, private val default: Number) :
+    ReadWriteProperty<Configurable, Number> {
     override fun getValue(thisRef: Configurable, property: KProperty<*>): Number {
         return thisRef.config[key ?: property.name]?.number ?: default
     }
@@ -176,7 +196,11 @@ class SafeNumberConfigDelegate(private val key: String? = null, private val defa
     }
 }
 
-class SafeEnumvConfigDelegate<E : Enum<E>>(private val key: String? = null, private val default: E, private val resolver: (String) -> E) : ReadWriteProperty<Configurable, E> {
+class SafeEnumvConfigDelegate<E : Enum<E>>(
+    private val key: String? = null,
+    private val default: E,
+    private val resolver: (String) -> E
+) : ReadWriteProperty<Configurable, E> {
     override fun getValue(thisRef: Configurable, property: KProperty<*>): E {
         return (thisRef.config[key ?: property.name]?.string)?.let { resolver(it) } ?: default
     }
@@ -188,7 +212,8 @@ class SafeEnumvConfigDelegate<E : Enum<E>>(private val key: String? = null, priv
 
 //Child node delegate
 
-class ChildConfigDelegate<T : Configurable>(private val key: String? = null, private val converter: (Config) -> T) : ReadWriteProperty<Configurable, T> {
+class ChildConfigDelegate<T : Configurable>(private val key: String? = null, private val converter: (Config) -> T) :
+    ReadWriteProperty<Configurable, T> {
     override fun getValue(thisRef: Configurable, property: KProperty<*>): T {
         return converter(thisRef.config[key ?: property.name]?.node ?: Config())
     }
@@ -214,7 +239,8 @@ fun Configurable.number(default: Number? = null, key: String? = null) = NumberCo
 
 fun Configurable.child(key: String? = null) = ChildConfigDelegate(key) { SimpleConfigurable(it) }
 
-fun <T : Configurable> Configurable.child(key: String? = null, converter: (Config) -> T) = ChildConfigDelegate(key, converter)
+fun <T : Configurable> Configurable.child(key: String? = null, converter: (Config) -> T) =
+    ChildConfigDelegate(key, converter)
 
 //fun <T : Configurable> Configurable.spec(spec: Specification<T>, key: String? = null) = ChildConfigDelegate<T>(key) { spec.wrap(this) }
 
@@ -227,4 +253,5 @@ fun Configurable.boolean(default: Boolean, key: String? = null) = SafeBooleanCon
 @JvmName("safeNumber")
 fun Configurable.number(default: Number, key: String? = null) = SafeNumberConfigDelegate(key, default)
 
-inline fun <reified E : Enum<E>> Configurable.enum(default: E, key: String? = null) = SafeEnumvConfigDelegate(key, default) { enumValueOf(it) }
+inline fun <reified E : Enum<E>> Configurable.enum(default: E, key: String? = null) =
+    SafeEnumvConfigDelegate(key, default) { enumValueOf(it) }

dataforge-meta/src/commonMain/kotlin/hep/dataforge/meta/MutableMetaNode.kt

@@ -6,7 +6,10 @@ import hep.dataforge.names.plus
 import hep.dataforge.names.toName
 import hep.dataforge.values.Value
 
-class MetaListener(val owner: Any? = null, val action: (name: Name, oldItem: MetaItem<*>?, newItem: MetaItem<*>?) -> Unit) {
+class MetaListener(
+    val owner: Any? = null,
+    val action: (name: Name, oldItem: MetaItem<*>?, newItem: MetaItem<*>?) -> Unit
+) {
     operator fun invoke(name: Name, oldItem: MetaItem<*>?, newItem: MetaItem<*>?) = action(name, oldItem, newItem)
 }
 
@@ -139,7 +142,11 @@ fun <M : MutableMetaNode<M>> M.update(meta: Meta) {
 
 /* Same name siblings generation */
 
-fun <M : MutableMeta<M>> M.setIndexed(name: Name, items: Iterable<MetaItem<M>>, queryFactory: (Int) -> String = { it.toString() }) {
+fun <M : MutableMeta<M>> M.setIndexed(
+    name: Name,
+    items: Iterable<MetaItem<M>>,
+    queryFactory: (Int) -> String = { it.toString() }
+) {
     val tokens = name.tokens.toMutableList()
     val last = tokens.last()
     items.forEachIndexed { index, meta ->
@@ -149,7 +156,11 @@ fun <M : MutableMeta<M>> M.setIndexed(name: Name, items: Iterable<MetaItem<M>>,
     }
 }
 
-fun <M : MutableMetaNode<M>> M.setIndexed(name: Name, metas: Iterable<Meta>, queryFactory: (Int) -> String = { it.toString() }) {
+fun <M : MutableMetaNode<M>> M.setIndexed(
+    name: Name,
+    metas: Iterable<Meta>,
+    queryFactory: (Int) -> String = { it.toString() }
+) {
     setIndexed(name, metas.map { wrap(name, it) }, queryFactory)
 }
 

dataforge-meta/src/commonMain/kotlin/hep/dataforge/meta/Specification.kt

@@ -26,24 +26,29 @@ interface SpecificationBuilder<T : Specification> {
     fun wrap(meta: Meta): T = wrap(meta.toConfig())
 }
 
-fun <T : Specification> specification(wrapper: (Config) -> T): SpecificationBuilder<T> = object : SpecificationBuilder<T> {
+fun <T : Specification> specification(wrapper: (Config) -> T): SpecificationBuilder<T> =
+    object : SpecificationBuilder<T> {
         override fun wrap(config: Config): T = wrapper(config)
     }
 
 /**
  * Apply specified configuration to configurable
  */
-fun <T : Configurable, C : Specification, S : SpecificationBuilder<C>> T.configure(spec: S, action: C.() -> Unit) = apply { spec.update(config, action) }
+fun <T : Configurable, C : Specification, S : SpecificationBuilder<C>> T.configure(spec: S, action: C.() -> Unit) =
+    apply { spec.update(config, action) }
 
 /**
  * Update configuration using given specification
  */
-fun <C : Specification, S : SpecificationBuilder<C>> Specification.update(spec: S, action: C.() -> Unit) = apply { spec.update(config, action) }
+fun <C : Specification, S : SpecificationBuilder<C>> Specification.update(spec: S, action: C.() -> Unit) =
+    apply { spec.update(config, action) }
 
 /**
  * Create a style based on given specification
  */
-fun <C : Specification, S : SpecificationBuilder<C>> S.createStyle(action: C.() -> Unit): Meta = Config().also { update(it, action) }
+fun <C : Specification, S : SpecificationBuilder<C>> S.createStyle(action: C.() -> Unit): Meta =
+    Config().also { update(it, action) }
 
 
-fun <C : Specification> Specification.spec(spec: SpecificationBuilder<C>, key: String? = null) = ChildConfigDelegate<C>(key) { spec.wrap(config) }
+fun <C : Specification> Specification.spec(spec: SpecificationBuilder<C>, key: String? = null) =
+    ChildConfigDelegate<C>(key) { spec.wrap(config) }