refactor tmdb api, cast&crew, node ext

2 files changed, 6 insertions, 2 deletions

diff --git a/base/src/database.rs b/base/src/database.rs
index f6f21bd..49645bc 100644
--- a/base/src/database.rs
+++ b/base/src/database.rs
@@ -6,7 +6,7 @@
 use bincode::{Decode, Encode};
 use jellycommon::{
     user::{NodeUserData, User},
-    Node,
+    ExtendedNode, Node,
 };
 use log::info;
 use serde::{Deserialize, Serialize};
@@ -19,8 +19,10 @@ pub const T_USER_NODE: TableDefinition<(&str, &str), Ser<NodeUserData>> =
     TableDefinition::new("user_node");
 pub const T_INVITE: TableDefinition<&str, Ser<()>> = TableDefinition::new("invite");
 pub const T_NODE: TableDefinition<&str, Ser<Node>> = TableDefinition::new("node");
+pub const T_NODE_EXTENDED: TableDefinition<&str, Ser<ExtendedNode>> =
+    TableDefinition::new("node-ext");
 pub const T_NODE_IMPORT: TableDefinition<&str, Ser<Vec<(Vec<usize>, Node)>>> =
-    TableDefinition::new("node_import");
+    TableDefinition::new("node-import");
 
 pub struct DataAcid {
     pub inner: redb::Database,
@@ -40,6 +42,7 @@ impl DataAcid {
             drop(txn.open_table(T_USER_NODE)?);
             drop(txn.open_table(T_NODE)?);
             drop(txn.open_table(T_NODE_IMPORT)?);
+            drop(txn.open_table(T_NODE_EXTENDED)?);
             txn.commit()?;
         }
 
diff --git a/base/src/federation.rs b/base/src/federation.rs
index 0041e26..542c535 100644
--- a/base/src/federation.rs
+++ b/base/src/federation.rs
@@ -37,6 +37,7 @@ impl Federation {
             .get(host)
             .ok_or(anyhow!("unknown instance"))?)
     }
+
     pub async fn get_session(&self, host: &String) -> anyhow::Result<Arc<Session>> {
         let mut w = self.sessions.write().await;
         if let Some(s) = w.get(host) {