8785929091

Committed 22 Apr 2024 02:34PM UTC coverage: 93.11% (+0.5%) from 92.604%

Build # 8785929091

Build Type

Pull #1437

github

Committed by

hectorgomezv

Commit Message

PR comments

Pull Request Pull Request #1437: Add queues routes layer

Run Details

1943 of 2341 branches covered (83.0%)

Branch coverage included in aggregate %.

55 of 59 new or added lines in 7 files covered. (93.22%)

15 existing lines in 2 files now uncovered.

6949 of 7209 relevant lines covered (96.39%)

316.82 hits per line

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

87.5

/src/__tests__/amqp-client.factory.ts

import amqp, { ChannelWrapper } from 'amqp-connection-manager';
import { Channel } from 'amqplib';

export async function amqpClientFactory(): Promise<{
  channel: ChannelWrapper;
  queueName: string;
}> {
  const { AMQP_URL, AMQP_EXCHANGE_NAME, AMQP_EXCHANGE_MODE, AMQP_QUEUE } =
    process.env;

  if (!AMQP_URL || !AMQP_EXCHANGE_NAME || !AMQP_EXCHANGE_MODE || !AMQP_QUEUE) {
    throw new Error('Invalid amqpClientFactory configuration');
  }

  const connection = amqp.connect(AMQP_URL);
  const channel = connection.createChannel({
    json: true,
    setup: async (ch: Channel) => {
      await ch.assertExchange(AMQP_EXCHANGE_NAME, AMQP_EXCHANGE_MODE, {
        durable: true,
      });
      await ch.assertQueue(AMQP_QUEUE, { durable: true });
      await ch.bindQueue(AMQP_QUEUE, AMQP_EXCHANGE_NAME, '');
    },
  });

  return { channel, queueName: AMQP_QUEUE };
}

1	import amqp, { ChannelWrapper } from 'amqp-connection-manager';	2✔
2	import { Channel } from 'amqplib';
3
4	export async function amqpClientFactory(): Promise<{	2✔
5	channel: ChannelWrapper;
6	queueName: string;
7	}> {
8	const { AMQP_URL, AMQP_EXCHANGE_NAME, AMQP_EXCHANGE_MODE, AMQP_QUEUE } =
9	process.env;	2✔
10
11	if (!AMQP_URL \|\| !AMQP_EXCHANGE_NAME \|\| !AMQP_EXCHANGE_MODE \|\| !AMQP_QUEUE) {	2!
NEW 12	throw new Error('Invalid amqpClientFactory configuration');	×
13	}
14
15	const connection = amqp.connect(AMQP_URL);	2✔
16	const channel = connection.createChannel({	2✔
17	json: true,
18	setup: async (ch: Channel) => {
19	await ch.assertExchange(AMQP_EXCHANGE_NAME, AMQP_EXCHANGE_MODE, {	2✔
20	durable: true,
21	});
22	await ch.assertQueue(AMQP_QUEUE, { durable: true });	2✔
23	await ch.bindQueue(AMQP_QUEUE, AMQP_EXCHANGE_NAME, '');	2✔
24	},
25	});
26
27	return { channel, queueName: AMQP_QUEUE };	2✔
28	}

safe-global / safe-client-gateway / 8785929091

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