graphops · cargopete · Jul 26, 2024
diff --git a/migrations/20230919165634_messages.down.sql b/migrations/20230919165634_messages.down.sql
diff --git a/migrations/20230919165634_messages.up.sql b/migrations/20230919165634_messages.up.sql
diff --git a/migrations/20240325124203_aggregates.down.sql b/migrations/20240325124203_aggregates.down.sql
diff --git a/migrations/20240325124203_aggregates.up.sql b/migrations/20240325124203_aggregates.up.sql
diff --git a/migrations/20240726113334_create_messages_and_indexer_aggregates_up.sql b/migrations/20240726113334_create_messages_and_indexer_aggregates_up.sql
@@ -0,0 +1,21 @@
+CREATE TABLE IF NOT EXISTS messages
+(
+    id     BIGSERIAL PRIMARY KEY,
+    message JSONB NOT NULL
+);
+
+CREATE TABLE IF NOT EXISTS indexer_aggregates
+(
+    id SERIAL PRIMARY KEY,
+    timestamp BIGINT NOT NULL,
+    graph_account VARCHAR(255) NOT NULL,
+    message_count BIGINT NOT NULL,
+    subgraphs_count BIGINT NOT NULL,
+    UNIQUE(graph_account, timestamp)
+);
+
+CREATE INDEX idx_message_nonce 
+ON messages ((CAST(message->>'nonce' AS BIGINT)));
+
+CREATE INDEX idx_message_graph_account 
+ON messages ((message->>'graph_account'));
diff --git a/migrations/20240726113339_create_messages_and_indexer_aggregates_down.sql b/migrations/20240726113339_create_messages_and_indexer_aggregates_down.sql
@@ -0,0 +1,5 @@
+DROP INDEX IF EXISTS idx_message_nonce;
+DROP INDEX IF EXISTS idx_message_graph_account;
+
+DROP TABLE IF EXISTS indexer_aggregates;
+DROP TABLE IF EXISTS messages;