diff options
Diffstat (limited to 'backend/internal/server/server.go')
| -rw-r--r-- | backend/internal/server/server.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/backend/internal/server/server.go b/backend/internal/server/server.go index 133deb7..c46a629 100644 --- a/backend/internal/server/server.go +++ b/backend/internal/server/server.go @@ -10,6 +10,7 @@ import ( spb "github.com/ansg191/ibd-trader-backend/api/gen/idb/stock/v1" upb "github.com/ansg191/ibd-trader-backend/api/gen/idb/user/v1" "github.com/ansg191/ibd-trader-backend/internal/database" + "github.com/ansg191/ibd-trader-backend/internal/ibd" "github.com/ansg191/ibd-trader-backend/internal/leader/manager/ibd/scrape" "github.com/ansg191/ibd-trader-backend/internal/redis/taskqueue" "github.com/ansg191/ibd-trader-backend/internal/server/idb/stock/v1" @@ -31,6 +32,7 @@ func New( port uint16, db database.Database, rClient *redis.Client, + client *ibd.Client, ) (*Server, error) { scrapeQueue, err := taskqueue.New( ctx, @@ -43,7 +45,7 @@ func New( } s := grpc.NewServer() - upb.RegisterUserServiceServer(s, user.New(db)) + upb.RegisterUserServiceServer(s, user.New(db, client)) spb.RegisterStockServiceServer(s, stock.New(db, scrapeQueue)) longrunningpb.RegisterOperationsServer(s, newOperationServer(scrapeQueue)) reflection.Register(s) |