sql: add support for listnetworkevents

Signed-off-by: Rusty Russell <rusty@rustcorp.com.au>
Changelog-Added: JSON-RPC: `sql` now supports the `networkevents` table.

Author: rustyrussell

plugins/Makefile

@@ -203,7 +203,7 @@ plugins/recover:  $(PLUGIN_RECOVER_OBJS) $(PLUGIN_LIB_OBJS) libcommon.a
 plugins/recklessrpc: $(PLUGIN_RECKLESSRPC_OBJS) $(PLUGIN_LIB_OBJS) libcommon.a
 
 # This covers all the low-level list RPCs which return simple arrays
-SQL_LISTRPCS := listchannels listforwards listhtlcs listinvoices listnodes listoffers listpeers listpeerchannels listclosedchannels listtransactions listsendpays listchainmoves listchannelmoves bkpr-listaccountevents bkpr-listincome
+SQL_LISTRPCS := listchannels listforwards listhtlcs listinvoices listnodes listoffers listpeers listpeerchannels listclosedchannels listtransactions listsendpays listchainmoves listchannelmoves bkpr-listaccountevents bkpr-listincome listnetworkevents
 SQL_LISTRPCS_SCHEMAS := $(foreach l,$(SQL_LISTRPCS),doc/schemas/$l.json)
 SQL_SCHEMA_PARTS := $(foreach l,$(SQL_LISTRPCS), plugins/sql-schema_$l_gen.h)
 

plugins/sql.c

@@ -1488,7 +1488,8 @@ static const struct refresh_funcs refresh_funcs[] = {
 	{ "listclosedchannels", default_refresh },
 	{ "listtransactions", default_refresh },
 	{ "bkpr-listaccountevents", default_refresh },
-	{ "bkpr-listincome", default_refresh }
+	{ "bkpr-listincome", default_refresh },
+	{ "listnetworkevents", default_refresh },
 };
 
 static const struct refresh_funcs *find_command_refresh(const char *cmdname)

tests/test_plugin.py

@@ -3890,7 +3890,23 @@ def test_sql(node_factory, bitcoind):
                         {'name': 'txid',
                          'type': 'txid'},
                         {'name': 'payment_id',
-                         'type': 'hex'}]}}
+                         'type': 'hex'}]},
+        'networkevents': {
+            'columns': [{'name': 'created_index',
+                         'type': 'u64'},
+                        {'name': 'timestamp',
+                         'type': 'u64'},
+                        {'name': 'peer_id',
+                         'type': 'pubkey'},
+                        {'name': 'type',
+                         'type': 'string'},
+                        {'name': 'reason',
+                         'type': 'string'},
+                        {'name': 'duration_nsec',
+                         'type': 'u64'},
+                        {'name': 'connect_attempted',
+                         'type': 'boolean'}]},
+    }
 
     sqltypemap = {'string': 'TEXT',
                   'boolean': 'INTEGER',