Function TestCreateMonitor_ForeignKeyViolation

database/balance_test.go:1189–1220

(t *testing.T)

}

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

	ds := Datasource{Conn: db}

	monitor := model.BalanceMonitor{
		BalanceID: "bln_nonexistent",
		Condition: model.AlertCondition{
			Field:    "balance",
			Operator: "<",
			Value:    1000,
		},
	}

	mock.ExpectExec(regexp.QuoteMeta(`
		INSERT INTO ledgerforge.balance_monitors (monitor_id, balance_id, field, operator, value, precision, precise_value, description, call_back_url, created_at)
		VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10)
	`)).
		WithArgs(sqlmock.AnyArg(), monitor.BalanceID, monitor.Condition.Field, monitor.Condition.Operator, monitor.Condition.Value, sqlmock.AnyArg(), sqlmock.AnyArg(), sqlmock.AnyArg(), sqlmock.AnyArg(), sqlmock.AnyArg()).
		WillReturnError(&pq.Error{Code: "23503", Message: "foreign_key_violation"})

	_, err = ds.CreateMonitor(monitor)
	assert.Error(t, err)
	apiErr, ok := err.(apierror.APIError)
	assert.True(t, ok)
	assert.Equal(t, apierror.ErrBadRequest, apiErr.Code)

	err = mock.ExpectationsWereMet()
	assert.NoError(t, err)
}

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