X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=src%2Fpersistence.rs;fp=src%2Fpersistence.rs;h=e0c734d7a0907cce82401c8a2696625efcd72212;hb=c5ad40eba4f970b0025cf590a1e2195a67cd541d;hp=a7cfb37caca8c17c9a21541f9e10d934d2c13477;hpb=a18c25649b77ec422bdbdffc530748b0a3ec64dd;p=rapid-gossip-sync-server

diff --git a/src/persistence.rs b/src/persistence.rs
index a7cfb37..e0c734d 100644
--- a/src/persistence.rs
+++ b/src/persistence.rs
@@ -69,21 +69,20 @@ impl<L: Deref> GossipPersister<L> where L::Target: Logger {
 				panic!("db init error: {}", initialization_error);
 			}
 
-			let initialization = client
-				.execute(config::db_announcement_table_creation_query(), &[])
-				.await;
-			if let Err(initialization_error) = initialization {
-				panic!("db init error: {}", initialization_error);
-			}
+			let table_creation_queries = [
+				config::db_announcement_table_creation_query(),
+				config::db_channel_update_table_creation_query(),
+				config::db_channel_update_table_creation_query(),
+				config::db_node_announcement_table_creation_query()
+			];
 
-			let initialization = client
-				.execute(
-					config::db_channel_update_table_creation_query(),
-					&[],
-				)
-				.await;
-			if let Err(initialization_error) = initialization {
-				panic!("db init error: {}", initialization_error);
+			for current_table_creation_query in table_creation_queries {
+				let initialization = client
+					.execute(current_table_creation_query, &[])
+					.await;
+				if let Err(initialization_error) = initialization {
+					panic!("db init error: {}", initialization_error);
+				}
 			}
 
 			let initialization = client
@@ -133,6 +132,9 @@ impl<L: Deref> GossipPersister<L> where L::Target: Logger {
 
 			let connections_cache_ref = Arc::clone(&connections_cache);
 			match gossip_message {
+				GossipMessage::NodeAnnouncement(_announcement, _seen_override) => {
+
+				},
 				GossipMessage::ChannelAnnouncement(announcement, seen_override) => {
 					let scid = announcement.contents.short_channel_id as i64;