forked from github-starred/komodo
alert logger 7000. fix alert open when empty
This commit is contained in:
@@ -11,6 +11,6 @@ FROM gcr.io/distroless/cc
|
||||
|
||||
COPY --from=builder /builder/target/release/alert_logger /
|
||||
|
||||
EXPOSE 7777
|
||||
EXPOSE 7000
|
||||
|
||||
CMD ["./alert_logger"]
|
||||
@@ -11,7 +11,7 @@ use termination_signal::tokio::immediate_term_handle;
|
||||
async fn app() -> anyhow::Result<()> {
|
||||
logger::init(log::LevelFilter::Info)?;
|
||||
|
||||
let socket_addr = SocketAddr::from_str("0.0.0.0:7777").unwrap();
|
||||
let socket_addr = SocketAddr::from_str("0.0.0.0:7000").unwrap();
|
||||
|
||||
info!(
|
||||
"v {} | {socket_addr}",
|
||||
|
||||
@@ -13,6 +13,10 @@ use crate::state::State;
|
||||
|
||||
impl State {
|
||||
pub async fn send_alerts(&self, alerts: &[Alert]) {
|
||||
if alerts.is_empty() {
|
||||
return;
|
||||
}
|
||||
|
||||
let alerters = self.db.alerters.get_some(None, None).await;
|
||||
|
||||
if let Err(e) = alerters {
|
||||
@@ -29,6 +33,10 @@ impl State {
|
||||
}
|
||||
|
||||
async fn send_alert(alerters: &[Alerter], alert: &Alert) {
|
||||
if alerters.is_empty() {
|
||||
return;
|
||||
}
|
||||
|
||||
let handles = alerters.iter().map(|alerter| async {
|
||||
match &alerter.config {
|
||||
AlerterConfig::Slack(SlackAlerterConfig { url }) => send_slack_alert(url, alert)
|
||||
|
||||
@@ -390,6 +390,10 @@ impl State {
|
||||
}
|
||||
|
||||
async fn open_alerts(&self, alerts: &[Alert]) {
|
||||
if alerts.is_empty() {
|
||||
return;
|
||||
}
|
||||
|
||||
let open = || async {
|
||||
self.db.alerts.create_many(alerts).await?;
|
||||
anyhow::Ok(())
|
||||
@@ -403,6 +407,10 @@ impl State {
|
||||
}
|
||||
|
||||
async fn update_alerts(&self, alerts: &[Alert]) {
|
||||
if alerts.is_empty() {
|
||||
return;
|
||||
}
|
||||
|
||||
let open = || async {
|
||||
let updates = alerts.iter().map(|alert| {
|
||||
let update = BulkUpdate {
|
||||
@@ -427,6 +435,10 @@ impl State {
|
||||
}
|
||||
|
||||
async fn resolve_alerts(&self, alert_ids: &[String]) {
|
||||
if alert_ids.is_empty() {
|
||||
return;
|
||||
}
|
||||
|
||||
let close = || async {
|
||||
let alert_ids = alert_ids
|
||||
.iter()
|
||||
|
||||
Reference in New Issue
Block a user