Method GetMonitorByID

database/balance.go:1176–1207

GetMonitorByID retrieves a BalanceMonitor by its unique MonitorID from the database. It queries the `ledgerforge.balance_monitors` table and maps the result into a model.BalanceMonitor object. Parameters: - id: The MonitorID of the monitor to retrieve. Returns: - *model.BalanceMonitor: A pointer t

(id string)

// - *model.BalanceMonitor: A pointer to the BalanceMonitor object if found.
// - error: If the monitor is not found or if any errors occur during the query, an `APIError` is returned.
func (d Datasource) GetMonitorByID(id string) (*model.BalanceMonitor, error) {
	var preciseValue int64 // Temporary variable to hold the precise value as int64

	// Query the database to get the monitor details by MonitorID
	row := d.Conn.QueryRowContext(context.Background(), `
		SELECT monitor_id, balance_id, field, operator, value, precision, precise_value, description, call_back_url, created_at
		FROM ledgerforge.balance_monitors WHERE monitor_id = $1
	`, id)

	// Initialize an empty BalanceMonitor object
	monitor := &model.BalanceMonitor{}
	// Initialize an empty AlertCondition object (part of the monitor)
	condition := &model.AlertCondition{}

	// Scan the result into the monitor and condition fields
	err := row.Scan(&monitor.MonitorID, &monitor.BalanceID, &condition.Field, &condition.Operator, &condition.Value, &condition.Precision, &preciseValue, &monitor.Description, &monitor.CallBackURL, &monitor.CreatedAt)
	if err != nil {
		// Handle the case where the monitor with the specified ID is not found
		if err == sql.ErrNoRows {
			return nil, apierror.NewAPIError(apierror.ErrNotFound, fmt.Sprintf("Monitor with ID '%s' not found", id), err)
		}
		// Return an internal server error for other query issues
		return nil, apierror.NewAPIError(apierror.ErrInternalServer, "Failed to retrieve monitor", err)
	}

	// Populate the PreciseValue field in the condition (convert from int64 to big.Int)
	monitor.Condition = *condition
	monitor.Condition.PreciseValue = big.NewInt(preciseValue)

	// Return the populated BalanceMonitor object
	return monitor, nil
}

// GetAllMonitors retrieves all balance monitors from the database.
// It queries the `ledgerforge.balance_monitors` table and returns a list of all monitors.