fix: implement proper thread ID handling for activities

stakwork · Feb 12, 2025 · 1716fe4 · 1716fe4
1 parent e7bef6b
commit 1716fe4
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/db/activities.go b/db/activities.go
@@ -69,6 +69,11 @@ func (db database) CreateActivity(activity *Activity) (*Activity, error) {
 	if activity.ID == uuid.Nil {
 		activity.ID = uuid.New()
 	}
+
+	if activity.ThreadID == uuid.Nil {
+		activity.ThreadID = activity.ID
+		activity.Sequence = 1
+	}
 
 	if activity.Actions == nil {
 		activity.Actions = []string{}