askrene-unreserve: add dev_remove_all option

Changelog-None

Signed-off-by: Lagrang3 <lagrang3@protonmail.com>

Author: Lagrang3

.msggen.json

@@ -851,6 +851,7 @@
             "AskRene-Unreserve.path[].short_channel_id_dir": 4
         },
         "Askrene-unreserveRequest": {
+            "AskRene-Unreserve.dev_remove_all": 2,
             "AskRene-Unreserve.path[]": 1
         },
         "Askrene-update-channelRequest": {
@@ -4746,6 +4747,10 @@
             "added": "v24.11",
             "deprecated": null
         },
+        "AskRene-Unreserve.dev_remove_all": {
+            "added": "v26.04",
+            "deprecated": null
+        },
         "AskRene-Unreserve.path[]": {
             "added": "v24.11",
             "deprecated": null

cln-grpc/proto/node.proto

@@ -1997,6 +1997,11 @@
                 }
               }
             }
+          },
+          "dev_remove_all": {
+            "hidden": true,
+            "type": "boolean",
+            "added": "v26.04"
           }
         }
       },

cln-grpc/src/convert.rs

@@ -46,6 +46,11 @@
             }
           }
         }
+      },
+      "dev_remove_all": {
+        "hidden": true,
+        "type": "boolean",
+        "added": "v26.04"
       }
     }
   },

cln-rpc/src/model.rs

@@ -946,24 +946,30 @@ static struct command_result *json_askrene_unreserve(struct command *cmd,
 	struct reserve_hop *path;
 	struct json_stream *response;
 	struct askrene *askrene = get_askrene(cmd->plugin);
+	bool *remove_all;
 
 	if (!param(cmd, buffer, params,
 		   p_req("path", param_reserve_path, &path),
+		   p_opt_dev("dev_remove_all", param_bool, &remove_all, false),
 		   NULL))
 		return command_param_failed();
 	plugin_log(cmd->plugin, LOG_TRACE, "%s called: %.*s", __func__,
 		   json_tok_full_len(params), json_tok_full(buffer, params));
 
-	for (size_t i = 0; i < tal_count(path); i++) {
-		if (!reserve_remove(askrene->reserved, &path[i])) {
-			return command_fail(cmd, JSONRPC2_INVALID_PARAMS,
-					    "Unknown reservation for %s%s%s",
-					    fmt_short_channel_id_dir(tmpctx,
-								     &path[i].scidd),
-					    path[i].layer ? " on layer " : "",
-					    path[i].layer ? layer_name(path[i].layer) : "");
+	if (*remove_all) {
+		reserve_remove_all(askrene->reserved);
+	} else {
+		for (size_t i = 0; i < tal_count(path); i++) {
+			if (!reserve_remove(askrene->reserved, &path[i])) {
+				return command_fail(cmd, JSONRPC2_INVALID_PARAMS,
+						    "Unknown reservation for %s%s%s",
+						    fmt_short_channel_id_dir(tmpctx,
+									     &path[i].scidd),
+						    path[i].layer ? " on layer " : "",
+						    path[i].layer ? layer_name(path[i].layer) : "");
+			}
 		}
- 	}
+	}
 
 	response = jsonrpc_stream_success(cmd);
 	return command_finished(cmd, response);

contrib/msggen/msggen/schema.json

@@ -88,6 +88,18 @@ bool reserve_remove(struct reserve_htable *reserved,
 	return false;
 }
 
+void reserve_remove_all(struct reserve_htable *reserved)
+{
+	struct reserve *r;
+	struct reserve_htable_iter rit;
+
+	for (r = reserve_htable_first(reserved, &rit); r;
+	     r = reserve_htable_next(reserved, &rit)) {
+		tal_free(r);
+	}
+	reserve_htable_clear(reserved);
+}
+
 void reserves_clear_capacities(struct reserve_htable *reserved,
 			       const struct gossmap *gossmap,
 			       fp16_t *capacities)

contrib/pyln-grpc-proto/pyln/grpc/node_pb2.py

@@ -29,6 +29,9 @@ void reserve_add(struct reserve_htable *reserved,
 bool reserve_remove(struct reserve_htable *reserved,
 		    const struct reserve_hop *rhop);
 
+/* Remove all reservations. */
+void reserve_remove_all(struct reserve_htable *reserved);
+
 /* Clear capacities array where we have reserves */
 void reserves_clear_capacities(struct reserve_htable *reserved,
 			       const struct gossmap *gossmap,