Alter Swap model to make Candlestick views with timescaledb.continuous

src/demo_uniswap/models/__init__.py

@@ -336,7 +336,7 @@ class Swap(Model):
     # pointer to transaction
     transaction_hash = fields.TextField()
     # timestamp of transaction
-    timestamp = fields.BigIntField()
+    timestamp = fields.DatetimeField(index=True)
     # pool swap occured within
     pool: fields.ForeignKeyRelation[Pool] = fields.ForeignKeyField('models.Pool', related_name='swaps')
     # allow indexing by tokens
@@ -410,4 +410,4 @@ class Flash(Model):
     # amount token1 paid for flash
     amount1_paid = fields.DecimalField(decimal_places=18, max_digits=96, default=0)
     # index within the txn
-    log_index = fields.BigIntField()
+    log_index = fields.BigIntField()

src/demo_uniswap/sql/on_reindex/20_create_ca_quotes_1m.sql

@@ -1,25 +1,25 @@
--- CREATE MATERIALIZED VIEW
---     candlestick_1m
--- WITH (timescaledb.continuous) AS
---
--- SELECT
---     time_bucket('1 minute'::INTERVAL, to_timestamp(timestamp)) AS bucket,
---     token0_id as token_id,
---     candlestick_agg(
---         to_timestamp(timestamp),
---         abs(amount_usd/amount0),
---         amount_usd
---     ) as candlestick
--- FROM swap
---     WHERE
---         amount_usd!=0
---     AND
---         amount0!=0
---
--- GROUP BY
---     bucket,
---     token0_id
--- ORDER BY
---     bucket,
---     token0_id
--- WITH NO DATA;
+CREATE MATERIALIZED VIEW
+    candlestick_1m
+WITH (timescaledb.continuous) AS
+
+SELECT
+    time_bucket('1 minute'::INTERVAL, timestamp) AS bucket,
+    token0_id as token_id,
+    candlestick_agg(
+        timestamp,
+        abs(amount_usd/amount0),
+        amount_usd
+    ) as candlestick
+FROM swap
+    WHERE
+        amount_usd!=0
+    AND
+        amount0!=0
+
+GROUP BY
+    bucket,
+    token0_id
+ORDER BY
+    bucket,
+    token0_id
+WITH NO DATA;

src/demo_uniswap/sql/on_reindex/21_create_ca_quotes_1h.sql

@@ -0,0 +1,25 @@
+CREATE MATERIALIZED VIEW
+    candlestick_1h
+WITH (timescaledb.continuous) AS
+
+SELECT
+    time_bucket('1 hour'::INTERVAL, timestamp) AS bucket,
+    token0_id as token_id,
+    candlestick_agg(
+        timestamp,
+        abs(amount_usd/amount0),
+        amount_usd
+    ) as candlestick
+FROM swap
+    WHERE
+        amount_usd!=0
+    AND
+        amount0!=0
+
+GROUP BY
+    bucket,
+    token0_id
+ORDER BY
+    bucket,
+    token0_id
+WITH NO DATA;

src/demo_uniswap/sql/on_reindex/22_create_ca_quotes_1d.sql

@@ -0,0 +1,25 @@
+CREATE MATERIALIZED VIEW
+    candlestick_1d
+WITH (timescaledb.continuous) AS
+
+SELECT
+    time_bucket('1 day'::INTERVAL, timestamp) AS bucket,
+    token0_id as token_id,
+    candlestick_agg(
+        timestamp,
+        abs(amount_usd/amount0),
+        amount_usd
+    ) as candlestick
+FROM swap
+    WHERE
+        amount_usd!=0
+    AND
+        amount0!=0
+
+GROUP BY
+    bucket,
+    token0_id
+ORDER BY
+    bucket,
+    token0_id
+WITH NO DATA;