dataforge-data/src/commonMain/kotlin/space/kscience/dataforge/actions/AbstractAction.kt

@@ -21,7 +21,7 @@ internal fun MutableMap<Name, *>.removeWhatStartsWith(name: Name) {
 /**
  * An action that caches results on-demand and recalculates them on source push
  */
-public abstract class AbstractAction<T, R>(
+public abstract class AbstractAction<T : Any, R : Any>(
     public val outputType: KType,
 ) : Action<T, R> {
 
@@ -37,23 +37,21 @@ public abstract class AbstractAction<T, R>(
      * Update part of the data set using provided data
      *
      * @param source the source data tree in case we need several data items to update
-     * @param meta the metadata used for the whole data tree
-     * @param updatedData an updated item
      */
     protected open fun DataSink<R>.update(
         source: DataTree<T>,
         meta: Meta,
-        updatedData: NamedData<T>,
+        namedData: NamedData<T>,
-    ) {
+    ){
         //by default regenerate the whole data set
-        generate(source, meta)
+        generate(source,meta)
     }
 
     @OptIn(DFInternal::class)
     override fun execute(
         dataSet: DataTree<T>,
         meta: Meta,
-    ): DataTree<R> = if (dataSet.isObservable()) {
+    ): DataTree<R> = if(dataSet.isObservable()) {
         MutableDataTree<R>(outputType, dataSet.updatesScope).apply {
             generate(dataSet, meta)
             dataSet.updates().onEach {
@@ -66,8 +64,8 @@ public abstract class AbstractAction<T, R>(
                 close()
             }
         }
-    } else {
+    } else{
-        DataTree(outputType) {
+        DataTree(outputType){
             generate(dataSet, meta)
         }
     }

dataforge-data/src/commonMain/kotlin/space/kscience/dataforge/actions/MapAction.kt

@@ -50,7 +50,7 @@ public class MapActionBuilder<T, R>(
 }
 
 @PublishedApi
-internal class MapAction<T, R>(
+internal class MapAction<T : Any, R : Any>(
     outputType: KType,
     private val block: MapActionBuilder<T, R>.() -> Unit,
 ) : AbstractAction<T, R>(outputType) {
@@ -86,8 +86,8 @@ internal class MapAction<T, R>(
         data.forEach { mapOne(it.name, it.data, meta) }
     }
 
-    override fun DataSink<R>.update(source: DataTree<T>, meta: Meta, updatedData: NamedData<T>) {
+    override fun DataSink<R>.update(source: DataTree<T>, meta: Meta, namedData: NamedData<T>) {
-        mapOne(updatedData.name, updatedData.data, updatedData.meta)
+        mapOne(namedData.name, namedData.data, namedData.meta)
     }
 }
 
@@ -96,7 +96,7 @@ internal class MapAction<T, R>(
  * A one-to-one mapping action
  */
 @DFExperimental
-public inline fun <T, reified R> Action.Companion.mapping(
+public inline fun <T : Any, reified R : Any> Action.Companion.mapping(
     noinline builder: MapActionBuilder<T, R>.() -> Unit,
 ): Action<T, R> = MapAction(typeOf<R>(), builder)
 

dataforge-data/src/commonMain/kotlin/space/kscience/dataforge/actions/ReduceAction.kt

@@ -12,7 +12,7 @@ import kotlin.reflect.KType
 import kotlin.reflect.typeOf
 
 
-public class JoinGroup<T, R>(
+public class JoinGroup<T : Any, R : Any>(
     public var name: String,
     internal val set: DataTree<T>,
     @PublishedApi internal var outputType: KType,
@@ -35,7 +35,7 @@ public class JoinGroup<T, R>(
 }
 
 @DFBuilder
-public class ReduceGroupBuilder<T, R>(
+public class ReduceGroupBuilder<T : Any, R : Any>(
     public val actionMeta: Meta,
     private val outputType: KType,
 ) {
@@ -79,7 +79,7 @@ public class ReduceGroupBuilder<T, R>(
 }
 
 @PublishedApi
-internal class ReduceAction<T, R>(
+internal class ReduceAction<T : Any, R : Any>(
     outputType: KType,
     private val action: ReduceGroupBuilder<T, R>.() -> Unit,
 ) : AbstractAction<T, R>(outputType) {

dataforge-data/src/commonMain/kotlin/space/kscience/dataforge/actions/SplitAction.kt

@@ -13,9 +13,9 @@ import kotlin.reflect.KType
 import kotlin.reflect.typeOf
 
 
-public class SplitBuilder<T, R>(public val name: Name, public val meta: Meta) {
+public class SplitBuilder<T : Any, R : Any>(public val name: Name, public val meta: Meta) {
 
-    public class FragmentRule<T, R>(
+    public class FragmentRule<T : Any, R : Any>(
         public val name: Name,
         public var meta: MutableMeta,
         @PublishedApi internal var outputType: KType,
@@ -44,7 +44,7 @@ public class SplitBuilder<T, R>(public val name: Name, public val meta: Meta) {
  * Action that splits each incoming element into a number of fragments defined in builder
  */
 @PublishedApi
-internal class SplitAction<T, R>(
+internal class SplitAction<T : Any, R : Any>(
     outputType: KType,
     private val action: SplitBuilder<T, R>.() -> Unit,
 ) : AbstractAction<T, R>(outputType) {
@@ -77,8 +77,8 @@ internal class SplitAction<T, R>(
         data.forEach { splitOne(it.name, it.data, meta) }
     }
 
-    override fun DataSink<R>.update(source: DataTree<T>, meta: Meta, updatedData: NamedData<T>) {
+    override fun DataSink<R>.update(source: DataTree<T>, meta: Meta, namedData: NamedData<T>) {
-        splitOne(updatedData.name, updatedData.data, updatedData.meta)
+        splitOne(namedData.name, namedData.data, namedData.meta)
     }
 }
 

dataforge-data/src/commonMain/kotlin/space/kscience/dataforge/data/GroupRule.kt

@@ -20,7 +20,7 @@ import space.kscience.dataforge.meta.string
 import space.kscience.dataforge.misc.DFInternal
 
 public interface GroupRule {
-    public fun <T> gather(set: DataTree<T>): Map<String, DataTree<T>>
+    public fun <T : Any> gather(set: DataTree<T>): Map<String, DataTree<T>>
 
     public companion object {
         /**
@@ -37,7 +37,7 @@ public interface GroupRule {
             defaultTagValue: String,
         ): GroupRule = object : GroupRule {
 
-            override fun <T> gather(
+            override fun <T : Any> gather(
                 set: DataTree<T>,
             ): Map<String, DataTree<T>> {
                 val map = HashMap<String, DataTreeBuilder<T>>()

dataforge-data/src/commonMain/kotlin/space/kscience/dataforge/data/NamedData.kt

@@ -10,7 +10,7 @@ public interface NamedData<out T> : Named, Data<T> {
 }
 
 public operator fun NamedData<*>.component1(): Name = name
-public operator fun <T> NamedData<T>.component2(): Data<T> = data
+public operator fun <T: Any> NamedData<T>.component2(): Data<T> = data
 
 private class NamedDataImpl<T>(
     override val name: Name,

dataforge-meta/src/commonMain/kotlin/space/kscience/dataforge/meta/MutableMeta.kt

@@ -19,10 +19,6 @@ public annotation class MetaBuilderMarker
 public interface MutableMetaProvider : MetaProvider, MutableValueProvider {
     override fun get(name: Name): MutableMeta?
     public operator fun set(name: Name, node: Meta?)
-
-    /**
-     * Set value with the given name. Does nothing if value is not changed.
-     */
     override fun setValue(name: Name, value: Value?)
 }
 
@@ -52,13 +48,11 @@ public interface MutableMeta : Meta, MutableMetaProvider {
     }
 
     override fun setValue(name: Name, value: Value?) {
-        if (value != getValue(name)) {
         getOrCreate(name).value = value
     }
-    }
 
     /**
-     * Get an existing node or create a new one
+     * Get existing node or create a new one
      */
     public fun getOrCreate(name: Name): MutableMeta
 
@@ -204,8 +198,10 @@ public operator fun MutableMetaProvider.set(key: String, metas: Iterable<Meta>):
 
 
 /**
- * Update the existing mutable node with another node.
+ * Update existing mutable node with another node. The rules are following:
- * Values that are present in the current provider and are missing in [meta] are kept.
+ *  * value replaces anything
+ *  * node updates node and replaces anything but node
+ *  * node list updates node list if number of nodes in the list is the same and replaces anything otherwise
  */
 public fun MutableMetaProvider.update(meta: Meta) {
     meta.valueSequence().forEach { (name, value) ->
@@ -226,7 +222,7 @@ public fun <M : MutableTypedMeta<M>> MutableTypedMeta<M>.edit(name: Name, builde
     getOrCreate(name).apply(builder)
 
 /**
- * Set a value at a given [name]. If a node does not exist, create it.
+ * Set a value at a given [name]. If node does not exist, create it.
  */
 public operator fun <M : MutableTypedMeta<M>> MutableTypedMeta<M>.set(name: Name, value: Value?) {
     edit(name) {
@@ -371,21 +367,6 @@ public fun MutableMeta.append(name: Name, value: Value): Unit = append(name, Met
 
 public fun MutableMeta.append(key: String, value: Value): Unit = append(Name.parse(key), value)
 
-/**
- * Update all items that exist in the [newMeta] and remove existing items that are missing in [newMeta].
- * This produces the same result as clearing all items and updating blank meta with a [newMeta], but does not
- * produce unnecessary invalidation events (if they are supported).
- */
-public fun MutableMeta.reset(newMeta: Meta) {
-    //remove old items
-    (items.keys - newMeta.items.keys).forEach {
-        remove(it.asName())
-    }
-    newMeta.items.forEach { (token, item)->
-        set(token, item)
-    }
-}
-
 /**
  * Create a mutable copy of this meta. The copy is created even if the Meta is already mutable
  */

dataforge-meta/src/commonMain/kotlin/space/kscience/dataforge/meta/SealedMeta.kt

@@ -76,8 +76,6 @@ internal class MetaBuilder(
 
 
     override fun set(name: Name, node: Meta?) {
-        //skip setting if value has not changed
-        if(node == get(name)) return
         when (name.length) {
             0 -> error("Can't set a meta with empty name")
             1 -> {
@@ -91,7 +89,7 @@ internal class MetaBuilder(
             }
 
             else -> {
-                getOrCreate(name.first().asName())[name.cutFirst()] = node
+                getOrCreate(name.first().asName()).set(name.cutFirst(), node)
             }
         }
     }

dataforge-meta/src/commonTest/kotlin/space/kscience/dataforge/meta/MetaTest.kt

@@ -61,33 +61,4 @@ class MetaTest {
         assertEquals(null, indexed["8"])
         assertEquals(12, indexed["12"].int)
     }
-
-    @Test
-    fun reset() {
-        val oldMeta = MutableMeta {
-            "a" put {
-                "value" put "aValue"
-            }
-            "b" put {
-                "value" put "bValue"
-            }
-            "c" put {
-                "value" put "cValue"
-            }
-        }
-        val newMeta = Meta {
-            "a" put {
-                "value" put "aValue"
-            }
-            "b" put {
-                "value" put "bValue"
-            }
-            "d" put {
-                "value" put "dValue"
-            }
-        }
-        oldMeta.reset(newMeta)
-        println(oldMeta)
-        assertEquals(setOf("a", "b", "d"), oldMeta.items.keys.map { it.toString() }.toSet())
-    }
 }

gradle/wrapper/gradle-wrapper.properties

@@ -1,5 +1,5 @@
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-8.6-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.4-bin.zip
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists