From a6564b326d84fc6e146d7f3e501adaaeecd1e1a7 Mon Sep 17 00:00:00 2001
From: Egor Baranov <49813134+egor-baranov@users.noreply.github.com>
Date: Mon, 23 Mar 2026 14:33:21 +0100
Subject: [PATCH] Rename observer package identifier and update references

---
 api/server.go                      | 4 ++--
 cmd/agentd-api/main.go             | 6 +++---
 cmd/agentd-worker/main.go          | 4 ++--
 obs/obs.go => observer/observer.go | 2 +-
 test/e2e/server_test.go            | 4 ++--
 test/e2e/sse_test.go               | 4 ++--
 6 files changed, 12 insertions(+), 12 deletions(-)
 rename obs/obs.go => observer/observer.go (98%)

diff --git a/api/server.go b/api/server.go
index 9ab6268..665c895 100644
--- a/api/server.go
+++ b/api/server.go
@@ -12,7 +12,7 @@ import (
 	"time"
 
 	"agentd/control"
-	"agentd/obs"
+	"agentd/observer"
 	"agentd/session"
 	"agentd/store"
 	"agentd/workflows"
@@ -21,7 +21,7 @@ import (
 
 type Server struct {
 	Logger     *slog.Logger
-	Metrics    *obs.Metrics
+	Metrics    *observer.Metrics
 	Temporal   workflows.Client
 	Registry   store.RegistryStore
 	Bundles    store.BundleStore
diff --git a/cmd/agentd-api/main.go b/cmd/agentd-api/main.go
index 23cddef..110c6ef 100644
--- a/cmd/agentd-api/main.go
+++ b/cmd/agentd-api/main.go
@@ -7,7 +7,7 @@ import (
 	"time"
 
 	"agentd/api"
-	"agentd/obs"
+	"agentd/observer"
 	"agentd/registry"
 	runtimeclient "agentd/runtime"
 	"agentd/scheduler"
@@ -19,8 +19,8 @@ import (
 
 func main() {
 	ctx := context.Background()
-	logger := obs.NewLogger("agentd-api")
-	metrics := obs.NewMetrics()
+	logger := observer.NewLogger("agentd-api")
+	metrics := observer.NewMetrics()
 	meta, err := store.Open(ctx, os.Getenv("DATABASE_URL"), getenv("AGENTD_ARTIFACT_DIR", "./var/artifacts"))
 	if err != nil {
 		logger.Error("open store", "error", err)
diff --git a/cmd/agentd-worker/main.go b/cmd/agentd-worker/main.go
index be63a6b..6c08ca4 100644
--- a/cmd/agentd-worker/main.go
+++ b/cmd/agentd-worker/main.go
@@ -5,7 +5,7 @@ import (
 	"os"
 
 	"agentd/control"
-	"agentd/obs"
+	"agentd/observer"
 	"agentd/registry"
 	runtimeclient "agentd/runtime"
 	"agentd/session"
@@ -17,7 +17,7 @@ import (
 
 func main() {
 	ctx := context.Background()
-	logger := obs.NewLogger("agentd-worker")
+	logger := observer.NewLogger("agentd-worker")
 	meta, err := store.Open(ctx, os.Getenv("DATABASE_URL"), getenv("AGENTD_ARTIFACT_DIR", "./var/artifacts"))
 	if err != nil {
 		logger.Error("open store", "error", err)
diff --git a/obs/obs.go b/observer/observer.go
similarity index 98%
rename from obs/obs.go
rename to observer/observer.go
index a15856f..87e06bf 100644
--- a/obs/obs.go
+++ b/observer/observer.go
@@ -1,4 +1,4 @@
-package obs
+package observer
 
 import (
 	"log/slog"
diff --git a/test/e2e/server_test.go b/test/e2e/server_test.go
index 4c4dc4d..1e939f3 100644
--- a/test/e2e/server_test.go
+++ b/test/e2e/server_test.go
@@ -10,7 +10,7 @@ import (
 
 	"agentd/api"
 	"agentd/control"
-	"agentd/obs"
+	"agentd/observer"
 	"agentd/store"
 )
 
@@ -25,7 +25,7 @@ func TestServerHealthAndRegistryList(t *testing.T) {
 	}
 
 	srv := httptest.NewServer((&api.Server{
-		Metrics:  obs.NewMetrics(),
+		Metrics:  observer.NewMetrics(),
 		Registry: mem,
 	}).Handler())
 	defer srv.Close()
diff --git a/test/e2e/sse_test.go b/test/e2e/sse_test.go
index 1345a1c..bab7725 100644
--- a/test/e2e/sse_test.go
+++ b/test/e2e/sse_test.go
@@ -10,13 +10,13 @@ import (
 	"time"
 
 	"agentd/api"
-	"agentd/obs"
+	"agentd/observer"
 	"agentd/session"
 )
 
 func TestSessionEventsSSE(t *testing.T) {
 	broker := session.NewMemoryBroker()
-	srv := httptest.NewServer((&api.Server{Metrics: obs.NewMetrics(), Broker: broker}).Handler())
+	srv := httptest.NewServer((&api.Server{Metrics: observer.NewMetrics(), Broker: broker}).Handler())
 	defer srv.Close()
 
 	ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)