Add OHLC SOL prices by pool for SVM (#193)

Also disable the validation for the pagination since the endpoint SQL
doesn't use `LIMIT`/`OFFSET`.

Author: fschoell

src/routes/token/ohlc/pools/index.ts

@@ -1,9 +1,10 @@
 import { Hono } from 'hono';
 import evm from './evm.js';
+import svm from './svm.js';
 
 const router = new Hono();
 
 router.route('/evm', evm);
-// router.route('/svm', svm);
+router.route('/svm', svm);
 
 export default router;

src/routes/token/ohlc/pools/svm.ts

@@ -48,8 +48,8 @@ const responseSchema = apiUsageResponse.extend({
 
 const openapi = describeRoute(
     withErrorResponses({
-        summary: 'OHLCV by Pool',
-        description: 'Provides pricing data in the Open/High/Low/Close/Volume (OHCLV) format.',
+        summary: 'Solana OHLCV prices (SOL) by Pool',
+        description: 'Provides pricing data in native SOL in the Open/High/Low/Close/Volume (OHCLV) format.',
         tags: ['SVM'],
         security: [{ bearerAuth: [] }],
         responses: {
@@ -63,18 +63,20 @@ const openapi = describeRoute(
                                 value: {
                                     data: [
                                         {
-                                            datetime: '2025-06-20 00:00:00',
-                                            pool: '58oQChx4yWmvKdwLLZzBi4ChoCc2fqCUWBkwMihLYQo2',
-                                            token0: 'EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v',
+                                            datetime: '2025-09-15 00:00:00',
+                                            amm: 'pAMMBay6oceH9fJKBRHGP5D4bD4sWpmSwMn52FMfXEA',
+                                            pool: 'AmmpSnW5xVeKHTAU9fMjyKEMPgrzmUj3ah5vgvHhAB5J',
+                                            token0: '9BB6NFEcjBCtnNLFko2FqVQBq8HHM13kCyYcdQbgpump',
+                                            token0_decimals: 6,
                                             token1: 'So11111111111111111111111111111111111111112',
-                                            open: 146.64474747474748,
-                                            high: 147.71993287074972,
-                                            low: 145.0099569301824,
-                                            close: 147.36215787385962,
-                                            volume: 551499356.7426533,
-                                            uaw: 337,
-                                            transactions: 1021110,
-                                            network_id: 'solana',
+                                            token1_decimals: 9,
+                                            open: 0.003648785031942177,
+                                            high: 0.0036724218787403977,
+                                            low: 0.0034598947533987442,
+                                            close: 0.0035191405556241413,
+                                            volume: 3.521022449,
+                                            uaw: 76,
+                                            transactions: 159,
                                         },
                                     ],
                                 },
@@ -101,9 +103,10 @@ route.get(
         if (!dbConfig) {
             return c.json({ error: `Network not found: ${params.network_id}` }, 400);
         }
-        const query = sqlQueries.ohlcv_prices_for_pool?.[dbConfig.type];
+        let query = sqlQueries.ohlcv_prices_for_pool?.[dbConfig.type];
         if (!query) return c.json({ error: 'Query for OHLC pool data could not be loaded' }, 500);
 
+        query = query.replaceAll('{svm_metadata_db}', config.tokenDatabases[params.network_id]?.database || '');
         const response = await makeUsageQueryJson(
             c,
             [query],

src/sql/balances_for_account/svm.sql

@@ -82,4 +82,4 @@ SELECT
     {network_id:String}     AS network_id
 FROM filtered_balances AS b
 LEFT JOIN metadata USING mint
-ORDER BY timestamp DESC
+ORDER BY timestamp DESC

src/sql/ohlcv_prices_for_pool/svm.sql

@@ -1,33 +1,49 @@
-WITH decimals AS (
+WITH ohlc AS
+(
     SELECT
-        pool,
-        if(decimals0 = 0, 9, decimals0) AS decimals0,
-        if(decimals1 = 0, 9, decimals1) AS decimals1,
-        pow(10, -abs(decimals0 - decimals1)) AS decimals_factor
-    FROM ohlc_prices
-    WHERE pool = {pool: String}
+        if(
+            toTime(toStartOfInterval(o.timestamp, INTERVAL {interval:UInt64} MINUTE)) = toDateTime('1970-01-02 00:00:00'),
+            toDate(toStartOfInterval(o.timestamp, INTERVAL {interval:UInt64} MINUTE)),
+            toStartOfInterval(o.timestamp, INTERVAL {interval:UInt64} MINUTE)
+        ) AS datetime,
+        toString(o.amm) AS amm,
+        toString(o.amm_pool) AS pool,
+        toString(o.mint0) AS token0,
+        toString(o.mint1) AS token1,
+        argMinMerge(open0) AS open_raw,
+        quantileDeterministicMerge({high_quantile:Float64})(quantile0) AS high_raw,
+        quantileDeterministicMerge({low_quantile:Float64})(quantile0) AS low_raw,
+        argMaxMerge(close0) AS close_raw,
+        sum(gross_volume1) AS volume,
+        uniqMerge(uaw) AS uaw,
+        sum(transactions) AS transactions,
+        token0 IN {stablecoin_contracts: Array(String)} AS is_stablecoin
+    FROM ohlc_prices AS o
+    WHERE pool = {pool:String}
+    AND timestamp >= today() - toIntervalMinute(({offset:UInt64} + {limit:UInt64} - 1) * {interval:UInt64})
+    AND timestamp <= today() - toIntervalMinute({offset:UInt64} * {interval:UInt64})
+    GROUP BY token0, token1, amm, amm_pool, datetime
 )
 SELECT
-    if(
-        toTime(toStartOfInterval(o.timestamp, INTERVAL {interval: UInt64} MINUTE)) = toDateTime('1970-01-02 00:00:00'),
-        toDate(toStartOfInterval(o.timestamp, INTERVAL {interval: UInt64} MINUTE)),
-        toStartOfInterval(o.timestamp, INTERVAL {interval: UInt64} MINUTE)
-    ) AS datetime,
-    toString(pool) AS pool,
-    toString(token0) AS token0,
-    toString(token1) AS token1,
-    decimals_factor * argMinMerge(o.open0) AS open,
-    decimals_factor * quantileDeterministicMerge({high_quantile: Float32})(o.quantile0) AS high,
-    decimals_factor * quantileDeterministicMerge({low_quantile: Float32})(o.quantile0) AS low,
-    decimals_factor * argMaxMerge(o.close0) AS close,
-    sum(o.gross_volume0) AS volume,
-    uniqMerge(o.uaw) AS uaw,
-    sum(o.transactions) AS transactions,
-    {network_id: String} AS network_id
-FROM ohlc_prices AS o
-JOIN decimals USING pool
-WHERE pool = {pool: String} AND timestamp BETWEEN {startTime: UInt64} AND {endTime: UInt64}
-GROUP BY token0, token1, decimals_factor, pool, datetime
-ORDER BY datetime DESC
-LIMIT   {limit:UInt64}
-OFFSET  {offset:UInt64}
+    datetime,
+    amm,
+    pool,
+    token0,
+    coalesce(
+        (SELECT decimals FROM `{svm_metadata_db}`.mints WHERE mint IN (SELECT token0 FROM ohlc) AND decimals != 0),
+        9
+    ) AS token0_decimals,
+    token1,
+    coalesce(
+        (SELECT decimals FROM `{svm_metadata_db}`.mints WHERE mint IN (SELECT token1 FROM ohlc) AND decimals != 0),
+        9
+    ) AS token1_decimals,
+    pow(10, -(token1_decimals - token0_decimals)) * if(is_stablecoin, 1/open_raw, open_raw) AS open,
+    pow(10, -(token1_decimals - token0_decimals)) * if(is_stablecoin, 1/low_raw, high_raw) AS high,
+    pow(10, -(token1_decimals - token0_decimals)) * if(is_stablecoin, 1/high_raw, low_raw) AS low,
+    pow(10, -(token1_decimals - token0_decimals)) * if(is_stablecoin, 1/close_raw, close_raw) AS close,
+    pow(10, -(token1_decimals)) * toFloat64(volume) * if(is_stablecoin, close, 1) AS volume,
+    uaw,
+    transactions
+FROM ohlc AS o
+ORDER BY datetime DESC;

src/types/zod.ts

@@ -301,18 +301,17 @@ export const statisticsSchema = z.object({
     bytes_read: z.optional(z.number()),
 });
 
-export const paginationSchema = z
-    .object({
-        previous_page: z.coerce.number().int().min(1),
-        current_page: z.coerce.number().int().min(1),
-        next_page: z.coerce.number().int().min(1),
-        total_pages: z.coerce.number().int().min(1),
-    })
-    .refine(
-        ({ previous_page, current_page, next_page, total_pages }) =>
-            previous_page <= current_page && current_page <= next_page && next_page <= total_pages,
-        "Requested page doesn't exist"
-    );
+export const paginationSchema = z.object({
+    previous_page: z.coerce.number().int().min(1),
+    current_page: z.coerce.number().int().min(1),
+    next_page: z.coerce.number().int().min(1),
+    total_pages: z.coerce.number().int().min(1),
+});
+// .refine(
+//     ({ previous_page, current_page, next_page, total_pages }) =>
+//         previous_page <= current_page && current_page <= next_page && next_page <= total_pages,
+//     "Requested page doesn't exist"
+// );
 export type PaginationSchema = z.infer<typeof paginationSchema>;
 
 // ----------------------