fix(logs): include unique identifier for logs (#119)

jim-junior · web-flow · commit 29939af53dd2 · 2025-10-11T21:35:09.000+03:00
diff --git a/internal/models/logs.go b/internal/models/logs.go
@@ -5,6 +5,7 @@ import (
 	"fmt"
 
 	"github.com/dgraph-io/badger/v4"
+	"github.com/google/uuid"
 
 	"github.com/open-ug/conveyor/pkg/types"
 )
@@ -15,7 +16,7 @@ type LogModel struct {
 
 // Generate composite key
 func makeKey(pipeline, driver, runid, timestamp string) string {
-	return fmt.Sprintf("%s|%s|%s|%s", pipeline, driver, runid, timestamp)
+	return fmt.Sprintf("%s|%s|%s|%s|%s", pipeline, driver, runid, timestamp, uuid.New().String())
 }
 
 // Insert log entry

Original file line number	Diff line number	Diff line change
`@@ -5,6 +5,7 @@ import (`
`5`	`5`	`"fmt"`
`6`	`6`
`7`	`7`	`"github.com/dgraph-io/badger/v4"`
	`8`	`+ "github.com/google/uuid"`
`8`	`9`
`9`	`10`	`"github.com/open-ug/conveyor/pkg/types"`
`10`	`11`	`)`
`@@ -15,7 +16,7 @@ type LogModel struct {`
`15`	`16`
`16`	`17`	`// Generate composite key`
`17`	`18`	`func makeKey(pipeline, driver, runid, timestamp string) string {`
`18`		`- return fmt.Sprintf("%s\|%s\|%s\|%s", pipeline, driver, runid, timestamp)`
	`19`	`+ return fmt.Sprintf("%s\|%s\|%s\|%s\|%s", pipeline, driver, runid, timestamp, uuid.New().String())`
`19`	`20`	`}`
`20`	`21`
`21`	`22`	`// Insert log entry`