askrene: add optional layers to reservations.

We have the issue of aliases: xpay uses scids like 0x0x0 for
routehints and blinded paths, and then can apply reservations to them.  But
generally, reservations are *global*, so we need to differentiate.

Changelog-Added: Plugins: `askrene-reserve` and `askrene-unreserve` can take an optional `layer` inside `path` elements.
Signed-off-by: Rusty Russell <rusty@rustcorp.com.au>

Author: rustyrussell

.msggen.json

@@ -762,6 +762,7 @@
         "Askrene-reservePath": {
             "AskRene-Reserve.path[].amount_msat": 3,
             "AskRene-Reserve.path[].direction": 2,
+            "AskRene-Reserve.path[].layer": 5,
             "AskRene-Reserve.path[].short_channel_id": 1,
             "AskRene-Reserve.path[].short_channel_id_dir": 4
         },
@@ -771,6 +772,7 @@
         "Askrene-unreservePath": {
             "AskRene-Unreserve.path[].amount_msat": 3,
             "AskRene-Unreserve.path[].direction": 2,
+            "AskRene-Unreserve.path[].layer": 5,
             "AskRene-Unreserve.path[].short_channel_id": 1,
             "AskRene-Unreserve.path[].short_channel_id_dir": 4
         },
@@ -4469,6 +4471,10 @@
             "added": "v24.08",
             "deprecated": null
         },
+        "AskRene-Reserve.path[].layer": {
+            "added": "v25.12",
+            "deprecated": null
+        },
         "AskRene-Reserve.path[].short_channel_id": {
             "added": "v24.08",
             "deprecated": null
@@ -4493,6 +4499,10 @@
             "added": "v24.08",
             "deprecated": null
         },
+        "AskRene-Unreserve.path[].layer": {
+            "added": "v25.12",
+            "deprecated": null
+        },
         "AskRene-Unreserve.path[].short_channel_id": {
             "added": "v24.08",
             "deprecated": null

cln-grpc/proto/node.proto

@@ -1553,6 +1553,13 @@
                   "description": [
                     "The amount to send into this hop."
                   ]
+                },
+                "layer": {
+                  "added": "v25.12",
+                  "type": "string",
+                  "description": [
+                    "The layer to restrict this reservation to (useful for fake channels)."
+                  ]
                 }
               }
             }
@@ -1654,6 +1661,13 @@
                   "description": [
                     "The amount to send into this hop."
                   ]
+                },
+                "layer": {
+                  "added": "v25.12",
+                  "type": "string",
+                  "description": [
+                    "The layer to restrict this reservation to (useful for fake channels)."
+                  ]
                 }
               }
             }

cln-grpc/src/convert.rs

@@ -36,6 +36,13 @@
               "description": [
                 "The amount to send into this hop."
               ]
+            },
+            "layer": {
+              "added": "v25.12",
+              "type": "string",
+              "description": [
+                "The layer to restrict this reservation to (useful for fake channels)."
+              ]
             }
           }
         }

cln-rpc/src/model.rs

@@ -36,6 +36,13 @@
               "description": [
                 "The amount to send into this hop."
               ]
+            },
+            "layer": {
+              "added": "v25.12",
+              "type": "string",
+              "description": [
+                "The layer to restrict this reservation to (useful for fake channels)."
+              ]
             }
           }
         }

contrib/msggen/msggen/schema.json

@@ -118,12 +118,21 @@ static struct command_result *parse_reserve_hop(struct command *cmd,
 						struct reserve_hop *rhop)
 {
 	const char *err;
+	const char *layername = NULL;
 
-	err = json_scan(tmpctx, buffer, tok, "{short_channel_id_dir:%,amount_msat:%}",
+	err = json_scan(tmpctx, buffer, tok, "{short_channel_id_dir:%,amount_msat:%,layer?:%}",
 			JSON_SCAN(json_to_short_channel_id_dir, &rhop->scidd),
-			JSON_SCAN(json_to_msat, &rhop->amount));
+			JSON_SCAN(json_to_msat, &rhop->amount),
+			JSON_SCAN_TAL(tmpctx, json_strdup, &layername));
 	if (err)
 		return command_fail_badparam(cmd, name, buffer, tok, err);
+	if (layername) {
+		rhop->layer = find_layer(get_askrene(cmd->plugin), layername);
+		if (!rhop->layer)
+			return command_fail_badparam(cmd, name, buffer, tok, "Unknown layer");
+	} else
+		rhop->layer = NULL;
+
 	return NULL;
 }
 
@@ -519,8 +528,8 @@ void get_constraints(const struct route_query *rq,
 		*max = gossmap_chan_get_capacity(rq->gossmap, chan);
 
 	/* Finally, if any is in use, subtract that! */
-	reserve_sub(rq->reserved, &scidd, min);
-	reserve_sub(rq->reserved, &scidd, max);
+	reserve_sub(rq->reserved, &scidd, rq->layers, min);
+	reserve_sub(rq->reserved, &scidd, rq->layers, max);
 }
 
 static struct command_result *do_getroutes(struct command *cmd,
@@ -876,9 +885,11 @@ static struct command_result *json_askrene_unreserve(struct command *cmd,
 	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",
+					    "Unknown reservation for %s%s%s",
 					    fmt_short_channel_id_dir(tmpctx,
-								     &path[i].scidd));
+								     &path[i].scidd),
+					    path[i].layer ? " on layer " : "",
+					    path[i].layer ? layer_name(path[i].layer) : "");
 		}
  	}
 
@@ -893,14 +904,15 @@ static struct command_result *json_askrene_listreservations(struct command *cmd,
 	struct askrene *askrene = get_askrene(cmd->plugin);
 	struct json_stream *response;
 
+	/* FIXME: We could allow layer names here? */
 	if (!param(cmd, buffer, params,
 		   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));
 
 	response = jsonrpc_stream_success(cmd);
-	json_add_reservations(response, askrene->reserved, "reservations");
+	json_add_reservations(response, askrene->reserved, "reservations", NULL);
 	return command_finished(cmd, response);
 }
 
@@ -1025,7 +1037,7 @@ static struct command_result *json_askrene_inform_channel(struct command *cmd,
 	case INFORM_CONSTRAINED:
 		/* It didn't pass, so minimal assumption is that reserve was all used
 		 * then there we were one msat short. */
-		if (!reserve_accumulate(askrene->reserved, scidd, amount))
+		if (!reserve_accumulate(askrene->reserved, scidd, layer, amount))
 			return command_fail(cmd, JSONRPC2_INVALID_PARAMS,
 					    "Amount overflow with reserves");
 		if (!amount_msat_sub(amount, *amount, AMOUNT_MSAT(1)))

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

@@ -60,7 +60,7 @@ static const char *why_max_constrained(const tal_t *ctx,
 			       fmt_amount_msat(tmpctx, max));
 	}
 
-	reservations = fmt_reservations(tmpctx, rq->reserved, scidd);
+	reservations = fmt_reservations(tmpctx, rq->reserved, scidd, rq->layers);
 	if (reservations) {
 		if (!ret)
 			ret = tal_strdup(ctx, "");