Function TestReconciliationEdgeCases

reconciliation_test.go:389–478

TestReconciliationEdgeCases tests edge cases in the reconciliation process

(t *testing.T)

// TestReconciliationEdgeCases tests edge cases in the reconciliation process
func TestReconciliationEdgeCases(t *testing.T) {
	cnf := &config.Configuration{
		Redis: config.RedisConfig{
			Dns: "localhost:6379",
		},
		Transaction: config.TransactionConfig{
			BatchSize:  100000,
			MaxWorkers: 1,
		},
		Queue: config.QueueConfig{
			WebhookQueue:   "webhook_queue",
			NumberOfQueues: 1,
		},
		Reconciliation: config.ReconciliationConfig{
			ProgressInterval: 100,
		},
	}
	config.ConfigStore.Store(cnf)
	mockDS := new(mocks.MockDataSource)

	ledgerforge := &LedgerForge{datasource: mockDS}

	ctx := context.Background()

	t.Run("Empty external transactions", func(t *testing.T) {
		externalTxns := []*model.Transaction{}
		matchingRules := []model.MatchingRule{
			{
				RuleID: "rule1",
				Criteria: []model.MatchingCriteria{
					{Field: "amount", Operator: "equals", AllowableDrift: 0},
				},
			},
		}

		matches, unmatched := ledgerforge.oneToOneReconciliation(ctx, externalTxns, matchingRules)

		assert.Equal(t, 0, len(matches), "Expected 0 matches")
		assert.Equal(t, 0, len(unmatched), "Expected 0 unmatched transactions")
	})

	t.Run("No matching internal transactions", func(t *testing.T) {
		externalTxns := []*model.Transaction{
			{TransactionID: "ext1", Amount: 100, CreatedAt: time.Now()},
		}

		mockDS.On("GetTransactionsByCriteria", mock.Anything, mock.Anything, mock.Anything, mock.Anything, mock.Anything, mock.Anything, 100000, int64(0)).Return([]*model.Transaction{}, nil).Once()

		matchingRules := []model.MatchingRule{
			{
				RuleID: "rule1",
				Criteria: []model.MatchingCriteria{
					{Field: "amount", Operator: "equals", AllowableDrift: 0},
				},
			},
		}

		matches, unmatched := ledgerforge.oneToOneReconciliation(ctx, externalTxns, matchingRules)