Fix badger GetTradeBySwapAcceptId

tdex-network · Dec 22, 2022 · 5f1e161 · 5f1e161
1 parent e175c5d
commit 5f1e161
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/internal/infrastructure/storage/db/badger/trade_repository_impl.go b/internal/infrastructure/storage/db/badger/trade_repository_impl.go
@@ -68,7 +68,12 @@ func (t tradeRepositoryImpl) GetCompletedTradesByMarket(
 func (t tradeRepositoryImpl) GetTradeBySwapAcceptId(
 	ctx context.Context, swapAcceptId string,
 ) (*domain.Trade, error) {
-	query := badgerhold.Where("SwapAccept.Id").Eq(swapAcceptId)
+	query := badgerhold.Where("SwapAccept").MatchFunc(
+		func(ra *badgerhold.RecordAccess) (bool, error) {
+			swapAccept := ra.Field().(*domain.Swap)
+			return swapAccept != nil && swapAccept.Id == swapAcceptId, nil
+		},
+	)
 
 	trades, err := t.findTrades(ctx, query)
 	if err != nil {