From 065c99a5117695120bd2fdd502395f361b767fbb Mon Sep 17 00:00:00 2001 From: Bretton May Date: Sun, 5 Oct 2025 19:56:51 -0700 Subject: [PATCH] refactor: Move jetstream to internal/atproto/jetstream MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Groups all atProto-related code under internal/atproto/ for better code organization: internal/ ├── atproto/ │ ├── lexicon/ # Protocol definitions │ └── jetstream/ # Firehose consumer ├── core/ # Business logic └── db/ # Persistence Changes: - Moved internal/jetstream/ → internal/atproto/jetstream/ - Updated import paths in cmd/server/main.go - Updated import paths in all test files All tests passing: ✅ Unit tests ✅ Integration tests ✅ E2E tests 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude --- cmd/server/main.go | 2 +- internal/{ => atproto}/jetstream/user_consumer.go | 0 tests/e2e/user_signup_test.go | 2 +- tests/integration/jetstream_consumer_test.go | 2 +- 4 files changed, 3 insertions(+), 3 deletions(-) rename internal/{ => atproto}/jetstream/user_consumer.go (100%) diff --git a/cmd/server/main.go b/cmd/server/main.go index dbd59c4..c4ca824 100644 --- a/cmd/server/main.go +++ b/cmd/server/main.go @@ -16,9 +16,9 @@ import ( "Coves/internal/api/middleware" "Coves/internal/api/routes" + "Coves/internal/atproto/jetstream" "Coves/internal/core/users" postgresRepo "Coves/internal/db/postgres" - "Coves/internal/jetstream" ) func main() { diff --git a/internal/jetstream/user_consumer.go b/internal/atproto/jetstream/user_consumer.go similarity index 100% rename from internal/jetstream/user_consumer.go rename to internal/atproto/jetstream/user_consumer.go diff --git a/tests/e2e/user_signup_test.go b/tests/e2e/user_signup_test.go index 64b25f2..053d03c 100644 --- a/tests/e2e/user_signup_test.go +++ b/tests/e2e/user_signup_test.go @@ -11,9 +11,9 @@ import ( "testing" "time" + "Coves/internal/atproto/jetstream" "Coves/internal/core/users" "Coves/internal/db/postgres" - "Coves/internal/jetstream" _ "github.com/lib/pq" "github.com/pressly/goose/v3" ) diff --git a/tests/integration/jetstream_consumer_test.go b/tests/integration/jetstream_consumer_test.go index 006f9a6..f44c7a6 100644 --- a/tests/integration/jetstream_consumer_test.go +++ b/tests/integration/jetstream_consumer_test.go @@ -5,9 +5,9 @@ import ( "testing" "time" + "Coves/internal/atproto/jetstream" "Coves/internal/core/users" "Coves/internal/db/postgres" - "Coves/internal/jetstream" ) func TestUserIndexingFromJetstream(t *testing.T) { -- 2.51.2