Fixing database_url for envio indexer and histoflux

0xIntuition · Jan 22, 2025 · 6199b4e · 6199b4e
1 parent 17f2d08
commit 6199b4e
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/docker-compose.yml b/docker-compose.yml
@@ -304,7 +304,7 @@ services:
       AWS_ACCESS_KEY_ID: $AWS_ACCESS_KEY_ID
       AWS_REGION: $AWS_REGION
       AWS_SECRET_ACCESS_KEY: $AWS_SECRET_ACCESS_KEY
-      DATABASE_URL: $DATABASE_URL
+      INDEXER_DATABASE_URL: $DATABASE_URL
       RAW_CONSUMER_QUEUE_URL: $RAW_CONSUMER_QUEUE_URL
       HYPERSYNC_TOKEN: $HYPERSYNC_TOKEN
       INDEXER_SCHEMA: $INDEXER_SCHEMA
@@ -332,7 +332,7 @@ services:
       AWS_ACCESS_KEY_ID: $AWS_ACCESS_KEY_ID
       AWS_REGION: $AWS_REGION
       AWS_SECRET_ACCESS_KEY: $AWS_SECRET_ACCESS_KEY 
-      DATABASE_URL: $DATABASE_URL
+      INDEXER_DATABASE_URL: $DATABASE_URL
       LOCALSTACK_URL: $LOCALSTACK_URL
       HISTOFLUX_CURSOR_ID: $HISTOFLUX_CURSOR_ID
     depends_on:

diff --git a/envio-indexer/src/app.rs b/envio-indexer/src/app.rs
@@ -16,7 +16,7 @@ pub struct Env {
     pub hypersync_token: String,
     pub localstack_url: Option<String>,
     pub raw_consumer_queue_url: String,
-    pub database_url: String,
+    pub indexer_database_url: String,
     pub indexer_schema: String,
 }
 
@@ -48,7 +48,7 @@ impl App {
         // Create the SQS client
         let aws_sqs_client = Self::get_aws_client(env.localstack_url.clone()).await;
         // Connect to the database
-        let pg_pool = connect_to_db(&env.database_url).await?;
+        let pg_pool = connect_to_db(&env.indexer_database_url).await?;
 
         Ok(Self {
             client,

diff --git a/histoflux/src/app_context.rs b/histoflux/src/app_context.rs
@@ -12,7 +12,7 @@ use sqlx::PgPool;
 #[derive(Clone, Deserialize, Debug)]
 pub struct Env {
     pub localstack_url: Option<String>,
-    pub database_url: String,
+    pub indexer_database_url: String,
     pub histoflux_cursor_id: i32,
 }
 
@@ -58,7 +58,7 @@ impl SqsProducer {
         // Create the SQS client
         let client = Self::get_aws_client(env.localstack_url.clone()).await;
         // Connect to the database
-        let pg_pool = connect_to_db(&env.database_url).await?;
+        let pg_pool = connect_to_db(&env.indexer_database_url).await?;
 
         let cursor = HistoFluxCursor::find(&pg_pool, env.histoflux_cursor_id)
             .await?