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

Revert "master -> mainnet"

Browse Source
This commit is contained in:
lowkeynicc
2025-05-27 21:20:42 -04:00
committed by GitHub
parent 0a846004a9
commit a01af128e9
5 changed files with 75 additions and 394 deletions
Download Patch File Download Diff File Expand all files Collapse all files

106
src/index.ts
View File

@@ -45,7 +45,6 @@ import {
import FEATURE_FLAGS from './utils/featureFlags';
import { getDLOBProviderFromOrderSubscriber } from './dlobProvider';
import { setGlobalDispatcher, Agent } from 'undici';
import { HermesClient } from '@pythnetwork/hermes-client';
setGlobalDispatcher(
new Agent({
@@ -77,9 +76,6 @@ const serverPort = process.env.PORT || 6969;
export const ORDERBOOK_UPDATE_INTERVAL = 1000;
const WS_FALLBACK_FETCH_INTERVAL = ORDERBOOK_UPDATE_INTERVAL * 60;
const useWebsocket = process.env.USE_WEBSOCKET?.toLowerCase() === 'true';
const hermesUrl = process.env.HERMES_ENDPOINT;
const pythLazerDriftToken = process.env.PYTH_LAZER_DRIFT_TOKEN;
const pythLazerEndpoint = process.env.PYTH_LAZER_ENDPOINT;
const logFormat =
':remote-addr - :remote-user [:date[clf]] ":method :url HTTP/:http-version" :status :res[content-length] ":referrer" ":user-agent" :req[x-forwarded-for]';
@@ -782,108 +778,6 @@ const main = async (): Promise<void> => {
}
});
app.get('/pythLazer', async (req, res, next) => {
try {
// Check origin validation
const origin = req.get('Origin') || req.get('Referer');
const allowedOrigins = ['https://app.drift.trade', 'https://beta.drift.trade'];
if (!origin || !allowedOrigins.some(allowed => origin.startsWith(allowed))) {
res.status(403).json({ error: 'Forbidden: Invalid origin' });
return;
}
const { feedIds } = req.query;
if (!feedIds) {
res.writeHead(400);
res.end('Bad Request: must include a feedIds');
return;
}
const feedIdsArray = (feedIds as string).split(',');
const latestLazerPricePayload = {
priceFeedIds: feedIdsArray?.map((f) => Number(f)),
properties: ['price', 'bestAskPrice', 'bestBidPrice', 'exponent'],
chains: ['solana'],
channel: 'real_time',
jsonBinaryEncoding: 'hex',
};
const latestPriceRes = await fetch(
pythLazerEndpoint,
{
method: 'POST',
headers: {
Authorization: `Bearer ${pythLazerDriftToken}`,
},
body: JSON.stringify(latestLazerPricePayload),
}
).then((res) => res.json());
const data = latestPriceRes.solana.data;
if (data) {
res.status(200).json({
data
});
return;
} else {
res.writeHead(404);
res.end('Not found');
}
} catch (err) {
next(err);
}
});
app.get('/pythPull', async (req, res, next) => {
try {
// Check origin validation
const origin = req.get('Origin') || req.get('Referer');
const allowedOrigins = ['https://app.drift.trade', 'https://beta.drift.trade'];
if (!origin || !allowedOrigins.some(allowed => origin.startsWith(allowed))) {
res.status(403).json({ error: 'Forbidden: Invalid origin' });
return;
}
const { feedIds } = req.query;
if (!feedIds) {
res.writeHead(400);
res.end('Bad Request: must include a feedIds');
return;
}
const feedIdsArray = (feedIds as string).split(',');
const hermesClient = new HermesClient(hermesUrl);
const latestPriceUpdates = await hermesClient.getLatestPriceUpdates(
feedIdsArray,
{
encoding: 'base64',
}
);
const data = latestPriceUpdates.binary.data.join('');
if (data) {
res.status(200).json({
data
});
return;
} else {
res.writeHead(404);
res.end('Not found');
}
} catch (err) {
next(err);
}
});
server.listen(serverPort, () => {
logger.info(`DLOB server listening on port http://localhost:${serverPort}`);
});