init

@@ -0,0 +163,4 @@
+{
+  GeometrySet geometry_set = params.extract_input<GeometrySet>("Points");
+  const Field<int> group_id_field = params.extract_input<Field<int>>("Curve Group ID");
+  const Field<float> length_field = params.extract_input<Field<float>>("Weight");

@@ -0,0 +90,4 @@
+  const int domain_size = points->totpoint;
+
+  Array<int> group_ids(domain_size);
+  Array<float> weights(domain_size);

@@ -0,0 +106,4 @@
+    bke::CurvesGeometry &curves = curves_id->geometry.wrap();
+    curves.cyclic_for_write().fill(false);
+    if (weights_is_single) {
+      bke::copy_attributes(points->attributes(),

@@ -0,0 +113,4 @@
+                           curves.attributes_for_write());
+      return curves_id;
+    }
+    const Array<int, 2> offset({0, domain_size});

@@ -0,0 +5,4 @@
+#include "node_geometry_util.hh"
+
+#include "BKE_attribute.hh"
+#include "BKE_attribute_math.hh"

@@ -0,0 +40,4 @@
+  const auto comparator = [&](const int index_a, const int index_b) {
+    const float weight_a = weights[index_a];
+    const float weight_b = weights[index_b];
+    if (UNLIKELY(weight_a == weight_b)) {

@@ -0,0 +47,4 @@
+    return weight_a > weight_b;
+  };
+
+  threading::parallel_for_each(offsets.index_range(), [&](const int group_index) {

@@ -0,0 +58,4 @@
+                            const Span<int> indices,
+                            MutableAttributeAccessor dst_attributes)
+{
+  src_attributes.for_all([&](const AttributeIDRef &id, const AttributeMetaData meta_data) {

@@ -0,0 +62,4 @@
+    if (id.is_anonymous() && !propagation_info.propagate(id.anonymous_id())) {
+      return true;
+    }
+    const bke::GAttributeReader src = src_attributes.lookup(id);

@@ -0,0 +71,4 @@
+    const GVArraySpan src_span(src.varray);
+    bke::attribute_math::convert_to_static_type(meta_data.data_type, [&](auto dummy) {
+      using T = decltype(dummy);
+      array_utils::gather<T, int>(src_span.typed<T>(), indices, dst.span.typed<T>());

@@ -0,0 +78,4 @@
+  });
+}
+
+static void deduce_curves(const Span<int> indices_of_curves,

@@ -0,0 +102,4 @@
+        }
+      });
+
+  Array<int> indices(deduplicated_groups.size());

@@ -0,0 +119,4 @@
+}
+
+static Curves *curve_from_points(const AttributeAccessor attributes,
+                                 const VArray<float> weights_varray,

@@ -0,0 +196,4 @@
+  geometry_set.modify_geometry_sets([&](GeometrySet &geometry_set) {
+    const PointCloud *points = geometry_set.get_pointcloud();
+    Curves *curves_id = curves_from_points(
+        points, group_id_field, weight_field, params.get_output_propagation_info("Curves"));

@@ -213,6 +214,7 @@ set(LIB
   PRIVATE bf::intern::guardedalloc
   bf_nodes
   extern_fmtlib
+  PRIVATE bf::intern::atomic

@@ -927,6 +927,13 @@ void gather_attributes(AttributeAccessor src_attributes,
                        const IndexMask &selection,
                        MutableAttributeAccessor dst_attributes);
 
+void gather_attributes(AttributeAccessor src_attributes,

@@ -0,0 +23,4 @@
+{
+  b.add_input<decl::Geometry>("Points")
+      .supported_type(GeometryComponent::Type::PointCloud)
+      .description("Points to build curves");

@@ -0,0 +28,4 @@
+      .field_on_all()
+      .hide_value()
+      .description(
+          "Index of curve for each point. ID groups will be converted to curves indices without "

@@ -0,0 +31,4 @@
+          "Index of curve for each point. ID groups will be converted to curves indices without "
+          "gaps");
+  b.add_input<decl::Float>("Weight").field_on_all().hide_value().description(
+      "Weight to sort points of curve");

@@ -0,0 +72,4 @@
+  }
+}
+
+int identifiers_to_indices(MutableSpan<int> r_identifiers_to_indices)

@@ -1036,0 +1056,4 @@
+    if (!dst) {
+      return true;
+    }
+    bke::attribute_math::convert_to_static_type(meta_data.data_type, [&](auto dummy) {

@@ -0,0 +91,4 @@
+  const int domain_size = weights_varray.size();
+  Curves *curves_id = bke::curves_new_nomain_single(domain_size, CURVE_TYPE_POLY);
+  bke::CurvesGeometry &curves = curves_id->geometry.wrap();
+  curves.cyclic_for_write().fill(false);

@@ -0,0 +111,4 @@
+                                  const Field<float> &weight_field,
+                                  const bke::AnonymousAttributePropagationInfo &propagation_info)
+{
+  if (points == nullptr) {

@@ -0,0 +165,4 @@
+  geometry_set.modify_geometry_sets([&](GeometrySet &geometry_set) {
+    const PointCloud *points = geometry_set.get_pointcloud();
+    geometry_set.replace_curves(nullptr);
+    if (points != nullptr) {