Function TestCreateMonitor_Success

database/balance_test.go:1119–1154

(t *testing.T)

}

func TestCreateMonitor_Success(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_123",
		Description: "Low balance alert",
		CallBackURL: "https://example.com/webhook",
		Condition: model.AlertCondition{
			Field:        "balance",
			Operator:     "<",
			Value:        1000,
			Precision:    100,
			PreciseValue: big.NewInt(100000),
		},
	}

	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, monitor.Condition.Precision, monitor.Condition.PreciseValue.String(), monitor.Description, monitor.CallBackURL, sqlmock.AnyArg()).
		WillReturnResult(sqlmock.NewResult(1, 1))

	createdMonitor, err := ds.CreateMonitor(monitor)
	assert.NoError(t, err)
	assert.NotEmpty(t, createdMonitor.MonitorID)
	assert.True(t, len(createdMonitor.MonitorID) > 0)
	assert.Equal(t, monitor.BalanceID, createdMonitor.BalanceID)

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

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