machankura/mempool
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Always use local data for pending/historical accelerations

Browse Source
This commit is contained in:
Mononaut 2024-04-05 08:06:31 +00:00
parent efe43329a1
commit c8e7cc773a
No known key found for this signature in database
GPG Key ID: A3F058E41374C04E
1 changed files with 14 additions and 42 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
backend/src/api/acceleration/acceleration.routes.ts
View File

@ -18,51 +18,23 @@ class AccelerationRoutes {
} }
private async $getAcceleratorAccelerations(req: Request, res: Response): Promise<void> { private async $getAcceleratorAccelerations(req: Request, res: Response): Promise<void> {
if (config.MEMPOOL_SERVICES.PREFER_LOCAL) { const accelerations = mempool.getAccelerations();
const accelerations = mempool.getAccelerations(); res.status(200).send(Object.values(accelerations));
res.status(200).send(Object.values(accelerations));
} else {
const url = `${config.MEMPOOL_SERVICES.API}/${req.originalUrl.replace('/api/v1/services/', '')}`;
try {
const response = await axios.get(url, { responseType: 'stream', timeout: 10000 });
for (const key in response.headers) {
res.setHeader(key, response.headers[key]);
}
response.data.pipe(res);
} catch (e) {
logger.err(`Unable to get current accelerations from ${url} in $getAcceleratorAccelerations(), ${e}`, this.tag);
res.status(500).end();
}
}
} }
private async $getAcceleratorAccelerationsHistory(req: Request, res: Response): Promise<void> { private async $getAcceleratorAccelerationsHistory(req: Request, res: Response): Promise<void> {
if (config.MEMPOOL_SERVICES.PREFER_LOCAL) { const history = await AccelerationRepository.$getAccelerationInfo(null, req.query.blockHeight ? parseInt(req.query.blockHeight as string, 10) : null);
const history = await AccelerationRepository.$getAccelerationInfo(null, req.query.blockHeight ? parseInt(req.query.blockHeight as string, 10) : null); res.status(200).send(history.map(accel => ({
res.status(200).send(history.map(accel => ({ txid: accel.txid,
txid: accel.txid, added: accel.added,
added: accel.added, status: 'completed',
status: 'completed', effectiveFee: accel.effective_fee,
effectiveFee: accel.effective_fee, effectiveVsize: accel.effective_vsize,
effectiveVsize: accel.effective_vsize, boostRate: accel.boost_rate,
boostRate: accel.boost_rate, boostCost: accel.boost_cost,
boostCost: accel.boost_cost, blockHeight: accel.height,
blockHeight: accel.height, pools: [accel.pool],
pools: [accel.pool], })));
})));
} else {
const url = `${config.MEMPOOL_SERVICES.API}/${req.originalUrl.replace('/api/v1/services/', '')}`;
try {
const response = await axios.get(url, { responseType: 'stream', timeout: 10000 });
for (const key in response.headers) {
res.setHeader(key, response.headers[key]);
}
response.data.pipe(res);
} catch (e) {
logger.err(`Unable to get acceleration history from ${url} in $getAcceleratorAccelerationsHistory(), ${e}`, this.tag);
res.status(500).end();
}
}
} }
private async $getAcceleratorAccelerationsHistoryAggregated(req: Request, res: Response): Promise<void> { private async $getAcceleratorAccelerationsHistoryAggregated(req: Request, res: Response): Promise<void> {