wip

Author: SwenSchaeferjohann

Cargo.lock

@@ -7,7 +7,7 @@ name = "photon-indexer"
 publish = true
 readme = "README.md"
 repository = "https://github.com/helius-labs/photon"
-version = "0.51.1"
+version = "0.51.2"
 
 [[bin]]
 name = "photon"

Cargo.toml

@@ -344,22 +344,7 @@ async fn execute_account_update_query_and_update_balances(
         let prev_spent: Option<bool> = row.try_get("", "prev_spent")?;
         match (prev_spent, &modification_type) {
             (_, ModificationType::Append) | (Some(false), ModificationType::Spend) => {
-                // SQLite: columns are TEXT after migration, read as String and parse
-                // Postgres: columns are DECIMAL, read directly as Decimal
-                let mut amount_of_interest = match db_backend {
-                    DatabaseBackend::Postgres => row.try_get("", balance_column)?,
-                    DatabaseBackend::Sqlite => {
-                        let amount_str: String = row.try_get("", balance_column)?;
-                        let amount_u64 = amount_str.parse::<u64>().map_err(|_| {
-                            IngesterError::DatabaseError(format!(
-                                "Invalid {} value in SQLite: {}",
-                                balance_column, amount_str
-                            ))
-                        })?;
-                        Decimal::from(amount_u64)
-                    }
-                    _ => panic!("Unsupported database backend"),
-                };
+                let mut amount_of_interest: Decimal = row.try_get("", balance_column)?;
                 amount_of_interest *= multiplier;
                 let owner = bytes_to_sql_format(db_backend, row.try_get("", "owner")?);
                 let key = match account_type {
@@ -381,40 +366,19 @@ async fn execute_account_update_query_and_update_balances(
         }
     }
 
-    // Format values for INSERT - SQLite uses TEXT columns, Postgres uses DECIMAL
     let values = balance_modifications
         .into_iter()
         .filter(|(_, value)| *value != Decimal::from(0))
-        .map(|(key, value)| {
-            match db_backend {
-                DatabaseBackend::Sqlite => {
-                    // Store as quoted string for TEXT column
-                    format!("({}, '{}')", key, value)
-                }
-                _ => {
-                    // Postgres: numeric value
-                    format!("({}, {})", key, value)
-                }
-            }
-        })
+        .map(|(key, value)| format!("({}, {})", key, value))
         .collect::<Vec<String>>();
 
     if !values.is_empty() {
         let values_string = values.join(", ");
-        // SQLite: TEXT columns require CAST for arithmetic operations
-        // Postgres: DECIMAL columns support direct arithmetic
-        let raw_sql = match db_backend {
-            DatabaseBackend::Sqlite => format!(
-                "INSERT INTO {owner_table_name} (owner {additional_columns}, {balance_column})
-                VALUES {values_string} ON CONFLICT (owner{additional_columns})
-                DO UPDATE SET {balance_column} = CAST(CAST({owner_table_name}.{balance_column} AS INTEGER) + CAST(excluded.{balance_column} AS INTEGER) AS TEXT)",
-            ),
-            _ => format!(
-                "INSERT INTO {owner_table_name} (owner {additional_columns}, {balance_column})
-                VALUES {values_string} ON CONFLICT (owner{additional_columns})
-                DO UPDATE SET {balance_column} = {owner_table_name}.{balance_column} + excluded.{balance_column}",
-            ),
-        };
+        let raw_sql = format!(
+            "INSERT INTO {owner_table_name} (owner {additional_columns}, {balance_column})
+            VALUES {values_string} ON CONFLICT (owner{additional_columns})
+            DO UPDATE SET {balance_column} = {owner_table_name}.{balance_column} + excluded.{balance_column}",
+        );
         txn.execute(Statement::from_string(db_backend, raw_sql))
             .await?;
     }

src/ingester/persist/mod.rs

@@ -14,7 +14,6 @@ pub mod m20250909_000001_add_queue_hash_chains;
 pub mod m20250910_000002_add_v2_queue_indexes;
 pub mod m20250923_000001_add_tree_metadata;
 pub mod m20251021_000001_optimize_nullifier_queue_index;
-pub mod m20251127_000001_sqlite_precision_fix;
 
 pub fn get_standard_migrations() -> Vec<Box<dyn MigrationTrait>> {
     vec![
@@ -32,6 +31,6 @@ pub fn get_standard_migrations() -> Vec<Box<dyn MigrationTrait>> {
         Box::new(m20250910_000002_add_v2_queue_indexes::Migration),
         Box::new(m20250923_000001_add_tree_metadata::Migration),
         Box::new(m20251021_000001_optimize_nullifier_queue_index::Migration),
-        Box::new(m20251127_000001_sqlite_precision_fix::Migration),
+        // m20251127_000001_sqlite_precision_fix disabled - SeaORM Decimal maps to REAL in SQLite
     ]
 }