kylefang/bitcoin-indexer
1
0
Fork 0
mirror of https://github.com/alexgo-io/bitcoin-indexer.git synced 2026-01-12 08:34:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: add option to skip chainhook node ping

Browse Source
This commit is contained in:
Rafael Cardenas
2023-06-28 21:32:32 -06:00
parent 72d43c6b41
commit a7c0b12ad9
1 changed files with 12 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
components/client/typescript/src/server.ts
View File

@@ -22,6 +22,7 @@ const ServerOptionsSchema = Type.Object({
port: Type.Integer(),
auth_token: Type.String(),
external_base_url: Type.String(),
wait_for_chainhook_node: Type.Boolean({ default: true }),
});
/** Local event server connection and authentication options */
export type ServerOptions = Static<typeof ServerOptionsSchema>;
@@ -92,6 +93,10 @@ export async function buildServer(
}
async function registerPredicates(this: FastifyInstance) {
if (predicates.length === 0) {
logger.info(`ChainhookEventObserver does not have predicates to register`);
return;
}
logger.info(
predicates,
`ChainhookEventObserver registering predicates at ${chainhookOpts.base_url}`
@@ -123,6 +128,10 @@ export async function buildServer(
}
async function removePredicates(this: FastifyInstance) {
if (predicates.length === 0) {
logger.info(`ChainhookEventObserver does not have predicates to close`);
return;
}
logger.info(`ChainhookEventObserver closing predicates at ${chainhookOpts.base_url}`);
const removals = predicates.map(
predicate =>
@@ -196,7 +205,9 @@ export async function buildServer(
bodyLimit: 41943040, // 40 MB
}).withTypeProvider<TypeBoxTypeProvider>();
fastify.addHook('onReady', waitForNode);
if (serverOpts.wait_for_chainhook_node) {
fastify.addHook('onReady', waitForNode);
}
fastify.addHook('onReady', registerPredicates);
fastify.addHook('onClose', removePredicates);