ComputerSurge/komodo
3
0
Fork 0
forked from github-starred/komodo
Code Pull Requests 1 Actions Packages Releases Activity

prog on alerting

Browse Source
This commit is contained in:
mbecker20
2023-08-20 03:55:30 -04:00
parent 7b3298e9e3
commit f0deda32dc
6 changed files with 275 additions and 161 deletions
Download Patch File Download Diff File Expand all files Collapse all files

190
Cargo.lock generated
View File

@@ -103,19 +103,19 @@ dependencies = [
[[package]]
name = "anyhow"
version = "1.0.71"
version = "1.0.75"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "9c7d0618f0e0b7e8ff11427422b64564d5fb0be1940354bfe2e0529b18a9d9b8"
checksum = "a4668cab20f66d8d020e1fbc0ebe47217433c1b6c8f2040faf858554e394ace6"
[[package]]
name = "async-trait"
version = "0.1.68"
version = "0.1.73"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "b9ccdd8f2a161be9bd5c023df56f1b2a0bd1d83872ae53b71a84a12c9bf6e842"
checksum = "bc00ceb34980c03614e35a3a4e218276a0a824e911d07651cd0d858a51e8c0f0"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.18",
"syn 2.0.29",
]
[[package]]
@@ -496,14 +496,14 @@ dependencies = [
[[package]]
name = "axum"
version = "0.6.18"
version = "0.6.20"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "f8175979259124331c1d7bf6586ee7e0da434155e4b2d48ec2c8386281d8df39"
checksum = "3b829e4e32b91e643de6eafe82b1d90675f5874230191a4ffbc1b336dec4d6bf"
dependencies = [
"async-trait",
"axum-core",
"base64 0.21.2",
"bitflags",
"bitflags 1.3.2",
"bytes",
"futures-util",
"headers",
@@ -603,6 +603,12 @@ version = "1.3.2"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "bef38d45163c2f1dde094a7dfd33ccf595c92905c8f8f4fdc18d06fb1037718a"
[[package]]
name = "bitflags"
version = "2.4.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "b4682ae6287fcf752ecaabbfcc7b6f9b72aa33933dc23a554d853aea8eea8635"
[[package]]
name = "bitvec"
version = "1.0.1"
@@ -683,7 +689,7 @@ dependencies = [
"base64 0.13.1",
"bitvec",
"hex",
"indexmap",
"indexmap 1.9.3",
"js-sys",
"lazy_static",
"rand",
@@ -765,9 +771,9 @@ dependencies = [
[[package]]
name = "clap"
version = "4.3.2"
version = "4.3.23"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "401a4694d2bf92537b6867d94de48c4842089645fdcdf6c71865b175d836e9c2"
checksum = "03aef18ddf7d879c15ce20f04826ef8418101c7e528014c3eeea13321047dca3"
dependencies = [
"clap_builder",
"clap_derive",
@@ -776,27 +782,26 @@ dependencies = [
[[package]]
name = "clap_builder"
version = "4.3.1"
version = "4.3.23"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "72394f3339a76daf211e57d4bcb374410f3965dcc606dd0e03738c7888766980"
checksum = "f8ce6fffb678c9b80a70b6b6de0aad31df727623a70fd9a842c30cd573e2fa98"
dependencies = [
"anstream",
"anstyle",
"bitflags",
"clap_lex",
"strsim",
]
[[package]]
name = "clap_derive"
version = "4.3.2"
version = "4.3.12"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "b8cd2b2a819ad6eec39e8f1d6b53001af1e5469f8c177579cdaeb313115b825f"
checksum = "54a9bb5758fc5dfe728d1019941681eccaf0cf8a4189b692a0ee2f2ecf90a050"
dependencies = [
"heck",
"proc-macro2",
"quote",
"syn 2.0.18",
"syn 2.0.29",
]
[[package]]
@@ -1054,7 +1059,7 @@ checksum = "dab95799d3c74d5c2f627e783e6b630b89f79d82a7b080c76086493a4cf651ef"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.18",
"syn 2.0.29",
]
[[package]]
@@ -1110,6 +1115,12 @@ dependencies = [
"serde",
]
[[package]]
name = "equivalent"
version = "1.0.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "5443807d6dff69373d433ab9ef5378ad8df50ca6298caf15de6e52e24aaf54d5"
[[package]]
name = "errno"
version = "0.3.1"
@@ -1248,7 +1259,7 @@ checksum = "89ca545a94061b6365f2c7355b4b32bd20df3ff95f02da9329b34ccc3bd6ee72"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.18",
"syn 2.0.29",
]
[[package]]
@@ -1320,7 +1331,7 @@ dependencies = [
"futures-sink",
"futures-util",
"http",
"indexmap",
"indexmap 1.9.3",
"slab",
"tokio",
"tokio-util",
@@ -1333,6 +1344,12 @@ version = "0.12.3"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8a9ee70c43aaf417c914396645a0fa852624801b24ebb7ae78fe8272889ac888"
[[package]]
name = "hashbrown"
version = "0.14.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "2c6201b9ff9fd90a5a3bac2e56a830d0caa509576f0e503818ee82c181b3437a"
[[package]]
name = "headers"
version = "0.3.8"
@@ -1340,7 +1357,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "f3e372db8e5c0d213e0cd0b9be18be2aca3d44cf2fe30a9d46a65581cd454584"
dependencies = [
"base64 0.13.1",
"bitflags",
"bitflags 1.3.2",
"bytes",
"headers-core",
"http",
@@ -1577,10 +1594,20 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "bd070e393353796e801d209ad339e89596eb4c8d430d18ede6a1cced8fafbd99"
dependencies = [
"autocfg",
"hashbrown",
"hashbrown 0.12.3",
"serde",
]
[[package]]
name = "indexmap"
version = "2.0.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "d5477fe2230a79769d8dc68e0eabf5437907c0457a5614a9e8dddb67f65eb65d"
dependencies = [
"equivalent",
"hashbrown 0.14.0",
]
[[package]]
name = "inout"
version = "0.1.3"
@@ -1715,9 +1742,9 @@ dependencies = [
[[package]]
name = "log"
version = "0.4.18"
version = "0.4.20"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "518ef76f2f87365916b142844c16d8fefd85039bc5699050210a7778ee1cd1de"
checksum = "b5e6163cb8c49088c2c36f57875e58ccd8c87c7427f7fbd50ea6710b2f3f2e8f"
[[package]]
name = "logger"
@@ -1858,7 +1885,7 @@ checksum = "ebcd85ec209a5b84fd9f54b9e381f6fa17462bc74160d018fc94fd8b9f61faa8"
dependencies = [
"async-trait",
"base64 0.13.1",
"bitflags",
"bitflags 1.3.2",
"bson",
"chrono",
"derivative",
@@ -1961,7 +1988,7 @@ version = "1.0.1"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.18",
"syn 2.0.29",
]
[[package]]
@@ -2011,7 +2038,7 @@ dependencies = [
"serde",
"serde_json",
"strum 0.25.0",
"strum_macros 0.25.0",
"strum_macros 0.25.2",
"typeshare",
]
@@ -2040,7 +2067,7 @@ checksum = "5daaa3fe65a15feb455a31a68ca3e6fc62efa8d1dc38660d6e8abd94079f2757"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.18",
"syn 2.0.29",
]
[[package]]
@@ -2129,7 +2156,7 @@ version = "0.10.54"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "69b3f656a17a6cbc115b5c7a40c616947d213ba182135b014d6051b73ab6f019"
dependencies = [
"bitflags",
"bitflags 1.3.2",
"cfg-if",
"foreign-types",
"libc",
@@ -2146,7 +2173,7 @@ checksum = "a948666b637a0f465e8564c73e89d4dde00d72d4d473cc972f390fc3dcee7d9c"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.18",
"syn 2.0.29",
]
[[package]]
@@ -2219,7 +2246,7 @@ checksum = "ad412582e4972654640acf910d4c85e2ba14a547fbcec5b8ddb944d82adec1e1"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.18",
"syn 2.0.29",
]
[[package]]
@@ -2267,14 +2294,14 @@ checksum = "39407670928234ebc5e6e580247dd567ad73a3578460c5990f9503df207e8f07"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.18",
"syn 2.0.29",
]
[[package]]
name = "pin-project-lite"
version = "0.2.9"
version = "0.2.12"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "e0a7ae3ac2f1173085d398531c705756c94a4c56843785df85a60c1a0afac116"
checksum = "12cc1b0bf1727a77a54b6654e7b5f1af8604923edc8b81885f8ec92f9e3f0a05"
[[package]]
name = "pin-utils"
@@ -2296,9 +2323,9 @@ checksum = "5b40af805b3121feab8a3c29f04d8ad262fa8e0561883e7653e024ae4479e6de"
[[package]]
name = "proc-macro2"
version = "1.0.59"
version = "1.0.66"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "6aeca18b86b413c660b781aa319e4e2648a3e6f9eadc9b47e9038e6fe9f3451b"
checksum = "18fb31db3f9bddb2ea821cde30a9f70117e3f119938b5ee630b7403aa6e2ead9"
dependencies = [
"unicode-ident",
]
@@ -2311,9 +2338,9 @@ checksum = "a1d01941d82fa2ab50be1e79e6714289dd7cde78eba4c074bc5a4374f650dfe0"
[[package]]
name = "quote"
version = "1.0.28"
version = "1.0.33"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "1b9ab9c7eadfd8df19006f1cf1a4aed13540ed5cbc047010ece5826e10825488"
checksum = "5267fca4496028628a95160fc423a33e8b2e6af8a5302579e322e4b520293cae"
dependencies = [
"proc-macro2",
]
@@ -2382,7 +2409,7 @@ version = "0.3.5"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "567664f262709473930a4bf9e51bf2ebf3348f2e748ccc50dea20646858f8f29"
dependencies = [
"bitflags",
"bitflags 1.3.2",
]
[[package]]
@@ -2470,7 +2497,7 @@ checksum = "6e1f7c7d2230fd8ab03239e20f32f99d85c8a1273bb159e1368cbda9fc2ff2ac"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.18",
"syn 2.0.29",
]
[[package]]
@@ -2537,7 +2564,7 @@ version = "0.37.19"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "acf8729d8542766f1b2cf77eb034d52f40d375bb8b615d0b147089946e16613d"
dependencies = [
"bitflags",
"bitflags 1.3.2",
"errno",
"io-lifetimes",
"libc",
@@ -2643,7 +2670,7 @@ version = "2.9.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "1fc758eb7bffce5b308734e9b0c1468893cae9ff70ebf13e7090be8dcbcc83a8"
dependencies = [
"bitflags",
"bitflags 1.3.2",
"core-foundation",
"core-foundation-sys",
"libc",
@@ -2683,9 +2710,9 @@ checksum = "388a1df253eca08550bef6c72392cfe7c30914bf41df5269b68cbd6ff8f570a3"
[[package]]
name = "serde"
version = "1.0.163"
version = "1.0.183"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "2113ab51b87a539ae008b5c6c02dc020ffa39afd2d83cffcb3f4eb2722cebec2"
checksum = "32ac8da02677876d532745a130fc9d8e6edfa81a269b107c5b00829b91d8eb3c"
dependencies = [
"serde_derive",
]
@@ -2701,22 +2728,22 @@ dependencies = [
[[package]]
name = "serde_derive"
version = "1.0.163"
version = "1.0.183"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8c805777e3930c8883389c602315a24224bcc738b63905ef87cd1420353ea93e"
checksum = "aafe972d60b0b9bee71a91b92fee2d4fb3c9d7e8f6b179aa99f27203d99a4816"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.18",
"syn 2.0.29",
]
[[package]]
name = "serde_json"
version = "1.0.96"
version = "1.0.105"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "057d394a50403bcac12672b2b18fb387ab6d289d957dab67dd201875391e52f1"
checksum = "693151e1ac27563d6dbcec9dee9fbd5da8539b20fa14ad3752b2e6d363ace360"
dependencies = [
"indexmap",
"indexmap 2.0.0",
"itoa",
"ryu",
"serde",
@@ -2739,7 +2766,7 @@ checksum = "bcec881020c684085e55a25f7fd888954d56609ef363479dc5a1305eb0d40cab"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.18",
"syn 2.0.29",
]
[[package]]
@@ -2782,7 +2809,7 @@ dependencies = [
"base64 0.13.1",
"chrono",
"hex",
"indexmap",
"indexmap 1.9.3",
"serde",
"serde_json",
"time 0.3.21",
@@ -2824,9 +2851,9 @@ dependencies = [
[[package]]
name = "sha2"
version = "0.10.6"
version = "0.10.7"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "82e6b795fe2e3b1e845bafcb27aa35405c4d47cdfc92af5fc8d3002f76cebdc0"
checksum = "479fb9d862239e610720565ca91403019f2f00410f1864c5aa7479b950a76ed8"
dependencies = [
"cfg-if",
"cpufeatures",
@@ -2897,7 +2924,7 @@ dependencies = [
"serde_derive",
"serde_json",
"strum 0.25.0",
"strum_macros 0.25.0",
"strum_macros 0.25.2",
]
[[package]]
@@ -2981,15 +3008,15 @@ dependencies = [
[[package]]
name = "strum_macros"
version = "0.25.0"
version = "0.25.2"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "fe9f3bd7d2e45dcc5e265fbb88d6513e4747d8ef9444cf01a533119bce28a157"
checksum = "ad8d03b598d3d0fff69bf533ee3ef19b8eeb342729596df84bcc7e1f96ec4059"
dependencies = [
"heck",
"proc-macro2",
"quote",
"rustversion",
"syn 2.0.18",
"syn 2.0.29",
]
[[package]]
@@ -3020,9 +3047,9 @@ dependencies = [
[[package]]
name = "syn"
version = "2.0.18"
version = "2.0.29"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "32d41677bcbe24c20c52e7c70b0d8db04134c5d1066bf98662e2871ad200ea3e"
checksum = "c324c494eba9d92503e6f1ef2e6df781e78f6a7705a0202d9801b198807d518a"
dependencies = [
"proc-macro2",
"quote",
@@ -3037,9 +3064,9 @@ checksum = "2047c6ded9c721764247e62cd3b03c09ffc529b2ba5b10ec482ae507a4a70160"
[[package]]
name = "sysinfo"
version = "0.29.2"
version = "0.29.8"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "9557d0845b86eea8182f7b10dff120214fb6cd9fd937b6f4917714e546a38695"
checksum = "d10ed79c22663a35a255d289a7fdcb43559fc77ff15df5ce6c341809e7867528"
dependencies = [
"cfg-if",
"core-foundation-sys",
@@ -3124,7 +3151,7 @@ checksum = "f9456a42c5b0d803c8cd86e73dd7cc9edd429499f37a3550d286d5e86720569f"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.18",
"syn 2.0.29",
]
[[package]]
@@ -3184,11 +3211,10 @@ checksum = "1f3ccbac311fea05f86f61904b462b55fb3df8837a366dfc601a0161d0532f20"
[[package]]
name = "tokio"
version = "1.29.1"
version = "1.32.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "532826ff75199d5833b9d2c5fe410f29235e25704ee5f0ef599fb51c21f4a4da"
checksum = "17ed6077ed6cd6c74735e21f37eb16dc3935f96878b1fe961074089cc80893f9"
dependencies = [
"autocfg",
"backtrace",
"bytes",
"libc",
@@ -3197,7 +3223,7 @@ dependencies = [
"parking_lot",
"pin-project-lite",
"signal-hook-registry",
"socket2 0.4.9",
"socket2 0.5.3",
"tokio-macros",
"windows-sys 0.48.0",
]
@@ -3210,7 +3236,7 @@ checksum = "630bdcf245f78637c13ec01ffae6187cca34625e8c63150d424b59e55af2675e"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.18",
"syn 2.0.29",
]
[[package]]
@@ -3257,9 +3283,9 @@ dependencies = [
[[package]]
name = "tokio-tungstenite"
version = "0.18.0"
version = "0.20.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "54319c93411147bced34cb5609a80e0a8e44c5999c93903a81cd866630ec0bfd"
checksum = "2b2dbec703c26b00d74844519606ef15d09a7d6857860f84ad223dec002ddea2"
dependencies = [
"futures-util",
"log",
@@ -3309,7 +3335,7 @@ version = "0.19.10"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "2380d56e8670370eee6566b0bfd4265f65b3f432e8c6d85623f728d4fa31f739"
dependencies = [
"indexmap",
"indexmap 1.9.3",
"serde",
"serde_spanned",
"toml_datetime",
@@ -3334,11 +3360,11 @@ dependencies = [
[[package]]
name = "tower-http"
version = "0.4.0"
version = "0.4.3"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "5d1d42a9b3f3ec46ba828e8d376aec14592ea199f70a06a548587ecd1c4ab658"
checksum = "55ae70283aba8d2a8b411c695c437fe25b8b5e44e23e780662002fc72fb47a82"
dependencies = [
"bitflags",
"bitflags 2.4.0",
"bytes",
"futures-core",
"futures-util",
@@ -3390,7 +3416,7 @@ checksum = "5f4f31f56159e98206da9efd823404b79b6ef3143b4a7ab76e67b1751b25a4ab"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.18",
"syn 2.0.29",
]
[[package]]
@@ -3455,13 +3481,13 @@ checksum = "3528ecfd12c466c6f163363caf2d02a71161dd5e1cc6ae7b34207ea2d42d81ed"
[[package]]
name = "tungstenite"
version = "0.18.0"
version = "0.20.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "30ee6ab729cd4cf0fd55218530c4522ed30b7b6081752839b68fcec8d0960788"
checksum = "e862a1c4128df0112ab625f55cd5c934bcb4312ba80b39ae4b4835a3fd58e649"
dependencies = [
"base64 0.13.1",
"byteorder",
"bytes",
"data-encoding",
"http",
"httparse",
"log",
@@ -3560,9 +3586,9 @@ dependencies = [
[[package]]
name = "urlencoding"
version = "2.1.2"
version = "2.1.3"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "e8db7427f936968176eaa7cdf81b7f98b980b18495ec28f1b5791ac3bfe3eea9"
checksum = "daf8dba3b7eb870caf1ddeed7bc9d2a049f3cfdfae7cb521b087cc33ae4c49da"
[[package]]
name = "utf-8"
@@ -3648,7 +3674,7 @@ dependencies = [
"once_cell",
"proc-macro2",
"quote",
"syn 2.0.18",
"syn 2.0.29",
"wasm-bindgen-shared",
]
@@ -3682,7 +3708,7 @@ checksum = "e128beba882dd1eb6200e1dc92ae6c5dbaa4311aa7bb211ca035779e5efc39f8"
dependencies = [
"proc-macro2",
"quote",
"syn 2.0.18",
"syn 2.0.29",
"wasm-bindgen-backend",
"wasm-bindgen-shared",
]

68
Cargo.toml
View File

@@ -29,39 +29,39 @@ parse_csl = "0.1.0"
mungos = "0.4.18"
svi = "0.1.4"
# external
tokio = { version = "1.29", features = ["full"] }
axum = { version = "0.6", features = ["ws", "json", "headers"] }
tower = { version = "0.4", features = ["timeout"] }
tower-http = { version = "0.4", features = ["fs", "cors"] }
reqwest = { version = "0.11", features = ["json"] }
clap = { version = "4.3", features = ["derive"] }
uuid = { version = "1.4", features = ["v4", "fast-rng", "serde"] }
serde = { version = "1.0", features = ["derive"] }
serde_json = "1.0"
tokio-util = "0.7"
futures = "0.3"
futures-util = "0.3"
dotenv = "0.15"
envy = "0.4"
anyhow = "1.0"
log = "0.4"
simple_logger = "4.2"
tokio = { version = "1.32.0", features = ["full"] }
axum = { version = "0.6.20", features = ["ws", "json", "headers"] }
tower = { version = "0.4.13", features = ["timeout"] }
tower-http = { version = "0.4.3", features = ["fs", "cors"] }
reqwest = { version = "0.11.18", features = ["json"] }
clap = { version = "4.3.21", features = ["derive"] }
uuid = { version = "1.4.1", features = ["v4", "fast-rng", "serde"] }
serde = { version = "1.0.183", features = ["derive"] }
serde_json = "1.0.105"
tokio-util = "0.7.8"
futures = "0.3.28"
futures-util = "0.3.28"
dotenv = "0.15.0"
envy = "0.4.2"
anyhow = "1.0.75"
log = "0.4.20"
simple_logger = "4.2.0"
bollard = "0.14.0"
derive_builder = "0.12"
derive_builder = "0.12.0"
typeshare = "1.0.1"
strum = "0.25"
strum_macros = "0.25"
sysinfo = "0.29"
async-trait = "0.1"
urlencoding = "2.1"
rand = "0.8"
jwt = "0.16"
hmac = "0.12"
sha2 = "0.10"
bcrypt = "0.15"
hex = "0.4"
aws-config = "0.56"
aws-sdk-ec2 = "0.29"
proc-macro2 = "1.0"
quote = "1.0"
syn = "2.0"
strum = "0.25.0"
strum_macros = "0.25.2"
sysinfo = "0.29.8"
async-trait = "0.1.73"
urlencoding = "2.1.3"
rand = "0.8.5"
jwt = "0.16.0"
hmac = "0.12.1"
sha2 = "0.10.7"
bcrypt = "0.15.0"
hex = "0.4.3"
aws-config = "0.56.0"
aws-sdk-ec2 = "0.29.0"
proc-macro2 = "1.0.66"
quote = "1.0.33"
syn = "2.0.29"

49
bin/core/src/helpers/alert.rs
View File

@@ -1,4 +1,5 @@
use anyhow::{anyhow, Context};
use futures::future::join_all;
use monitor_types::entities::{
alert::{Alert, AlertData},
alerter::*,
@@ -8,13 +9,44 @@ use monitor_types::entities::{
use reqwest::StatusCode;
use slack::types::Block;
pub async fn send_alert(alerter: &Alerter, alert: &Alert) -> anyhow::Result<()> {
match &alerter.config {
AlerterConfig::Slack(SlackAlerterConfig { url }) => send_slack_alert(url, alert).await,
AlerterConfig::Custom(CustomAlerterConfig { url }) => send_custom_alert(url, alert).await,
use crate::state::State;
impl State {
pub async fn send_alerts(&self, alerts: &[Alert]) {
let alerters = self.db.alerters.get_some(None, None).await;
if let Err(e) = alerters {
error!("ERROR sending alerts | failed to get alerters from db | {e:#?}");
return;
}
let alerters = alerters.unwrap();
let handles = alerts.iter().map(|alert| send_alert(&alerters, alert));
join_all(handles).await;
}
}
pub async fn send_alert(alerters: &[Alerter], alert: &Alert) {
let handles = alerters.iter().map(|alerter| async {
match &alerter.config {
AlerterConfig::Slack(SlackAlerterConfig { url }) => send_slack_alert(url, alert)
.await
.context("failed to send slack alert"),
AlerterConfig::Custom(CustomAlerterConfig { url }) => send_custom_alert(url, alert)
.await
.context(format!("failed to send alert to custom alerter at {url}")),
}
});
join_all(handles)
.await
.into_iter()
.filter_map(|res| res.err())
.for_each(|e| error!("{e:#?}"));
}
pub async fn send_slack_alert(url: &str, alert: &Alert) -> anyhow::Result<()> {
let level = alert.level;
let (text, blocks): (_, Option<_>) = match &alert.data {
@@ -27,6 +59,15 @@ pub async fn send_slack_alert(url: &str, alert: &Alert) -> anyhow::Result<()> {
];
(text, blocks.into())
}
AlertData::ServerReachable { name, region, .. } => {
let region = fmt_region(region);
let text = format!("OK ✅ | *{name}*{region} is now *reachable*");
let blocks = vec![
Block::header("OK ✅"),
Block::section(format!("*{name}*{region} is now *reachable*")),
];
(text, blocks.into())
}
AlertData::ServerCpu {
name,
region,

13
bin/core/src/monitor/alert/deployment.rs
View File

@@ -1,9 +1,13 @@
use monitor_types::entities::{alert::AlertData, deployment::Deployment};
use monitor_types::entities::{
alert::{Alert, AlertData},
deployment::Deployment, server::stats::SeverityLevel,
};
use crate::{helpers::resource::StateResource, state::State};
impl State {
pub async fn alert_deployments(&self) {
let mut alerts = Vec::<Alert>::new();
for v in self.deployment_status_cache.get_list().await {
if v.prev.is_none() {
continue;
@@ -24,7 +28,14 @@ impl State {
from: prev,
to: v.curr.state,
};
let alert = Alert {
level: SeverityLevel::Warning,
data,
..Default::default()
};
alerts.push(alert);
}
}
self.send_alerts(&alerts).await;
}
}

111
bin/core/src/monitor/alert/server.rs
View File

@@ -76,7 +76,77 @@ impl State {
}
}
let res = self.resolve_alerts(&alert_ids_to_close).await;
tokio::join!(
self.open_alerts(alerts_to_open),
self.resolve_alerts(&alert_ids_to_close)
);
}
async fn open_alerts(&self, alerts: Vec<Alert>) {
let open = || async {
// self.db.alerters.create_many(alerts).await?;
anyhow::Ok(())
};
let alert = || async { todo!() };
let (res, _) = tokio::join!(open(), alert());
if let Err(e) = res {
error!("failed to create alerts on db | {e:#?}");
}
}
async fn resolve_alerts(&self, alert_ids: &[String]) {
let close = || async {
let alert_ids = alert_ids
.iter()
.map(|id| ObjectId::from_str(id).context("failed to convert alert id to ObjectId"))
.collect::<anyhow::Result<Vec<_>>>()?;
self.db
.alerts
.update_many(
doc! { "_id": { "$in": alert_ids } },
doc! {
"$set": {
"resolved": "true",
"resolved_ts": monitor_timestamp()
}
},
)
.await
.context("failed to resolve alerts on db")?;
anyhow::Ok(())
};
let alert = || async {
// alert that alert has be resolved
todo!()
};
let (res, _) = tokio::join!(close(), alert());
if let Err(e) = res {
error!("failed to resolve alerts | {e:#?}");
}
}
async fn get_open_alerts(&self) -> anyhow::Result<OpenAlertMap> {
let alerts = self
.db
.alerts
.get_some(doc! { "resolved": false }, None)
.await
.context("failed to get open alerts from db")?;
let mut map = OpenAlertMap::new();
for alert in alerts {
let inner = map.entry(alert.target.clone()).or_default();
inner.insert(alert.variant, alert);
}
Ok(map)
}
async fn get_all_servers_map(&self) -> anyhow::Result<HashMap<String, ServerListItem>> {
@@ -99,43 +169,4 @@ impl State {
Ok(servers)
}
async fn resolve_alerts(&self, alert_ids: &[String]) -> anyhow::Result<()> {
let alert_ids = alert_ids
.iter()
.map(|id| ObjectId::from_str(id).context("failed to convert alert id to ObjectId"))
.collect::<anyhow::Result<Vec<_>>>()?;
self.db
.alerts
.update_many(
doc! { "_id": { "$in": alert_ids } },
doc! {
"$set": {
"resolved": "true",
"resolved_ts": monitor_timestamp()
}
},
)
.await
.context("failed to resolve alerts on db")?;
Ok(())
}
async fn get_open_alerts(&self) -> anyhow::Result<OpenAlertMap> {
let alerts = self
.db
.alerts
.get_some(doc! { "resolved": false }, None)
.await
.context("failed to get open alerts from db")?;
let mut map = OpenAlertMap::new();
for alert in alerts {
let inner = map.entry(alert.target.clone()).or_default();
inner.insert(alert.variant, alert);
}
Ok(map)
}
}

5
lib/types/src/entities/alert.rs
View File

@@ -63,6 +63,11 @@ pub enum AlertData {
name: String,
region: Option<String>,
},
ServerReachable {
id: String,
name: String,
region: Option<String>,
},
ServerCpu {
id: String,
name: String,