diff options
author | 2024-08-05 19:17:24 -0700 | |
---|---|---|
committer | 2024-08-05 19:17:24 -0700 | |
commit | 63e70075365bbfaeb7cd91572f881c2114307dfd (patch) | |
tree | 115cbca886240a118eaea7150892a57f08d56f5d /backend/internal/server2 | |
parent | 739eba1a2e3a8ea806de41b96da79ae06a8445b2 (diff) | |
download | ibd-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.go | 7 |
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) { |