fix: tests

Signed-off-by: Lawrence Zawila <113581282+darkmatterpool@users.noreply.github.com>

Makefile

@@ -7,3 +7,6 @@ lint:
 lint-fix:
 	golangci-lint run --fix
 
+run-tests:
+	go test -race -count=1 ./...
+

internal/pkg/ingestion/ingester.go

@@ -74,13 +74,13 @@ func (i *DefaultIngester) processBatch(ctx context.Context, batch Batch) ([]paym
 					Referenced: elem.Referenced,
 					Provider:   i.provider,
 				})
-			if ret.Err() != nil && errors.Is(ret.Err(), mongo.ErrNoDocuments) {
+			if ret.Err() != nil && !errors.Is(ret.Err(), mongo.ErrNoDocuments) {
 				logger.Errorf("Error retrieving payment: %s", ret.Err())
 
 				return nil, fmt.Errorf("error retrieving payment: %w", ret.Err())
 			}
 
-			if ret.Err() == nil {
+			if ret != nil && ret.Err() == nil {
 				payment := payments.Payment{}
 
 				err := ret.Decode(&payment)
@@ -94,8 +94,6 @@ func (i *DefaultIngester) processBatch(ctx context.Context, batch Batch) ([]paym
 			}
 		}
 
-		var err error
-
 		switch {
 		case elem.Forward && elem.Adjustment != nil:
 			update = bson.M{

internal/pkg/ingestion/ingester_test.go

@@ -26,6 +26,14 @@ func TestIngester(t *testing.T) {
 		ingester := NewDefaultIngester(provider, uuid.New(), mt.DB, sharedlogging.NewNoOpLogger(), nil)
 
 		mt.AddMockResponses(
+			mtest.CreateCursorResponse(1, "test.test", mtest.FirstBatch, bson.D{
+				{Key: "ok", Value: 1},
+				{Key: "value", Value: bson.D{}},
+			}),
+			bson.D{
+				{Key: "ok", Value: 1},
+				{Key: "value", Value: bson.D{}},
+			}, // Find payment update
 			bson.D{
 				{Key: "ok", Value: 1},
 				{Key: "value", Value: bson.D{}},
@@ -51,6 +59,7 @@ func TestIngester(t *testing.T) {
 		}, State{
 			Counter: 1,
 		})
+
 		require.NoError(t, err)
 	})
 }