37ff644aa7
- #1: remove mock alert events that poisoned production responses - #2: add Notifier interface + Send implementations for all channels - #3/#4: notification goroutines now carry a 30s context timeout and retry up to 3x with exponential backoff - #5: schedule email digest in poller via DIGEST_INTERVAL_HOURS (default 24h) - #6: SystemStatus queries real checkpoint data; returns starting/active/idle with latestBlock and lag - #7: Ethereum RPC client retries on network errors, 429, and 5xx with 1s/2s backoff - #8: alert_events dedup index + ON CONFLICT DO NOTHING to prevent duplicate events on poller restart - #9: PATCH /v1/addresses/{id} for label editing; frontend address list gains inline edit and remove buttons
89 lines
2.4 KiB
Go
89 lines
2.4 KiB
Go
package models
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
|
|
"github.com/jackc/pgx/v5"
|
|
"github.com/jackc/pgx/v5/pgxpool"
|
|
"github.com/kjannette/koin-ping/backend-go/internal/domain"
|
|
)
|
|
|
|
type AlertEventModel struct {
|
|
pool *pgxpool.Pool
|
|
}
|
|
|
|
func NewAlertEventModel(pool *pgxpool.Pool) *AlertEventModel {
|
|
return &AlertEventModel{pool: pool}
|
|
}
|
|
|
|
func (m *AlertEventModel) ListRecentByUser(ctx context.Context, userID string, limit int) ([]domain.AlertEvent, error) {
|
|
rows, err := m.pool.Query(ctx,
|
|
`SELECT ae.id, ae.alert_rule_id, ae.message, ae.address_label, ae.tx_hash, ae.timestamp
|
|
FROM alert_events ae
|
|
JOIN alert_rules ar ON ar.id = ae.alert_rule_id
|
|
JOIN addresses a ON a.id = ar.address_id
|
|
WHERE a.user_id = $1
|
|
ORDER BY ae.timestamp DESC
|
|
LIMIT $2`,
|
|
userID, limit,
|
|
)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
defer rows.Close()
|
|
|
|
var events []domain.AlertEvent
|
|
for rows.Next() {
|
|
var e domain.AlertEvent
|
|
if err := rows.Scan(&e.ID, &e.AlertRuleID, &e.Message, &e.AddressLabel, &e.TxHash, &e.Timestamp); err != nil {
|
|
return nil, err
|
|
}
|
|
events = append(events, e)
|
|
}
|
|
return events, rows.Err()
|
|
}
|
|
|
|
func (m *AlertEventModel) ListRecent(ctx context.Context, limit int) ([]domain.AlertEvent, error) {
|
|
rows, err := m.pool.Query(ctx,
|
|
`SELECT id, alert_rule_id, message, address_label, tx_hash, timestamp
|
|
FROM alert_events
|
|
ORDER BY timestamp DESC
|
|
LIMIT $1`,
|
|
limit,
|
|
)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
defer rows.Close()
|
|
|
|
var events []domain.AlertEvent
|
|
for rows.Next() {
|
|
var e domain.AlertEvent
|
|
if err := rows.Scan(&e.ID, &e.AlertRuleID, &e.Message, &e.AddressLabel, &e.TxHash, &e.Timestamp); err != nil {
|
|
return nil, err
|
|
}
|
|
events = append(events, e)
|
|
}
|
|
return events, rows.Err()
|
|
}
|
|
|
|
func (m *AlertEventModel) Create(ctx context.Context, alertRuleID int, message string, addressLabel *string, txHash *string) (*domain.AlertEvent, error) {
|
|
var e domain.AlertEvent
|
|
err := m.pool.QueryRow(ctx,
|
|
`INSERT INTO alert_events (alert_rule_id, message, address_label, tx_hash)
|
|
VALUES ($1, $2, $3, $4)
|
|
ON CONFLICT DO NOTHING
|
|
RETURNING id, alert_rule_id, message, address_label, tx_hash, timestamp`,
|
|
alertRuleID, message, addressLabel, txHash,
|
|
).Scan(&e.ID, &e.AlertRuleID, &e.Message, &e.AddressLabel, &e.TxHash, &e.Timestamp)
|
|
if err != nil {
|
|
if errors.Is(err, pgx.ErrNoRows) {
|
|
// Duplicate silently skipped by ON CONFLICT DO NOTHING
|
|
return nil, nil
|
|
}
|
|
return nil, err
|
|
}
|
|
return &e, nil
|
|
}
|