8661734377

Committed 12 Apr 2024 12:04PM UTC coverage: 92.839% (-0.2%) from 93.001%

Build # 8661734377

Build Type

Pull #1382

github

Committed by

hectorgomezv

Commit Message

Refactor modules structure, add QueuesRepository

Pull Request Pull Request #1382: [WIP] PoC: consume events from TXS queue

Run Details

1939 of 2347 branches covered (82.62%)

Branch coverage included in aggregate %.

100 of 108 new or added lines in 15 files covered. (92.59%)

9 existing lines in 2 files now uncovered.

6786 of 7051 relevant lines covered (96.24%)

358.52 hits per line

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

82.35

/src/__tests__/retry.ts

/**
 * Stops execution for {@link milliseconds} milliseconds.
 */
export async function milliseconds(milliseconds: number): Promise<void> {
  await new Promise((_) => setTimeout(_, milliseconds));
}

/**
 * Executes the function {@link fn}, retrying if it throws an error.
 * Uses a linear strategy by retrying each {@link delayMs} milliseconds.
 * If {@link maxAttempts} is reached, it throws the error returned by {@link fn} last execution.
 */
export async function retry(
  fn: () => void,
  maxAttempts: number = 40,
  delayMs: number = 100,
): Promise<void> {
  let attempt = 0;
  const execute = async (): Promise<void> => {
    try {
      return await fn();
    } catch (error) {
      if (attempt >= maxAttempts) {
        throw error;
      }
    }

    await milliseconds(delayMs);
    attempt++;
    return execute();
  };
  return execute();
}

1	/**
2	* Stops execution for {@link milliseconds} milliseconds.
3	*/
4	export async function milliseconds(milliseconds: number): Promise<void> {	2✔
5	await new Promise((_) => setTimeout(_, milliseconds));	58✔
6	}
7
8	/**
9	* Executes the function {@link fn}, retrying if it throws an error.
10	* Uses a linear strategy by retrying each {@link delayMs} milliseconds.
11	* If {@link maxAttempts} is reached, it throws the error returned by {@link fn} last execution.
12	*/
13	export async function retry(	2✔
14	fn: () => void,
15	maxAttempts: number = 40,	33✔
16	delayMs: number = 100,	33✔
17	): Promise<void> {
18	let attempt = 0;	66✔
19	const execute = async (): Promise<void> => {	66✔
20	try {	124✔
21	return await fn();	124✔
22	} catch (error) {
23	if (attempt >= maxAttempts) {	58!
NEW 24	throw error;	×
25	}
26	}
27
28	await milliseconds(delayMs);	58✔
29	attempt++;	58✔
30	return execute();	58✔
31	};
32	return execute();	66✔
33	}

safe-global / safe-client-gateway / 8661734377

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