data-observatory: renamed transactions to payments because there is already transaction in the base scraper schema

nym-data-observatory/migrations/002_payment_transactions.sql

@@ -1,4 +1,4 @@
-CREATE TABLE transactions (
+CREATE TABLE payments (
     id INTEGER PRIMARY KEY AUTOINCREMENT,
     transaction_hash TEXT NOT NULL UNIQUE,
     sender_address TEXT NOT NULL,

nym-data-observatory/src/db/models.rs

@@ -31,7 +31,7 @@ pub(crate) struct PriceHistory {
 }
 
 #[derive(Serialize, Deserialize, Debug, ToSchema)]
-pub(crate) struct PaymentTransaction {
+pub(crate) struct PaymentRecord {
     pub(crate) transaction_hash: String,
     pub(crate) sender_address: String,
     pub(crate) receiver_address: String,

nym-data-observatory/src/db/queries/payments.rs

@@ -2,7 +2,7 @@ use crate::db::DbPool;
 use anyhow::Result;
 
 pub async fn get_last_checked_height(pool: &DbPool) -> Result<i64> {
-    let result = sqlx::query_scalar!("SELECT MAX(height) FROM transactions")
+    let result = sqlx::query_scalar!("SELECT MAX(height) FROM payments")
         .fetch_one(pool)
         .await?;
     Ok(result.unwrap_or(0))
@@ -21,7 +21,7 @@ pub async fn insert_payment(
 
     sqlx::query!(
         r#"
-        INSERT INTO transactions (
+        INSERT INTO payments (
             transaction_hash, sender_address, receiver_address,
             amount, height, timestamp, memo
         ) VALUES (?, ?, ?, ?, ?, ?, ?)

nym-data-observatory/src/http/api_docs.rs

@@ -6,5 +6,9 @@ use utoipauto::utoipauto;
 // https://github.com/ProbablyClem/utoipauto/issues/13#issuecomment-1974911829
 #[utoipauto(paths = "./nym-data-observatory/src")]
 #[derive(OpenApi)]
-#[openapi(info(title = "Nym API"), tags(), components(schemas()))]
+#[openapi(
+    info(title = "Nym Data Observatory API"),
+    tags(),
+    components(schemas())
+)]
 pub(super) struct ApiDoc;

nym-data-observatory/src/payment_listener/mod.rs

@@ -37,7 +37,7 @@ pub(crate) async fn run_payment_listener(
             .await?;
 
         for tx in transactions {
-            println!("Processing transaction: {}", tx.hash);
+            tracing::info!("Processing transaction: {}", tx.hash);
             if let Some(raw_log) = tx.raw_log.as_deref() {
                 if let Some(transfer) = parse_transfer_from_raw_log(raw_log)? {
                     if transfer.recipient == payment_receive_address {