fix

Author: AmbientTea

toolkit/data-sources/db-sync/src/db_model.rs

@@ -23,15 +23,17 @@ pub(crate) enum TxInConfiguration {
 
 impl TxInConfiguration {
 	pub(crate) async fn from_connection(pool: &Pool<Postgres>) -> Result<Self, SqlxError> {
-		let query = sqlx::query_scalar::<_, i64>(
-			"select count(*) from information_schema.tables where table_name = 'tx_in';",
-		);
-
-		if query.fetch_all(pool).await?.first() == Some(&0) {
-			Ok(Self::Consumed)
-		} else {
-			Ok(Self::Legacy)
+		let consumed_by_tx_id_populated = sqlx::query_scalar::<_, bool>(
+			"SELECT EXISTS (SELECT 1 FROM tx_out where consumed_by_tx_id is not null);",
+		)
+		.fetch_one(pool)
+		.await?;
+
+		if consumed_by_tx_id_populated {
+			return Ok(Self::Consumed);
 		}
+
+		Ok(Self::Legacy)
 	}
 }