9686884963

Committed 26 Jun 2024 09:17PM UTC coverage: 14.435% (-0.2%) from 14.62%

Build # 9686884963

Build Type

Pull #8261

github

Committed by

web-flow

Commit Message

Merge a01884011 into 4b0cef8c2

Pull Request Pull Request #8261: Fix to remove useNotificationSubscriptions

Run Details

3519 of 23068 branches covered (15.25%)

Branch coverage included in aggregate %.

0 of 1 new or added line in 1 file covered. (0.0%)

84 existing lines in 4 files now uncovered.

4814 of 34659 relevant lines covered (13.89%)

4.65 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/packages/commonwealth/server/workers/evmChainEvents/startEvmPolling.ts

import { dispose, logger } from '@hicommonwealth/core';
import { models } from '@hicommonwealth/model';
import { fileURLToPath } from 'url';
import { config } from '../../config';
import { processChainNode, scheduleNodeProcessing } from './nodeProcessing';

const __filename = fileURLToPath(import.meta.url);
const log = logger(__filename);

/**
 * Starts an infinite loop that periodically fetches and parses blocks from
 * relevant EVM blockchains. Events parsed from these blocks are emitted
 * as chain-event notifications. The interval between each fetch is specified in milliseconds and should be
 * no more than 500k ms (500 seconds) so that we support any EVM chain that has an average block time of
 * 1 second or more (block fetching is limited to 500 blocks per interval). The recommended interval
 * is 120_000 ms (120 seconds) to avoid issues with public EVM nodes rate limiting requests.
 */
export async function startEvmPolling(
  interval: number,
): Promise<NodeJS.Timeout> {
  log.info(`Starting EVM poller`);
  if (interval > 500_000) {
    throw new Error(
      `Interval for EVM polling must be less than 500_000 ms (500 seconds)`,
    );
  }

  log.info(
    `All chains will be polled for events every ${interval / 1000} seconds`,
  );
  await scheduleNodeProcessing(models, interval, processChainNode);
  return setInterval(
    scheduleNodeProcessing,
    interval,
    models,
    interval,
    processChainNode,
  );
}

if (import.meta.url.endsWith(process.argv[1])) {
  startEvmPolling(config.WORKERS.EVM_CE_POLL_INTERVAL_MS).catch((e) => {
    log.fatal('Evm poller shutting down due to a critical error:', e);
    // eslint-disable-next-line @typescript-eslint/no-floating-promises
    dispose()('ERROR', true);
  });
}

1	import { dispose, logger } from '@hicommonwealth/core';
2	import { models } from '@hicommonwealth/model';
3	import { fileURLToPath } from 'url';
4	import { config } from '../../config';
5	import { processChainNode, scheduleNodeProcessing } from './nodeProcessing';
6
UNCOV 7	const __filename = fileURLToPath(import.meta.url);	×
UNCOV 8	const log = logger(__filename);	×
9
10	/**
11	* Starts an infinite loop that periodically fetches and parses blocks from
12	* relevant EVM blockchains. Events parsed from these blocks are emitted
13	* as chain-event notifications. The interval between each fetch is specified in milliseconds and should be
14	* no more than 500k ms (500 seconds) so that we support any EVM chain that has an average block time of
15	* 1 second or more (block fetching is limited to 500 blocks per interval). The recommended interval
16	* is 120_000 ms (120 seconds) to avoid issues with public EVM nodes rate limiting requests.
17	*/
18	export async function startEvmPolling(
19	interval: number,
20	): Promise<NodeJS.Timeout> {
UNCOV 21	log.info(`Starting EVM poller`);	×
UNCOV 22	if (interval > 500_000) {	×
23	throw new Error(	×
24	`Interval for EVM polling must be less than 500_000 ms (500 seconds)`,
25	);
26	}
27
UNCOV 28	log.info(	×
29	`All chains will be polled for events every ${interval / 1000} seconds`,
30	);
UNCOV 31	await scheduleNodeProcessing(models, interval, processChainNode);	×
UNCOV 32	return setInterval(	×
33	scheduleNodeProcessing,
34	interval,
35	models,
36	interval,
37	processChainNode,
38	);
39	}
40
UNCOV 41	if (import.meta.url.endsWith(process.argv[1])) {	×
42	startEvmPolling(config.WORKERS.EVM_CE_POLL_INTERVAL_MS).catch((e) => {	×
43	log.fatal('Evm poller shutting down due to a critical error:', e);	×
44	// eslint-disable-next-line @typescript-eslint/no-floating-promises
45	dispose()('ERROR', true);	×
46	});
47	}

hicommonwealth / commonwealth / 9686884963

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous