aljaz/lightning
1
0
Fork 0
mirror of https://github.com/aljazceru/lightning.git synced 2025-12-19 15:14:23 +01:00
Code Issues Packages Projects Releases Wiki Activity

plugin: Implement custom notification dispatch for plugins

Browse Source 
Changelog-Added: plugin: Plugins may now send custom notifications that other plugins can subscribe to.
This commit is contained in:
Christian Decker
2021-04-27 21:07:38 +02:00
committed by Rusty Russell
parent 9d310366af
commit f716c55983
1 changed files with 23 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
lightningd/plugin.c
View File

@@ -426,7 +426,8 @@ static const char *plugin_notification_handle(struct plugin *plugin,
const jsmntok_t *toks) const jsmntok_t *toks)
{ {
const jsmntok_t *methtok, *paramstok; const jsmntok_t *methtok, *paramstok;
const char *methname;
struct jsonrpc_notification *n;
methtok = json_get_member(plugin->buffer, toks, "method"); methtok = json_get_member(plugin->buffer, toks, "method");
paramstok = json_get_member(plugin->buffer, toks, "params"); paramstok = json_get_member(plugin->buffer, toks, "params");
@@ -447,6 +448,27 @@ static const char *plugin_notification_handle(struct plugin *plugin,
} else if (json_tok_streq(plugin->buffer, methtok, "message") } else if (json_tok_streq(plugin->buffer, methtok, "message")
|| json_tok_streq(plugin->buffer, methtok, "progress")) { || json_tok_streq(plugin->buffer, methtok, "progress")) {
return plugin_notify_handle(plugin, methtok, paramstok); return plugin_notify_handle(plugin, methtok, paramstok);
}
methname = json_strdup(tmpctx, plugin->buffer, methtok);
if (notifications_have_topic(plugin->plugins, methname)) {
n = tal(NULL, struct jsonrpc_notification);
n->method = tal_steal(n, methname);
n->stream = new_json_stream(n, NULL, NULL);
json_object_start(n->stream, NULL);
json_add_string(n->stream, "jsonrpc", "2.0");
json_add_string(n->stream, "method", methname);
json_add_tok(n->stream, "params", paramstok, plugin->buffer);
json_object_end(n->stream); /* closes '.' */
/* We guarantee to have \n\n at end of each response. */
json_stream_append(n->stream, "\n\n", strlen("\n\n"));
plugins_notify(plugin->plugins, take(n));
return NULL;
} else { } else {
return tal_fmt(plugin, "Unknown notification method %.*s", return tal_fmt(plugin, "Unknown notification method %.*s",
json_tok_full_len(methtok), json_tok_full_len(methtok),