trade/trade-deploy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(hasura): track derived dlob stats tables

Browse Source
This commit is contained in:
u1
2026-01-10 11:26:13 +00:00
parent 1b1603c8f0
commit 45a637f545
1 changed files with 43 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
kustomize/base/hasura/hasura-bootstrap.mjs
View File

@@ -95,6 +95,8 @@ async function main() {
const baseTicks = { schema: 'public', name: 'drift_ticks' }; const baseTicks = { schema: 'public', name: 'drift_ticks' };
const dlobL2LatestTable = { schema: 'public', name: 'dlob_l2_latest' }; const dlobL2LatestTable = { schema: 'public', name: 'dlob_l2_latest' };
const dlobStatsLatestTable = { schema: 'public', name: 'dlob_stats_latest' }; const dlobStatsLatestTable = { schema: 'public', name: 'dlob_stats_latest' };
const dlobDepthBpsLatestTable = { schema: 'public', name: 'dlob_depth_bps_latest' };
const dlobSlippageLatestTable = { schema: 'public', name: 'dlob_slippage_latest' };
const baseCandlesFn = { schema: 'public', name: 'get_drift_candles' }; const baseCandlesFn = { schema: 'public', name: 'get_drift_candles' };
const candlesReturnTable = { schema: 'public', name: 'drift_candles' }; const candlesReturnTable = { schema: 'public', name: 'drift_candles' };
@@ -252,6 +254,47 @@ async function main() {
'updated_at', 'updated_at',
]); ]);
await ensureDlobTable(dlobDepthBpsLatestTable, [
'market_name',
'band_bps',
'market_type',
'market_index',
'ts',
'slot',
'mid_price',
'best_bid_price',
'best_ask_price',
'bid_base',
'ask_base',
'bid_usd',
'ask_usd',
'imbalance',
'raw',
'updated_at',
]);
await ensureDlobTable(dlobSlippageLatestTable, [
'market_name',
'side',
'size_usd',
'market_type',
'market_index',
'ts',
'slot',
'mid_price',
'best_bid_price',
'best_ask_price',
'vwap_price',
'worst_price',
'filled_usd',
'filled_base',
'impact_bps',
'levels_consumed',
'fill_pct',
'raw',
'updated_at',
]);
// Return table type for candle functions (needed for Hasura to track the function). // Return table type for candle functions (needed for Hasura to track the function).
await metadataIgnore({ type: 'pg_track_table', args: { source, table: candlesReturnTable } }); await metadataIgnore({ type: 'pg_track_table', args: { source, table: candlesReturnTable } });