Run fmt

Author: fabubaker

raphtory-storage/src/mutation/mod.rs

@@ -22,8 +22,7 @@ use std::sync::Arc;
 use storage::{
     error::StorageError,
     pages::{
-        edge_page::writer::EdgeWriter,
-        graph_prop_page::writer::GraphPropWriter,
+        edge_page::writer::EdgeWriter, graph_prop_page::writer::GraphPropWriter,
         node_page::writer::NodeWriter,
     },
     resolver::mapping_resolver::InvalidNodeId,

raphtory/src/db/api/mutation/addition_ops.rs

@@ -16,12 +16,10 @@ use raphtory_api::core::{
     },
     utils::time::{IntoTimeWithFormat, TryIntoInputTime},
 };
-use raphtory_storage::{
-    mutation::{
-        addition_ops::{EdgeWriteLock, InternalAdditionOps, NodeWriteLock},
-        durability_ops::DurabilityOps,
-        MutationError,
-    },
+use raphtory_storage::mutation::{
+    addition_ops::{EdgeWriteLock, InternalAdditionOps, NodeWriteLock},
+    durability_ops::DurabilityOps,
+    MutationError,
 };
 use storage::wal::{GraphWalOps, WalOps};
 

raphtory/src/db/api/storage/storage.rs

@@ -4,7 +4,7 @@ use crate::{
         internal::{InheritEdgeHistoryFilter, InheritNodeHistoryFilter, InternalStorageOps},
         Base, InheritViewOps,
     },
-    errors::GraphError,
+    errors::{into_graph_err, GraphError},
 };
 use db4_graph::{TemporalGraph, WriteLockedGraph};
 use raphtory_api::core::{
@@ -24,7 +24,7 @@ use raphtory_storage::{
     layer_ops::InheritLayerOps,
     mutation::{
         addition_ops::{EdgeWriteLock, InternalAdditionOps, SessionAdditionOps},
-        addition_ops_ext::{AtomicAddEdge, UnlockedSession},
+        addition_ops_ext::{AtomicAddEdge, AtomicAddNode, UnlockedSession},
         deletion_ops::InternalDeletionOps,
         durability_ops::DurabilityOps,
         property_addition_ops::InternalPropertyAdditionOps,
@@ -37,8 +37,6 @@ use std::{
     sync::Arc,
 };
 use storage::wal::{GraphWalOps, WalOps, LSN};
-use crate::{errors::into_graph_err};
-use raphtory_storage::mutation::addition_ops_ext::AtomicAddNode;
 
 // Re-export for raphtory dependencies to use when creating graphs.
 pub use storage::{persist::strategy::PersistenceStrategy, Config, Extension};

raphtory/src/db/graph/edge.rs

@@ -443,7 +443,11 @@ impl<G: StaticGraphViewOps + PropertyAdditionOps + AdditionOps> EdgeView<G> {
 
         let mut writer = self
             .graph
-            .atomic_add_edge(NodeRef::Internal(src), NodeRef::Internal(dst), Some(edge_id))
+            .atomic_add_edge(
+                NodeRef::Internal(src),
+                NodeRef::Internal(dst),
+                Some(edge_id),
+            )
             .map_err(into_graph_err)?;
 
         let props_for_wal = props_with_status
@@ -454,7 +458,7 @@ impl<G: StaticGraphViewOps + PropertyAdditionOps + AdditionOps> EdgeView<G> {
             })
             .collect::<Vec<_>>();
 
-       let lsn = wal
+        let lsn = wal
             .log_add_edge(
                 transaction_id,
                 t,

raphtory/src/db/graph/node.rs

@@ -39,8 +39,11 @@ use raphtory_api::core::{
 use raphtory_storage::{
     core_ops::CoreGraphOps,
     graph::graph::GraphStorage,
-    mutation::{addition_ops::{InternalAdditionOps, NodeWriteLock},
-    durability_ops::DurabilityOps, MutationError},
+    mutation::{
+        addition_ops::{InternalAdditionOps, NodeWriteLock},
+        durability_ops::DurabilityOps,
+        MutationError,
+    },
 };
 use std::{
     fmt,
@@ -505,13 +508,9 @@ impl<G: StaticGraphViewOps + PropertyAdditionOps + AdditionOps> NodeView<'static
 
         writer.set_type(new_type_id);
 
-        let lsn = wal.log_set_node_type(
-            transaction_id,
-            vid,
-            new_type,
-            new_type_id,
-        )
-        .map_err(into_graph_err)?;
+        let lsn = wal
+            .log_set_node_type(transaction_id, vid, new_type, new_type_id)
+            .map_err(into_graph_err)?;
 
         writer.set_lsn(lsn);
         transaction_manager.end_transaction(transaction_id);