Function TestRecordMatches_Success

database/reconciliation_test.go:215–252

(t *testing.T)

}

func TestRecordMatches_Success(t *testing.T) {
	db, mock, err := sqlmock.New()
	assert.NoError(t, err)
	defer func() { _ = db.Close() }()

	ds := Datasource{Conn: db}
	ctx := context.TODO()

	matches := []model.Match{
		{
			ExternalTransactionID: "ext1",
			InternalTransactionID: "int1",
			ReconciliationID:      "rec123",
			Amount:                1000,
			Date:                  time.Now(),
		},
		{
			ExternalTransactionID: "ext2",
			InternalTransactionID: "int2",
			ReconciliationID:      "rec123",
			Amount:                2000,
			Date:                  time.Now(),
		},
	}

	mock.ExpectBegin()

	for _, match := range matches {
		mock.ExpectExec("INSERT INTO ledgerforge.matches").
			WithArgs(match.ExternalTransactionID, match.InternalTransactionID, match.ReconciliationID, match.Amount, match.Date).
			WillReturnResult(sqlmock.NewResult(1, 1))
	}

	mock.ExpectCommit()

	err = ds.RecordMatches(ctx, "rec123", matches)
	assert.NoError(t, err)
}

func TestRecordMatches_Fail(t *testing.T) {
	db, mock, err := sqlmock.New()