From 26b678b3482900e032d6e303a34990c1c0d2a93d Mon Sep 17 00:00:00 2001 From: aleidk Date: Sat, 30 Nov 2024 18:54:43 -0300 Subject: [PATCH] fix: only bulkAdd new collections instead of all collections It was duplicating previosly created nodes --- pkg/platform.go | 22 +++++++++++++--------- 1 file changed, 13 insertions(+), 9 deletions(-) diff --git a/pkg/platform.go b/pkg/platform.go index 999e075..a0bfdea 100644 --- a/pkg/platform.go +++ b/pkg/platform.go @@ -42,24 +42,28 @@ func (platform *Platform) FetchCollections( fmt.Printf("Collections: %v\n", len(platform.Collections)) - err = BulkCreateNode(platform._conn, platform.Collections) + err = BulkCreateNode(platform._conn, values) if err != nil { return err } - for _, item := range platform.Collections { - err := platform.AddRelationship( - &Relationship{ - _class: "PLATFORM_HAS_COLLECTION", - From: platform.Id, - To: item.Id, - }) + relationships := make([]*Relationship, 0, len(values)) + + for _, item := range values { + relation := &Relationship{ + _class: "PLATFORM_HAS_COLLECTION", + From: platform.Id, + To: item.Id, + } + + err := platform.AddRelationship(relation) if err != nil { return err } + relationships = append(relationships, relation) } - err = BulkCreateRelationships(platform._conn, platform._relationships) + err = BulkCreateRelationships(platform._conn, relationships) if err != nil { return err }