txcount native asset reducer

txpipe · Sep 17, 2022 · 4c9579b · 4c9579b
1 parent c30a80b
commit 4c9579b
Show file tree

Hide file tree

Showing 16 changed files with 46 additions and 794 deletions.
diff --git a/.gitignore b/.gitignore
@@ -8,8 +8,8 @@
 
 # These are backup files generated by rustfmt
 **/*.rs.bk
-daemon.toml
-daemon.json
+daemon*.toml
+daemon*.json
 
 # Mac Files
 .DS_Store

diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -12,8 +12,8 @@ authors = ["Santiago Carmuega <santiago@carmuega.me>"]
 
 
 [dependencies]
-#pallas = "0.14.0-alpha.3"
-pallas = { path = "../pallas/pallas" }
+pallas = "0.14.0-alpha.3"
+# pallas = { path = "../pallas/pallas" }
 # pallas = { git = "https://github.com/txpipe/pallas.git" }
 hex = "0.4.3"
 net2 = "0.2.37"

diff --git a/src/enrich/sled.rs b/src/enrich/sled.rs
@@ -275,4 +275,4 @@ impl gasket::runtime::Worker for Worker {
             None => Ok(()),
         }
     }
-}
+}
diff --git a/src/model.rs b/src/model.rs
@@ -75,7 +75,6 @@ pub type Set = String;
 pub type Member = String;
 pub type Key = String;
 pub type Delta = i64;
-pub type LargeDelta = i128;
 pub type Timestamp = u64;
 
 #[derive(Debug)]
@@ -110,8 +109,6 @@ pub enum CRDTCommand {
     BlockStarting(Point),
     SetAdd(Set, Member),
     SetRemove(Set, Member),
-    SortedSetAdd(Set, Member, Delta),
-    SortedSetRemove(Set, Member, Delta),
     TwoPhaseSetAdd(Set, Member),
     TwoPhaseSetRemove(Set, Member),
     GrowOnlySetAdd(Set, Member),
@@ -171,7 +168,7 @@ impl CRDTCommand {
         V: Into<Value>,
     {
         let key = match prefix {
-        Some(prefix) => format!("{}.{}", prefix, key),
+            Some(prefix) => format!("{}.{}", prefix, key),
             None => key.to_string(),
         };
 

diff --git a/src/reducers/asset_holders_by_asset.rs b/src/reducers/asset_holders_by_asset.rs
diff --git a/src/reducers/balance_by_script.rs b/src/reducers/balance_by_script.rs
-Original file line number
+Diff line change
@@ Expand Up / @@ -275,4 +275,4 @@ impl gasket::runtime::Worker for Worker { @@
                 None => Ok(()),
             }
         }
-    }
+    }