Difuse/difos
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 2

unetd: cli: add hook calls for invite/join status changes

Browse source 
Allows different frontends to interact without parsing human readable
messages

Signed-off-by: Felix Fietkau <nbd@nbd.name>
This commit is contained in:
Felix Fietkau 2025-05-14 11:21:56 +02:00
parent 4d18c41a6c
commit 7f1b9a4209
1 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
package/network/services/unetd/files/unet.uc
View file

@ -549,6 +549,7 @@ function network_invite_peer_update(model, ctx, msg)
model.status_msg("Updated configuration"); model.status_msg("Updated configuration");
} }
model.run_hook("unet_enroll", "invite_done");
__network_enroll_cancel(model, ctx); __network_enroll_cancel(model, ctx);
} }
@ -576,8 +577,10 @@ function network_invite(ctx, argv, named)
invite.sub = model.ubus.subscriber((msg) => { invite.sub = model.ubus.subscriber((msg) => {
if (msg.type == "enroll_peer_update") if (msg.type == "enroll_peer_update")
network_invite_peer_update(ctx.model, ctx, msg); network_invite_peer_update(ctx.model, ctx, msg);
else if (msg.type == "enroll_timeout") else if (msg.type == "enroll_timeout") {
ctx.model.run_hook("unet_enroll", "invite_timeout");
__network_enroll_cancel(ctx.model, ctx); __network_enroll_cancel(ctx.model, ctx);
}
}); });
let req = { let req = {
@ -627,6 +630,7 @@ function network_join_peer_update(model, ctx, msg)
model.status_msg("Configuration added for interface " + name); model.status_msg("Configuration added for interface " + name);
model.run_hook("unet_enroll", "join_done");
__network_enroll_cancel(model, ctx); __network_enroll_cancel(model, ctx);
} }
@ -681,8 +685,10 @@ function network_join(ctx, argv, named)
data.sub = model.ubus.subscriber((msg) => { data.sub = model.ubus.subscriber((msg) => {
if (msg.type == "enroll_peer_update") if (msg.type == "enroll_peer_update")
network_join_peer_update(ctx.model, ctx, msg); network_join_peer_update(ctx.model, ctx, msg);
else if (msg.type == "enroll_timeout") else if (msg.type == "enroll_timeout") {
ctx.model.run_hook("unet_enroll", "join_timeout");
__network_enroll_cancel(ctx.model, ctx); __network_enroll_cancel(ctx.model, ctx);
}
}); });
data.sub.subscribe("unetd"); data.sub.subscribe("unetd");
model.ubus.call("unetd", "enroll_start", req); model.ubus.call("unetd", "enroll_start", req);