Method DeleteMonitor

database/balance.go:1359–1383

DeleteMonitor deletes a balance monitor from the database by its monitor ID. It removes the monitor from the `ledgerforge.balance_monitors` table. Parameters: - id: The ID of the monitor to be deleted. Returns: - error: If the deletion fails or the monitor is not found, an appropriate `APIError` i

(id string)

// Returns:
// - error: If the deletion fails or the monitor is not found, an appropriate `APIError` is returned.
func (d Datasource) DeleteMonitor(id string) error {
	// Execute the SQL DELETE statement, removing the monitor by its ID
	result, err := d.Conn.ExecContext(context.Background(), `
		DELETE FROM ledgerforge.balance_monitors WHERE monitor_id = $1
	`, id)
	// If an error occurred during execution, return an internal server error
	if err != nil {
		return apierror.NewAPIError(apierror.ErrInternalServer, "Failed to delete monitor", err)
	}

	// Check how many rows were affected by the delete operation
	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", id), nil)
	}

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

// TakeBalanceSnapshots creates daily snapshots of balances in batches.
// It uses the PostgreSQL function to process balances in chunks to avoid memory issues