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