Function TestRecordMatches_Fail

database/reconciliation_test.go:254–281

(t *testing.T)

}

func TestRecordMatches_Fail(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(),
		},
	}

	mock.ExpectBegin()
	mock.ExpectExec("INSERT INTO ledgerforge.matches").
		WithArgs(matches[0].ExternalTransactionID, matches[0].InternalTransactionID, matches[0].ReconciliationID, matches[0].Amount, matches[0].Date).
		WillReturnError(fmt.Errorf("failed to insert match"))
	mock.ExpectRollback()

	err = ds.RecordMatches(ctx, "rec123", matches)
	assert.Error(t, err)
	assert.Equal(t, apierror.ErrInternalServer, err.(apierror.APIError).Code)
}

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