feat: improved error handling

juicycleff · juicycleff · commit 2cc40ede774d · 2026-07-08T08:29:12.000-05:00
diff --git a/go.mod b/go.mod
@@ -4,21 +4,23 @@ go 1.25.7
 
 require (
 	github.com/a-h/templ v0.3.1001
-	github.com/xraph/fabriq v0.0.3
+	github.com/jackc/pgx/v5 v5.10.0
+	github.com/xraph/fabriq v0.0.4
 	github.com/xraph/forge v1.8.0
 	github.com/xraph/forgeui v1.4.1
 	github.com/xraph/go-utils v1.1.1
-	github.com/xraph/grove v1.5.8
-	github.com/xraph/grove/drivers/mongodriver v1.5.8
-	github.com/xraph/grove/drivers/pgdriver v1.5.8
-	github.com/xraph/grove/drivers/sqlitedriver v1.5.8
+	github.com/xraph/grove v1.5.9
+	github.com/xraph/grove/drivers/mongodriver v1.5.9
+	github.com/xraph/grove/drivers/pgdriver v1.5.9
+	github.com/xraph/grove/drivers/sqlitedriver v1.5.9
 	github.com/xraph/nexus v1.5.5
 	github.com/xraph/sentinel v1.5.2
 	github.com/xraph/shield v1.5.2
 	github.com/xraph/vessel v1.0.2
 	github.com/xraph/weave v1.5.4
 	go.jetify.com/typeid/v2 v2.0.0-alpha.3
 	go.mongodb.org/mongo-driver/v2 v2.5.0
+	modernc.org/sqlite v1.46.1
 )
 
 require go.uber.org/atomic v1.11.0 // indirect
@@ -83,7 +85,6 @@ require (
 	github.com/hashicorp/serf v0.10.1 // indirect
 	github.com/jackc/pgpassfile v1.0.0 // indirect
 	github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761 // indirect
-	github.com/jackc/pgx/v5 v5.10.0 // indirect
 	github.com/jackc/puddle/v2 v2.2.2 // indirect
 	github.com/josharian/intern v1.0.0 // indirect
 	github.com/json-iterator/go v1.1.12 // indirect
@@ -141,8 +142,8 @@ require (
 	github.com/xdg-go/scram v1.2.0 // indirect
 	github.com/xdg-go/stringprep v1.0.4 // indirect
 	github.com/xraph/confy v0.5.2 // indirect
-	github.com/xraph/grove/kv v1.5.7 // indirect
-	github.com/xraph/grove/kv/drivers/redisdriver v1.5.7 // indirect
+	github.com/xraph/grove/kv v1.5.8 // indirect
+	github.com/xraph/grove/kv/drivers/redisdriver v1.5.8 // indirect
 	github.com/xraph/trove v1.5.1 // indirect
 	github.com/youmark/pkcs8 v0.0.0-20240726163527-a2c0da244d78 // indirect
 	github.com/yusufpapurcu/wmi v1.2.4 // indirect
@@ -186,7 +187,6 @@ require (
 	modernc.org/libc v1.68.0 // indirect
 	modernc.org/mathutil v1.7.1 // indirect
 	modernc.org/memory v1.11.0 // indirect
-	modernc.org/sqlite v1.46.1 // indirect
 	nhooyr.io/websocket v1.8.17 // indirect
 	sigs.k8s.io/json v0.0.0-20250730193827-2d320260d730 // indirect
 	sigs.k8s.io/randfill v1.0.0 // indirect
diff --git a/go.sum b/go.sum
@@ -408,26 +408,26 @@ github.com/xdg-go/stringprep v1.0.4 h1:XLI/Ng3O1Atzq0oBs3TWm+5ZVgkq2aqdlvP9JtoZ6
 github.com/xdg-go/stringprep v1.0.4/go.mod h1:mPGuuIYwz7CmR2bT9j4GbQqutWS1zV24gijq1dTyGkM=
 github.com/xraph/confy v0.5.2 h1:YlZDDG2sZWyiSm4yjXTLQ7RFdy/3izg/plJh1g9guEA=
 github.com/xraph/confy v0.5.2/go.mod h1:FPupuOi04fSgh8pKb9BOTPxyzq9WhIncfY9aDH0bLO8=
-github.com/xraph/fabriq v0.0.3 h1:RX6sTLvjB5ZmGvuPitJMYa06y0OA+1fCQyKtwXcqejI=
-github.com/xraph/fabriq v0.0.3/go.mod h1:mr8mWrSKs4X8lUMHp7rUuiQkrG7sY+PSuQYIWW/5eB0=
+github.com/xraph/fabriq v0.0.4 h1:GamTKt+eRIl6Jj1SS/6zLeOFODDm3hK3gnwcBdOHg54=
+github.com/xraph/fabriq v0.0.4/go.mod h1:YLX7fHRmgqPqcOz4T+5ek8VSk/i70ltB0IpEYWD6IH4=
 github.com/xraph/forge v1.8.0 h1:P+Pw0krcF3L278wiWHTs3KZDaC53j4egKguzOpKr+nA=
 github.com/xraph/forge v1.8.0/go.mod h1:a+N9fYEEwb6Los1VcJ9V/xFThohkQsyo7vc9w9mD7V4=
 github.com/xraph/forgeui v1.4.1 h1:LHK1t/sZ+9zL+MNUZralO9/rc0f5UCa19dpbWTuRMNg=
 github.com/xraph/forgeui v1.4.1/go.mod h1:rH/+wb1tt2pXSHotWAvoP+Lt846xlIjuwPDSpS5K5mw=
 github.com/xraph/go-utils v1.1.1 h1:k5TOQ1qhXLdEX8W5F60mSuPcFOPc8sBsnhmjx/Kpr5g=
 github.com/xraph/go-utils v1.1.1/go.mod h1:tZN4SuGy9otCo6dETp7Cvkgyiy0BvaJaZbTBv4Euvo4=
-github.com/xraph/grove v1.5.8 h1:BgTy8+9V4l5OSqkXmM25mXNxh15FX7GFPjgWNaXjwH0=
-github.com/xraph/grove v1.5.8/go.mod h1:bgjHNhnmyfEyzbdpcppRt+Zf24nNcbGKlo450Mi4giI=
-github.com/xraph/grove/drivers/mongodriver v1.5.8 h1:RKDD0RnWPSl6WhwIaLf6wiCFXc9mo3rCzDH06NQBPDM=
-github.com/xraph/grove/drivers/mongodriver v1.5.8/go.mod h1:xojoSuw3qSm3NIe3xBmasocRQ7oyju3XbjvdlCXVXIU=
-github.com/xraph/grove/drivers/pgdriver v1.5.8 h1:p47i96rmhOGDMYT949FbH06k4vRvQ+9rDpXCgNvEl+Q=
-github.com/xraph/grove/drivers/pgdriver v1.5.8/go.mod h1:BBCrIuCBrRajE/dB5IKC0HshU/bUHPNS/etWtmX19qo=
-github.com/xraph/grove/drivers/sqlitedriver v1.5.8 h1:GpncObiNhFdwWLowt7Xb9vul+vV0xingp6DqKyMvzsQ=
-github.com/xraph/grove/drivers/sqlitedriver v1.5.8/go.mod h1:xzHewWROOPVn0Luu8/sWEAhSgmDnw3xmNrRw0xcefnM=
-github.com/xraph/grove/kv v1.5.7 h1:kkkicqZdLQkur4K4jKpKQiwq1uRJchTjO5LvWofMKOw=
-github.com/xraph/grove/kv v1.5.7/go.mod h1:rdwh/Ja2WOhZ3YwrIp8vBeDNATAOj+2vrK+XVuRHrJU=
-github.com/xraph/grove/kv/drivers/redisdriver v1.5.7 h1:XpzswYNxTvbJJ5Pk7gWwl4SGFTI1k3CMC0UfqY7xUHk=
-github.com/xraph/grove/kv/drivers/redisdriver v1.5.7/go.mod h1:15TFWsrEvCTHKiqgn40x06VzQTFEaiWyjpVoA2m3FFU=
+github.com/xraph/grove v1.5.9 h1:BTYvJnq5zqKWMr2bkDPmW7BWE5HZkThOmWn/qT6C/XE=
+github.com/xraph/grove v1.5.9/go.mod h1:bgjHNhnmyfEyzbdpcppRt+Zf24nNcbGKlo450Mi4giI=
+github.com/xraph/grove/drivers/mongodriver v1.5.9 h1:KUUzAdAPGgOZfiIgh3Ipekq8/As/j3ZnAK1DmerA5/0=
+github.com/xraph/grove/drivers/mongodriver v1.5.9/go.mod h1:xojoSuw3qSm3NIe3xBmasocRQ7oyju3XbjvdlCXVXIU=
+github.com/xraph/grove/drivers/pgdriver v1.5.9 h1:HOnF6RjWA9p4WkKL/xHJqUzVq/MZoIlARYkD/dvcUdw=
+github.com/xraph/grove/drivers/pgdriver v1.5.9/go.mod h1:BBCrIuCBrRajE/dB5IKC0HshU/bUHPNS/etWtmX19qo=
+github.com/xraph/grove/drivers/sqlitedriver v1.5.9 h1:vtpkXh5NUWI1X9/UUkA5PF1oVLbd9LkPXtQPy3gmOwM=
+github.com/xraph/grove/drivers/sqlitedriver v1.5.9/go.mod h1:xzHewWROOPVn0Luu8/sWEAhSgmDnw3xmNrRw0xcefnM=
+github.com/xraph/grove/kv v1.5.8 h1:Eg+laumIvqa/pQxCpxsqX2QPXQHdpJGlGfRMaHwbrcM=
+github.com/xraph/grove/kv v1.5.8/go.mod h1:rdwh/Ja2WOhZ3YwrIp8vBeDNATAOj+2vrK+XVuRHrJU=
+github.com/xraph/grove/kv/drivers/redisdriver v1.5.8 h1:Glz3AJMB2D2U8Qco13ciLfh5LJWCcAW5nh46xvs5w+o=
+github.com/xraph/grove/kv/drivers/redisdriver v1.5.8/go.mod h1:15TFWsrEvCTHKiqgn40x06VzQTFEaiWyjpVoA2m3FFU=
 github.com/xraph/nexus v1.5.5 h1:ccxqPpJ+z/5UImdYkOBwgov6Qo5lQYEhOtcjeDPOr8Q=
 github.com/xraph/nexus v1.5.5/go.mod h1:Qug6QyTrXIeD0oMPO0vVvMcF8jNZiZ+oqn9YuRdg8HI=
 github.com/xraph/sentinel v1.5.2 h1:cxSI6PZ49uUKj6egaCFtwTrAwrKtgeeBvY4yG+xPbEA=
diff --git a/store/mongo/agent.go b/store/mongo/agent.go
@@ -20,6 +20,9 @@ func (s *Store) Create(ctx context.Context, config *agent.Config) error {
 
 	_, err := s.mdb.NewInsert(m).Exec(ctx)
 	if err != nil {
+		if isUniqueViolation(err) {
+			return fmt.Errorf("cortex/mongo: create agent: %w", cortex.ErrAlreadyExists)
+		}
 		return fmt.Errorf("cortex/mongo: create agent: %w", err)
 	}
 
diff --git a/store/mongo/behavior.go b/store/mongo/behavior.go
@@ -20,6 +20,9 @@ func (s *Store) CreateBehavior(ctx context.Context, b *behavior.Behavior) error
 
 	_, err := s.mdb.NewInsert(m).Exec(ctx)
 	if err != nil {
+		if isUniqueViolation(err) {
+			return fmt.Errorf("cortex/mongo: create behavior: %w", cortex.ErrAlreadyExists)
+		}
 		return fmt.Errorf("cortex/mongo: create behavior: %w", err)
 	}
 
diff --git a/store/mongo/orchestration.go b/store/mongo/orchestration.go
@@ -18,6 +18,9 @@ func (s *Store) CreateOrchestration(ctx context.Context, c *orchestration.Config
 	c.UpdatedAt = t
 
 	if _, err := s.mdb.NewInsert(orchestrationConfigToModel(c)).Exec(ctx); err != nil {
+		if isUniqueViolation(err) {
+			return fmt.Errorf("cortex/mongo: create orchestration: %w", cortex.ErrAlreadyExists)
+		}
 		return fmt.Errorf("cortex/mongo: create orchestration: %w", err)
 	}
 
diff --git a/store/mongo/persona.go b/store/mongo/persona.go
@@ -20,6 +20,9 @@ func (s *Store) CreatePersona(ctx context.Context, p *persona.Persona) error {
 
 	_, err := s.mdb.NewInsert(m).Exec(ctx)
 	if err != nil {
+		if isUniqueViolation(err) {
+			return fmt.Errorf("cortex/mongo: create persona: %w", cortex.ErrAlreadyExists)
+		}
 		return fmt.Errorf("cortex/mongo: create persona: %w", err)
 	}
 
diff --git a/store/mongo/skill.go b/store/mongo/skill.go
@@ -20,6 +20,9 @@ func (s *Store) CreateSkill(ctx context.Context, sk *skill.Skill) error {
 
 	_, err := s.mdb.NewInsert(m).Exec(ctx)
 	if err != nil {
+		if isUniqueViolation(err) {
+			return fmt.Errorf("cortex/mongo: create skill: %w", cortex.ErrAlreadyExists)
+		}
 		return fmt.Errorf("cortex/mongo: create skill: %w", err)
 	}
 
diff --git a/store/mongo/store.go b/store/mongo/store.go
@@ -84,3 +84,9 @@ func now() time.Time {
 func isNoDocuments(err error) bool {
 	return errors.Is(err, mongo.ErrNoDocuments)
 }
+
+// isUniqueViolation reports whether err is a MongoDB duplicate-key error
+// (code 11000), so callers can translate it into cortex.ErrAlreadyExists.
+func isUniqueViolation(err error) bool {
+	return mongo.IsDuplicateKeyError(err)
+}
diff --git a/store/mongo/store_test.go b/store/mongo/store_test.go
@@ -0,0 +1,32 @@
+package mongo
+
+import (
+	"errors"
+	"fmt"
+	"testing"
+
+	"go.mongodb.org/mongo-driver/v2/mongo"
+)
+
+func TestIsUniqueViolation(t *testing.T) {
+	dup := mongo.WriteException{
+		WriteErrors: mongo.WriteErrors{{Code: 11000, Message: "E11000 duplicate key error"}},
+	}
+	tests := []struct {
+		name string
+		err  error
+		want bool
+	}{
+		{"nil", nil, false},
+		{"duplicate key", dup, true},
+		{"wrapped duplicate key", fmt.Errorf("create agent: %w", dup), true},
+		{"plain error", errors.New("boom"), false},
+	}
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			if got := isUniqueViolation(tt.err); got != tt.want {
+				t.Errorf("isUniqueViolation(%v) = %v, want %v", tt.err, got, tt.want)
+			}
+		})
+	}
+}
diff --git a/store/mongo/trait.go b/store/mongo/trait.go
@@ -20,6 +20,9 @@ func (s *Store) CreateTrait(ctx context.Context, t *trait.Trait) error {
 
 	_, err := s.mdb.NewInsert(m).Exec(ctx)
 	if err != nil {
+		if isUniqueViolation(err) {
+			return fmt.Errorf("cortex/mongo: create trait: %w", cortex.ErrAlreadyExists)
+		}
 		return fmt.Errorf("cortex/mongo: create trait: %w", err)
 	}
 
diff --git a/store/postgres/agent.go b/store/postgres/agent.go
@@ -19,6 +19,9 @@ func (s *Store) Create(ctx context.Context, config *agent.Config) error {
 	m := agentToModel(config)
 	_, err := s.pgdb.NewInsert(m).Exec(ctx)
 	if err != nil {
+		if isUniqueViolation(err) {
+			return fmt.Errorf("cortex: create agent: %w", cortex.ErrAlreadyExists)
+		}
 		return fmt.Errorf("cortex: create agent: %w", err)
 	}
 	return nil
diff --git a/store/postgres/behavior.go b/store/postgres/behavior.go
@@ -19,6 +19,9 @@ func (s *Store) CreateBehavior(ctx context.Context, b *behavior.Behavior) error
 	m := behaviorToModel(b)
 	_, err := s.pgdb.NewInsert(m).Exec(ctx)
 	if err != nil {
+		if isUniqueViolation(err) {
+			return fmt.Errorf("cortex: create behavior: %w", cortex.ErrAlreadyExists)
+		}
 		return fmt.Errorf("cortex: create behavior: %w", err)
 	}
 	return nil
diff --git a/store/postgres/orchestration.go b/store/postgres/orchestration.go
@@ -17,6 +17,9 @@ func (s *Store) CreateOrchestration(ctx context.Context, c *orchestration.Config
 	c.CreatedAt = now
 	c.UpdatedAt = now
 	if _, err := s.pgdb.NewInsert(orchestrationConfigToModel(c)).Exec(ctx); err != nil {
+		if isUniqueViolation(err) {
+			return fmt.Errorf("cortex: create orchestration: %w", cortex.ErrAlreadyExists)
+		}
 		return fmt.Errorf("cortex: create orchestration: %w", err)
 	}
 	return nil
diff --git a/store/postgres/persona.go b/store/postgres/persona.go
@@ -19,6 +19,9 @@ func (s *Store) CreatePersona(ctx context.Context, p *persona.Persona) error {
 	m := personaToModel(p)
 	_, err := s.pgdb.NewInsert(m).Exec(ctx)
 	if err != nil {
+		if isUniqueViolation(err) {
+			return fmt.Errorf("cortex: create persona: %w", cortex.ErrAlreadyExists)
+		}
 		return fmt.Errorf("cortex: create persona: %w", err)
 	}
 	return nil
diff --git a/store/postgres/skill.go b/store/postgres/skill.go
@@ -19,6 +19,9 @@ func (s *Store) CreateSkill(ctx context.Context, sk *skill.Skill) error {
 	m := skillToModel(sk)
 	_, err := s.pgdb.NewInsert(m).Exec(ctx)
 	if err != nil {
+		if isUniqueViolation(err) {
+			return fmt.Errorf("cortex: create skill: %w", cortex.ErrAlreadyExists)
+		}
 		return fmt.Errorf("cortex: create skill: %w", err)
 	}
 	return nil
diff --git a/store/postgres/store.go b/store/postgres/store.go
@@ -4,8 +4,10 @@ package postgres
 
 import (
 	"context"
+	"errors"
 	"fmt"
 
+	"github.com/jackc/pgx/v5/pgconn"
 	"github.com/xraph/grove"
 	"github.com/xraph/grove/drivers/pgdriver"
 	"github.com/xraph/grove/migrate"
@@ -51,3 +53,16 @@ func (s *Store) Ping(ctx context.Context) error {
 func (s *Store) Close() error {
 	return s.db.Close()
 }
+
+// pgUniqueViolation is the PostgreSQL SQLSTATE code for unique_violation.
+const pgUniqueViolation = "23505"
+
+// isUniqueViolation reports whether err is a PostgreSQL unique-constraint
+// violation, so callers can translate it into cortex.ErrAlreadyExists.
+func isUniqueViolation(err error) bool {
+	var pgErr *pgconn.PgError
+	if errors.As(err, &pgErr) {
+		return pgErr.Code == pgUniqueViolation
+	}
+	return false
+}
diff --git a/store/postgres/store_test.go b/store/postgres/store_test.go
@@ -0,0 +1,30 @@
+package postgres
+
+import (
+	"errors"
+	"fmt"
+	"testing"
+
+	"github.com/jackc/pgx/v5/pgconn"
+)
+
+func TestIsUniqueViolation(t *testing.T) {
+	tests := []struct {
+		name string
+		err  error
+		want bool
+	}{
+		{"nil", nil, false},
+		{"unique violation", &pgconn.PgError{Code: "23505"}, true},
+		{"wrapped unique violation", fmt.Errorf("create agent: %w", &pgconn.PgError{Code: "23505"}), true},
+		{"foreign key violation", &pgconn.PgError{Code: "23503"}, false},
+		{"plain error", errors.New("boom"), false},
+	}
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			if got := isUniqueViolation(tt.err); got != tt.want {
+				t.Errorf("isUniqueViolation(%v) = %v, want %v", tt.err, got, tt.want)
+			}
+		})
+	}
+}
diff --git a/store/postgres/trait.go b/store/postgres/trait.go
@@ -19,6 +19,9 @@ func (s *Store) CreateTrait(ctx context.Context, t *trait.Trait) error {
 	m := traitToModel(t)
 	_, err := s.pgdb.NewInsert(m).Exec(ctx)
 	if err != nil {
+		if isUniqueViolation(err) {
+			return fmt.Errorf("cortex: create trait: %w", cortex.ErrAlreadyExists)
+		}
 		return fmt.Errorf("cortex: create trait: %w", err)
 	}
 	return nil
diff --git a/store/sqlite/agent.go b/store/sqlite/agent.go
@@ -17,6 +17,9 @@ func (s *Store) Create(ctx context.Context, config *agent.Config) error {
 	m := agentToModel(config)
 	_, err := s.sdb.NewInsert(m).Exec(ctx)
 	if err != nil {
+		if isUniqueViolation(err) {
+			return fmt.Errorf("cortex/sqlite: create agent: %w", cortex.ErrAlreadyExists)
+		}
 		return fmt.Errorf("cortex/sqlite: create agent: %w", err)
 	}
 	return nil
diff --git a/store/sqlite/behavior.go b/store/sqlite/behavior.go
@@ -17,6 +17,9 @@ func (s *Store) CreateBehavior(ctx context.Context, b *behavior.Behavior) error
 	m := behaviorToModel(b)
 	_, err := s.sdb.NewInsert(m).Exec(ctx)
 	if err != nil {
+		if isUniqueViolation(err) {
+			return fmt.Errorf("cortex/sqlite: create behavior: %w", cortex.ErrAlreadyExists)
+		}
 		return fmt.Errorf("cortex/sqlite: create behavior: %w", err)
 	}
 	return nil
diff --git a/store/sqlite/orchestration.go b/store/sqlite/orchestration.go
@@ -15,6 +15,9 @@ func (s *Store) CreateOrchestration(ctx context.Context, c *orchestration.Config
 	c.CreatedAt = now
 	c.UpdatedAt = now
 	if _, err := s.sdb.NewInsert(orchestrationConfigToModel(c)).Exec(ctx); err != nil {
+		if isUniqueViolation(err) {
+			return fmt.Errorf("cortex/sqlite: create orchestration: %w", cortex.ErrAlreadyExists)
+		}
 		return fmt.Errorf("cortex/sqlite: create orchestration: %w", err)
 	}
 	return nil
diff --git a/store/sqlite/persona.go b/store/sqlite/persona.go
@@ -17,6 +17,9 @@ func (s *Store) CreatePersona(ctx context.Context, p *persona.Persona) error {
 	m := personaToModel(p)
 	_, err := s.sdb.NewInsert(m).Exec(ctx)
 	if err != nil {
+		if isUniqueViolation(err) {
+			return fmt.Errorf("cortex/sqlite: create persona: %w", cortex.ErrAlreadyExists)
+		}
 		return fmt.Errorf("cortex/sqlite: create persona: %w", err)
 	}
 	return nil
diff --git a/store/sqlite/skill.go b/store/sqlite/skill.go
@@ -17,6 +17,9 @@ func (s *Store) CreateSkill(ctx context.Context, sk *skill.Skill) error {
 	m := skillToModel(sk)
 	_, err := s.sdb.NewInsert(m).Exec(ctx)
 	if err != nil {
+		if isUniqueViolation(err) {
+			return fmt.Errorf("cortex/sqlite: create skill: %w", cortex.ErrAlreadyExists)
+		}
 		return fmt.Errorf("cortex/sqlite: create skill: %w", err)
 	}
 	return nil
diff --git a/store/sqlite/store.go b/store/sqlite/store.go
diff --git a/store/sqlite/store_test.go b/store/sqlite/store_test.go
diff --git a/store/sqlite/trait.go b/store/sqlite/trait.go

Original file line number	Diff line number	Diff line change
`@@ -20,6 +20,9 @@ func (s Store) Create(ctx context.Context, config agent.Config) error {`
`20`	`20`
`21`	`21`	`_, err := s.mdb.NewInsert(m).Exec(ctx)`
`22`	`22`	`if err != nil {`
	`23`	`+ if isUniqueViolation(err) {`
	`24`	`+ return fmt.Errorf("cortex/mongo: create agent: %w", cortex.ErrAlreadyExists)`
	`25`	`+ }`
`23`	`26`	`return fmt.Errorf("cortex/mongo: create agent: %w", err)`
`24`	`27`	`}`
`25`	`28`
Original file line number	Diff line number	Diff line change
`@@ -18,6 +18,9 @@ func (s Store) CreateOrchestration(ctx context.Context, c orchestration.Config`
`18`	`18`	`c.UpdatedAt = t`
`19`	`19`
`20`	`20`	`if _, err := s.mdb.NewInsert(orchestrationConfigToModel(c)).Exec(ctx); err != nil {`
	`21`	`+ if isUniqueViolation(err) {`
	`22`	`+ return fmt.Errorf("cortex/mongo: create orchestration: %w", cortex.ErrAlreadyExists)`
	`23`	`+ }`
`21`	`24`	`return fmt.Errorf("cortex/mongo: create orchestration: %w", err)`
`22`	`25`	`}`
`23`	`26`