commit 065c99a5117695120bd2fdd502395f361b767fbb · bretton.dev/coves

+1 -1

cmd/server/main.go

···

       16
       16
        
       

     

       17
       17
        
       	"Coves/internal/api/middleware"

     

       18
       18
        
       	"Coves/internal/api/routes"

     

       19
       19
       +
       	"Coves/internal/atproto/jetstream"

     

       19
       20
        
       	"Coves/internal/core/users"

     

       20
       21
        
       	postgresRepo "Coves/internal/db/postgres"

     

       21
       21
       -
       	"Coves/internal/jetstream"

     

       22
       22
        
       )

     

       23
       23
        
       

     

       24
       24
        
       func main() {

internal/jetstream/user_consumer.go internal/atproto/jetstream/user_consumer.go

+1 -1

tests/e2e/user_signup_test.go

···

       11
       11
        
       	"testing"

     

       12
       12
        
       	"time"

     

       13
       13
        
       

     

       14
       14
       +
       	"Coves/internal/atproto/jetstream"

     

       14
       15
        
       	"Coves/internal/core/users"

     

       15
       16
        
       	"Coves/internal/db/postgres"

     

       16
       16
       -
       	"Coves/internal/jetstream"

     

       17
       17
        
       	_ "github.com/lib/pq"

     

       18
       18
        
       	"github.com/pressly/goose/v3"

     

       19
       19
        
       )

+1 -1

tests/integration/jetstream_consumer_test.go

···

       5
       5
        
       	"testing"

     

       6
       6
        
       	"time"

     

       7
       7
        
       

     

       8
       8
       +
       	"Coves/internal/atproto/jetstream"

     

       8
       9
        
       	"Coves/internal/core/users"

     

       9
       10
        
       	"Coves/internal/db/postgres"

     

       10
       10
       -
       	"Coves/internal/jetstream"

     

       11
       11
        
       )

     

       12
       12
        
       

     

       13
       13
        
       func TestUserIndexingFromJetstream(t *testing.T) {