Merge branch 'develop' of https://github.com/astraly-labs/pragma-node into develop

Author: EvolveArt

compose.yaml

@@ -30,6 +30,10 @@ services:
   #         condition: service_healthy
   pragma-node:
     container_name: "pragma-node"
+    environment:
+      - DATABASE_MAX_CONN=5
+      - TOPIC=pragma-data
+      - KAFKA_BROKERS=pragma-kafka:9092
     depends_on:
       pragma-kafka:
         condition: service_healthy
@@ -119,6 +123,12 @@ services:
 
   pragma-ingestor-1:
     container_name: "pragma-ingestor-1"
+    environment:
+      - DATABASE_URL=postgres://postgres:test-password@db:5432/pragma
+      - DATABASE_MAX_CONN=5
+      - BROKERS=pragma-kafka:9092
+      - TOPIC=pragma-data
+      - GROUP_ID=pragma-data
     depends_on:
       pragma-kafka:
         condition: service_healthy
@@ -129,10 +139,6 @@ services:
       - pragma-db-network
     build:
       dockerfile: infra/pragma-ingestor/Dockerfile
-    environment:
-      BROKERS: pragma-kafka:9092
-      TOPIC: pragma-data
-      GROUP_ID: pragma-data
 
 networks:
   pragma-db-network:

pragma-entities/migrations/2023-12-29-052754_add_hypertable_entries/down.sql

@@ -1,2 +1,2 @@
 -- This file should undo anything in `up.sql`
-SELECT detach_table('entries');
+SELECT detach_table('entries');

pragma-ingestor/Cargo.toml

@@ -11,7 +11,7 @@ envy = "0.4.2"
 lazy_static = "1.4.0"
 pragma-common = { path = "../pragma-common", version = "1.0.0" }
 pragma-entities = { path = "../pragma-entities", version = "1.0.0" }
-rdkafka = "0.35.0"
+rdkafka = "0.36.0"
 serde = "1.0.193"
 serde_json = "1.0.108"
 thiserror = "1.0.50"

pragma-node/Cargo.toml

@@ -21,7 +21,7 @@ envy = "0.4.2"
 lazy_static = "1.4.0"
 pragma-common = { path = "../pragma-common", version = "1.0.0" }
 pragma-entities = { path = "../pragma-entities", version = "1.0.0" }
-rdkafka = "0.35.0"
+rdkafka = "0.36.0"
 serde = { version = "1.0", features = ["derive"] }
 serde_json = { version = "1.0", features = ["arbitrary_precision"] }
 starknet = "0.6.0"