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) {