Compare commits
3 Commits
8722c0085c
...
0aaae85873
Author | SHA1 | Date |
---|---|---|
Astro | 0aaae85873 | |
Astro | e27d772c3b | |
Astro | b04887ac6d |
File diff suppressed because it is too large
Load Diff
38
flake.lock
38
flake.lock
|
@ -7,11 +7,11 @@
|
||||||
]
|
]
|
||||||
},
|
},
|
||||||
"locked": {
|
"locked": {
|
||||||
"lastModified": 1671096816,
|
"lastModified": 1679567394,
|
||||||
"narHash": "sha256-ezQCsNgmpUHdZANDCILm3RvtO1xH8uujk/+EqNvzIOg=",
|
"narHash": "sha256-ZvLuzPeARDLiQUt6zSZFGOs+HZmE+3g4QURc8mkBsfM=",
|
||||||
"owner": "nix-community",
|
"owner": "nix-community",
|
||||||
"repo": "naersk",
|
"repo": "naersk",
|
||||||
"rev": "d998160d6a076cfe8f9741e56aeec7e267e3e114",
|
"rev": "88cd22380154a2c36799fe8098888f0f59861a15",
|
||||||
"type": "github"
|
"type": "github"
|
||||||
},
|
},
|
||||||
"original": {
|
"original": {
|
||||||
|
@ -23,11 +23,11 @@
|
||||||
},
|
},
|
||||||
"nixpkgs": {
|
"nixpkgs": {
|
||||||
"locked": {
|
"locked": {
|
||||||
"lastModified": 1671190014,
|
"lastModified": 1685938391,
|
||||||
"narHash": "sha256-NW385LW4Nj53Hbv3LXr458s4NL2/wcARC8rzK7vSWkw=",
|
"narHash": "sha256-96Jw6TbWDLSopt5jqCW8w1Fc1cjQyZlhfBnJ3OZGpME=",
|
||||||
"owner": "NixOS",
|
"owner": "NixOS",
|
||||||
"repo": "nixpkgs",
|
"repo": "nixpkgs",
|
||||||
"rev": "fbcb61bd7eb19914cbd88789c3586a63ff46b72b",
|
"rev": "31cd1b4afbaf0b1e81272ee9c31d1ab606503aed",
|
||||||
"type": "github"
|
"type": "github"
|
||||||
},
|
},
|
||||||
"original": {
|
"original": {
|
||||||
|
@ -44,13 +44,31 @@
|
||||||
"utils": "utils"
|
"utils": "utils"
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"utils": {
|
"systems": {
|
||||||
"locked": {
|
"locked": {
|
||||||
"lastModified": 1667395993,
|
"lastModified": 1681028828,
|
||||||
"narHash": "sha256-nuEHfE/LcWyuSWnS8t12N1wc105Qtau+/OdUAjtQ0rA=",
|
"narHash": "sha256-Vy1rq5AaRuLzOxct8nz4T6wlgyUR7zLU309k9mBC768=",
|
||||||
|
"owner": "nix-systems",
|
||||||
|
"repo": "default",
|
||||||
|
"rev": "da67096a3b9bf56a91d16901293e51ba5b49a27e",
|
||||||
|
"type": "github"
|
||||||
|
},
|
||||||
|
"original": {
|
||||||
|
"owner": "nix-systems",
|
||||||
|
"repo": "default",
|
||||||
|
"type": "github"
|
||||||
|
}
|
||||||
|
},
|
||||||
|
"utils": {
|
||||||
|
"inputs": {
|
||||||
|
"systems": "systems"
|
||||||
|
},
|
||||||
|
"locked": {
|
||||||
|
"lastModified": 1685518550,
|
||||||
|
"narHash": "sha256-o2d0KcvaXzTrPRIo0kOLV0/QXHhDQ5DTi+OxcjO8xqY=",
|
||||||
"owner": "numtide",
|
"owner": "numtide",
|
||||||
"repo": "flake-utils",
|
"repo": "flake-utils",
|
||||||
"rev": "5aed5285a952e0b949eb3ba02c12fa4fcfef535f",
|
"rev": "a1720a10a6cfe8234c0e93907ffe81be440f4cef",
|
||||||
"type": "github"
|
"type": "github"
|
||||||
},
|
},
|
||||||
"original": {
|
"original": {
|
||||||
|
|
|
@ -27,11 +27,6 @@
|
||||||
''cargo clippy --all --all-features --tests -- \
|
''cargo clippy --all --all-features --tests -- \
|
||||||
-D clippy::pedantic \
|
-D clippy::pedantic \
|
||||||
-D warnings \
|
-D warnings \
|
||||||
-A clippy::module-name-repetitions \
|
|
||||||
-A clippy::too-many-lines \
|
|
||||||
-A clippy::cast-possible-wrap \
|
|
||||||
-A clippy::cast-possible-truncation \
|
|
||||||
-A clippy::nonminimal_bool \
|
|
||||||
-A clippy::unused-async''
|
-A clippy::unused-async''
|
||||||
];
|
];
|
||||||
meta.description = "Send Prometheus alerts to XMPP Multi-User Chatrooms";
|
meta.description = "Send Prometheus alerts to XMPP Multi-User Chatrooms";
|
||||||
|
|
|
@ -24,7 +24,7 @@ impl Handle {
|
||||||
pub async fn run(jid: String, password: String, muc_jid: String) -> Handle {
|
pub async fn run(jid: String, password: String, muc_jid: String) -> Handle {
|
||||||
let muc_jid: FullJid = match FullJid::from_str(&muc_jid) {
|
let muc_jid: FullJid = match FullJid::from_str(&muc_jid) {
|
||||||
Ok(jid) => jid,
|
Ok(jid) => jid,
|
||||||
Err(err) => panic!("MUC Jid invalid: {:?}", err),
|
Err(err) => panic!("MUC Jid invalid: {err:?}"),
|
||||||
};
|
};
|
||||||
let (tx, mut rx) = mpsc::channel(1);
|
let (tx, mut rx) = mpsc::channel(1);
|
||||||
let handle = Handle {
|
let handle = Handle {
|
||||||
|
@ -36,7 +36,7 @@ pub async fn run(jid: String, password: String, muc_jid: String) -> Handle {
|
||||||
loop {
|
loop {
|
||||||
match client.next().await {
|
match client.next().await {
|
||||||
Some(Event::Online { .. }) => {
|
Some(Event::Online { .. }) => {
|
||||||
println!("XMPP client now online at {}", jid);
|
println!("XMPP client now online at {jid}");
|
||||||
let packet = Packet::Stanza(make_join_presence(muc_jid.clone()));
|
let packet = Packet::Stanza(make_join_presence(muc_jid.clone()));
|
||||||
client.send(packet).await
|
client.send(packet).await
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
@ -56,13 +56,13 @@ pub async fn run(jid: String, password: String, muc_jid: String) -> Handle {
|
||||||
Ok(presence) => {
|
Ok(presence) => {
|
||||||
if presence.from == Some(Jid::Full(muc_jid.clone())) {
|
if presence.from == Some(Jid::Full(muc_jid.clone())) {
|
||||||
if presence.type_ == PresenceType::Error {
|
if presence.type_ == PresenceType::Error {
|
||||||
println!("Failed to enter MUC {:?}", muc_jid);
|
println!("Failed to enter MUC {muc_jid:?}");
|
||||||
} else {
|
} else {
|
||||||
println!("Entered MUC {:?}", muc_jid);
|
println!("Entered MUC {muc_jid:?}");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
Err(err) => println!("Received invalid presence: {:?}", err),
|
Err(err) => println!("Received invalid presence: {err:?}"),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
systemd::daemon::notify(false, [(systemd::daemon::STATE_WATCHDOG, "1")].iter())
|
systemd::daemon::notify(false, [(systemd::daemon::STATE_WATCHDOG, "1")].iter())
|
||||||
|
|
|
@ -34,7 +34,7 @@ impl Payload {
|
||||||
jabber.send_message(message).await;
|
jabber.send_message(message).await;
|
||||||
}
|
}
|
||||||
Err(e) => {
|
Err(e) => {
|
||||||
error_message = Some(format!("{}", e));
|
error_message = Some(format!("{e}"));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue