Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "points-indexer"
version = "0.1.38"
version = "0.1.39"
edition = "2024"
resolver = "2"

Expand Down
6 changes: 3 additions & 3 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -5,12 +5,12 @@ Currently tracking:
- `eBABY`
- [x] Babylon
- [x] `HODL` points
- [x] `DEFI LP` (TowerFi) points
- [x] `DEFI SWAP` (TowerFi) points
- [x] `DEFI LP` (TowerFi) points (DISABLED)
- [x] `DEFI SWAP` (TowerFi) points (DISABLED)
- [x] Lottery tickets
- [x] Ethereum
- [x] `HODL` points
- [x] `DEFI LP` (Uniswap V3) points
- [x] `DEFI LP` (Uniswap V3) points (DISABLED)
- [x] Lottery tickets
- `eU`
- [x] Ethereum
Expand Down
4 changes: 2 additions & 2 deletions src/indexer/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -204,7 +204,7 @@ impl Indexer {

let mut should_increment = true;

if self.network.supports_defi_lp_points(&self.lst) {
if self.network.enabled_defi_lp_points(&self.lst) {
let latest_stored_defi_lp_height = sqlx::query_as::<_, UserDeFiLpPoint>(
format!(
"SELECT * FROM {} ORDER BY height DESC LIMIT 1",
Expand All @@ -222,7 +222,7 @@ impl Indexer {
should_increment && latest_stored_hodl_height == latest_stored_defi_lp_height;
}

if self.network.supports_swap_points() {
if self.network.enabled_swap_points() {
let latest_stored_defi_swap_height = sqlx::query_as!(
UserDeFiSwapPoint,
"SELECT * FROM babylon_user_point_defi_swap ORDER BY height DESC LIMIT 1"
Expand Down
12 changes: 6 additions & 6 deletions src/indexer/query_historical.rs
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,7 @@ impl QueryHistorical for Indexer {
let underlying_token = self.network.underlying_token(&self.lst);

for (token_addr, token) in self.network.lp_related_tokens(&self.lst, &self.config) {
if !self.network.supports_defi_lp_points(&self.lst)
if !self.network.enabled_defi_lp_points(&self.lst)
&& token_addr != self.network.underlying_token(&self.lst)
{
continue;
Expand Down Expand Up @@ -374,7 +374,7 @@ impl QueryHistorical for Indexer {
amount: decoded_transfer_log.value.to(),
});
}
if self.network.supports_defi_lp_points(&self.lst) {
if self.network.enabled_defi_lp_points(&self.lst) {
if *topic0 == IUniswapV3PoolEvents::Mint::SIGNATURE_HASH {
ethereum_lp_tx_hashes.insert(hash.clone());
let decoded_mint_log =
Expand Down Expand Up @@ -480,7 +480,7 @@ impl QueryHistorical for Indexer {
.await;

// HashMap<(lp, user_address), u128>
let mut lp_positions = if !self.network.supports_defi_lp_points(&self.lst) {
let mut lp_positions = if !self.network.enabled_defi_lp_points(&self.lst) {
HashMap::new()
} else {
future::join_all(self.network.lps(&self.lst, &self.config).iter().map(|lp| {
Expand Down Expand Up @@ -525,7 +525,7 @@ impl QueryHistorical for Indexer {
})
};

let lp_infos = if !self.network.supports_defi_lp_points(&self.lst) {
let lp_infos = if !self.network.enabled_defi_lp_points(&self.lst) {
HashMap::new()
} else {
let span = tracing::span!(tracing::Level::INFO, "lp_infos");
Expand Down Expand Up @@ -1330,7 +1330,7 @@ impl QueryHistorical for Indexer {
}
}

if self.network.supports_defi_lp_points(&self.lst) {
if self.network.enabled_defi_lp_points(&self.lst) {
// Store DEFI LP points
'store_defi_lp: {
let span = tracing::span!(tracing::Level::INFO, "store_defi_lp");
Expand Down Expand Up @@ -1629,7 +1629,7 @@ impl QueryHistorical for Indexer {
.instrument(tracing::span!(tracing::Level::INFO, "store_defi_lp_txs"))
});

if self.network.supports_swap_points() {
if self.network.enabled_swap_points() {
// Store DEFI SWAP points
'store_defi_swap: {
let span = tracing::span!(tracing::Level::INFO, "store_defi_swap");
Expand Down
8 changes: 4 additions & 4 deletions src/utils/network.rs
Original file line number Diff line number Diff line change
Expand Up @@ -132,15 +132,15 @@ impl IndexerNetwork {
IndexerLst::EU => config.union.initial_heights.clone(),
}
}
pub fn supports_defi_lp_points(&self, lst: &IndexerLst) -> bool {
pub fn enabled_defi_lp_points(&self, lst: &IndexerLst) -> bool {
match lst {
IndexerLst::EBaby => true,
IndexerLst::EBaby => false,
IndexerLst::EU => true,
}
}
pub fn supports_swap_points(&self) -> bool {
pub fn enabled_swap_points(&self) -> bool {
match self {
Self::Babylon => true,
Self::Babylon => false,
Self::Ethereum => false,
}
}
Expand Down