aboutsummaryrefslogtreecommitdiff
path: root/backend/internal/server2
diff options
context:
space:
mode:
authorGravatar Anshul Gupta <ansg191@anshulg.com> 2024-08-05 19:17:24 -0700
committerGravatar Anshul Gupta <ansg191@anshulg.com> 2024-08-05 19:17:24 -0700
commit63e70075365bbfaeb7cd91572f881c2114307dfd (patch)
tree115cbca886240a118eaea7150892a57f08d56f5d /backend/internal/server2
parent739eba1a2e3a8ea806de41b96da79ae06a8445b2 (diff)
downloadibd-trader-63e70075365bbfaeb7cd91572f881c2114307dfd.tar.gz
ibd-trader-63e70075365bbfaeb7cd91572f881c2114307dfd.tar.zst
ibd-trader-63e70075365bbfaeb7cd91572f881c2114307dfd.zip
Fix lint issues
Diffstat (limited to 'backend/internal/server2')
-rw-r--r--backend/internal/server2/idb/stock/v1/stock.go7
1 files changed, 4 insertions, 3 deletions
diff --git a/backend/internal/server2/idb/stock/v1/stock.go b/backend/internal/server2/idb/stock/v1/stock.go
index 3a94c82..30f0991 100644
--- a/backend/internal/server2/idb/stock/v1/stock.go
+++ b/backend/internal/server2/idb/stock/v1/stock.go
@@ -30,7 +30,7 @@ func New(db database.StockStore, queue taskqueue.TaskQueue[scrape.TaskInfo]) *Se
return &Server{db: db, queue: queue}
}
-func (s *Server) CreateStock(ctx context.Context, request *pb.CreateStockRequest) (*longrunningpb.Operation, error) {
+func (s *Server) CreateStock(ctx context.Context, request *pb.CreateStockRequest) (*pb.CreateStockResponse, error) {
task, err := s.queue.Enqueue(ctx, scrape.TaskInfo{Symbol: request.Symbol})
if err != nil {
slog.ErrorContext(ctx, "failed to enqueue task", "err", err)
@@ -50,11 +50,12 @@ func (s *Server) CreateStock(ctx context.Context, request *pb.CreateStockRequest
slog.ErrorContext(ctx, "failed to marshal metadata", "err", err)
return nil, status.New(codes.Internal, "failed to marshal metadata").Err()
}
- return op, nil
+ return &pb.CreateStockResponse{Operation: op}, nil
}
func (s *Server) GetStock(ctx context.Context, request *pb.GetStockRequest) (*pb.GetStockResponse, error) {
-
+ //TODO implement me
+ panic("implement me")
}
func (s *Server) ListStocks(ctx context.Context, request *pb.ListStocksRequest) (*pb.ListStocksResponse, error) {