feat: unique index hypertable

Author: EvolveArt

compose.yaml

@@ -44,7 +44,7 @@ services:
       dockerfile: infra/pragma-node/Dockerfile
 
   db:
-    image: timescale/timescaledb:1.7.4-pg12
+    image: timescale/timescaledb-ha:pg14-latest
     restart: always
     user: postgres
     secrets:
@@ -61,7 +61,7 @@ services:
     expose:
       - 5432
     healthcheck:
-      test: ["CMD", "pg_isready"]
+      test: [ "CMD", "pg_isready" ]
       interval: 10s
       timeout: 5s
       retries: 5
@@ -102,7 +102,7 @@ services:
           "kafka-topics",
           "--list",
           "--bootstrap-server",
-          "pragma-kafka:9092",
+          "pragma-kafka:9092"
         ]
     environment:
       KAFKA_BROKER_ID: 1
@@ -153,6 +153,7 @@ volumes:
   pragma_zookeeper_data:
   pragma_zookeeper_logs:
 
+
 secrets:
   db-password:
     file: infra/db/password.txt

pragma-entities/migrations/2023-11-18-131303_add_entries_index/down.sql

@@ -1,2 +1,2 @@
 -- This file should undo anything in `up.sql`
-DROP INDEX IF EXISTS idx_entries_source;
+DROP INDEX IF EXISTS idx_entries_unique;

pragma-entities/migrations/2023-11-18-131303_add_entries_index/up.sql

@@ -1,3 +1,3 @@
 -- Your SQL goes here
-DROP INDEX IF EXISTS idx_entries_publisher_source_timestamp;
-CREATE INDEX idx_entries_source ON entries(source);
+CREATE UNIQUE INDEX idx_entries_unique
+  ON entries(pair_id, source, timestamp);

pragma-entities/migrations/2023-11-18-143139_add_composite_index/down.sql

@@ -1,2 +1,4 @@
 -- Your SQL goes here
-SELECT create_hypertable('entries', 'timestamp');
+SELECT create_hypertable('entries', by_range('timestamp'));
+SELECT * FROM add_dimension('entries', by_hash('pair_id', 4))
+SELECT * FROM add_dimension('entries', by_hash('source', 4))