prepare v4.3.1

Author: daywalker90

CHANGELOG.md

@@ -1,5 +1,15 @@
 # Changelog
 
+## [4.3.1] - 2026-08-10
+
+### Fixed
+- use the `help` rpc instead of the (custom) version string to determine available rpc methods
+- validate amount in htlc hook handler
+- don't shutdown plugin if a background task fails, increase log level instead and restart task
+- fixed `sling-deletejob` with `delete_stats=true` not deleting stat files
+- fixed typo in `sling-go` output json: `tasks_failed_start:` -> `tasks_failed_start`
+- a few theoretical integer overflows
+
 ## [4.3.0] - 2026-06-07
 
 ### Added

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "sling"
-version = "4.3.0"
+version = "4.3.1"
 edition = "2024"
 rust-version = "1.85.0"
 

Cargo.toml

@@ -1,6 +1,6 @@
 plugin:
   name: sling
-  version: 4.3.0
+  version: 4.3.1
   lang: rust
   install: |
     cargo build --release && cp target/release/sling . && cargo clean

coffee.yml

@@ -51,11 +51,11 @@ pub async fn parse_job(
 
             //also convert to msat
             let amount_msat = match ar.get("amount") {
-                Some(amt) => {
-                    amt.as_u64()
-                        .ok_or(anyhow!("amount must be a positive integer"))?
-                        * 1_000
-                }
+                Some(amt) => amt
+                    .as_u64()
+                    .ok_or(anyhow!("amount must be a positive integer"))?
+                    .checked_mul(1_000)
+                    .ok_or_else(|| anyhow!("amount too large"))?,
                 None => return Err(anyhow!("Missing amount")),
             };
             if amount_msat == 0 {
@@ -115,7 +115,8 @@ pub async fn parse_job(
                 job.add_depleteuptoamount_msat(
                     da.as_u64()
                         .ok_or(anyhow!("depleteuptoamount must be an integer"))?
-                        * 1_000,
+                        .checked_mul(1_000)
+                        .ok_or_else(|| anyhow!("depleteuptoamount too large"))?,
                 );
             }
 

src/parse.rs

@@ -204,7 +204,7 @@ pub async fn slinggo(
         }
     }
 
-    Ok(json!({ "tasks_started": spawn_count , "tasks_failed_start:": spawn_fail_count }))
+    Ok(json!({ "tasks_started": spawn_count , "tasks_failed_start": spawn_fail_count }))
 }
 
 pub async fn slingstop(
@@ -620,11 +620,6 @@ pub async fn slingdeletejob(
     match input {
         inp if inp.eq("all") => {
             stop_job(plugin.clone(), serde_json::Value::Array(vec![])).await?;
-            let jobfile = sling_dir.join(JOB_FILE_NAME);
-            fs::remove_file(jobfile).await?;
-            plugin.state().tasks.lock().remove_all_tasks();
-            log::info!("Deleted all jobs");
-            let except_chans = read_except_chans(&sling_dir).await?;
             if delete_stats {
                 let jobs = read_jobs(&sling_dir, plugin.clone()).await?;
                 for scid in jobs.keys() {
@@ -636,6 +631,13 @@ pub async fn slingdeletejob(
                             .await;
                 }
             }
+
+            let jobfile = sling_dir.join(JOB_FILE_NAME);
+            fs::remove_file(jobfile).await?;
+            plugin.state().tasks.lock().remove_all_tasks();
+            log::info!("Deleted all jobs");
+            let except_chans = read_except_chans(&sling_dir).await?;
+
             let mut config = plugin.state().config.lock();
             config.exclude_chans_pull.clone_from(&except_chans);
             config.exclude_chans_push = except_chans;

src/rpc_sling.rs

@@ -673,7 +673,7 @@ fn build_candidatelist(
             continue;
         }
 
-        if scid.block() > blockheight - config.candidates_min_age {
+        if scid.block() > blockheight.saturating_sub(config.candidates_min_age) {
             log::trace!(
                 "{}: build_candidatelist: {} is too new: {}>{}",
                 task_ident,