Method UpdateMonitor

database/balance.go:1323–1349

UpdateMonitor updates an existing balance monitor in the database. It updates fields such as `balance_id`, `field`, `operator`, `value`, `description`, and `call_back_url` for the monitor identified by `monitor_id`. Parameters: - monitor: A pointer to the `BalanceMonitor` object containing the upda

(monitor *model.BalanceMonitor)

// Returns:
// - error: If the update fails, an appropriate `APIError` is returned.
func (d Datasource) UpdateMonitor(monitor *model.BalanceMonitor) error {
	// Execute the SQL update statement, replacing the placeholder values with the monitor's data
	result, err := d.Conn.ExecContext(context.Background(), `
		UPDATE ledgerforge.balance_monitors
		SET balance_id = $2, field = $3, operator = $4, value = $5, description = $6, call_back_url = $7
		WHERE monitor_id = $1
	`, monitor.MonitorID, monitor.BalanceID, monitor.Condition.Field, monitor.Condition.Operator, monitor.Condition.Value, monitor.Description, monitor.CallBackURL)
	// If an error occurred during execution, return an internal server error
	if err != nil {
		return apierror.NewAPIError(apierror.ErrInternalServer, "Failed to update monitor", err)
	}

	// Check how many rows were affected by the update
	rowsAffected, err := result.RowsAffected()
	if err != nil {
		// If an error occurred while checking rows affected, return an internal server error
		return apierror.NewAPIError(apierror.ErrInternalServer, "Failed to get rows affected", err)
	}

	// If no rows were affected, return a not found error indicating the monitor does not exist
	if rowsAffected == 0 {
		return apierror.NewAPIError(apierror.ErrNotFound, fmt.Sprintf("Monitor with ID '%s' not found", monitor.MonitorID), nil)
	}

	// Return nil if the update was successful
	return nil
}

// DeleteMonitor deletes a balance monitor from the database by its monitor ID.
// It removes the monitor from the `ledgerforge.balance_monitors` table.