test(amqp-sender): add tests for queue, topic, binding and publish

Author: juanmarin-co

src/adapter/amqp/amqp-sender.ts

@@ -4,7 +4,7 @@ import { ConfirmChannel } from 'amqplib'
 import {
   BrokerSender,
   QueueSpecitication,
-  ExchangeSpecification,
+  TopicSpecification,
   BindingSpecification
 } from '../../domain/model/broker.model'
 
@@ -15,7 +15,7 @@ export class AmqpSender implements BrokerSender {
     return this.channel.addSetup((channel: ConfirmChannel) => channel.assertQueue(name, rest))
   }
 
-  declareTopic({ name }: ExchangeSpecification): Promise<void> {
+  declareTopic({ name }: TopicSpecification): Promise<void> {
     return this.channel.addSetup((channel: ConfirmChannel) => channel.assertExchange(name, 'topic'))
   }
 

src/domain/model/broker.model.ts

@@ -3,7 +3,7 @@ export interface QueueSpecitication {
   exclusive: boolean
 }
 
-export interface ExchangeSpecification {
+export interface TopicSpecification {
   name: string
 }
 
@@ -23,7 +23,7 @@ export type MessageConsumer = (messageContent: object) => Promise<void>
 export interface BrokerSender {
   declareQueue(specification: QueueSpecitication): Promise<void>
 
-  declareTopic(specification: ExchangeSpecification): Promise<void>
+  declareTopic(specification: TopicSpecification): Promise<void>
 
   bind(specification: BindingSpecification): Promise<void>
 }

test/adapter/amqp-receiver.test.ts

@@ -3,9 +3,10 @@ import { ChannelWrapper } from 'amqp-connection-manager'
 import { AmqpReceiver } from '../../src/adapter/amqp/amqp-receiver'
 import { ConfirmChannel, ConsumeMessage, Message } from 'amqplib'
 
+const queueName = 'myQueue'
+const messageContent = Buffer.from('{"foo": "bar"}', 'utf8')
+
 describe(`AMQP receiver`, () => {
-  const queueName = 'myQueue'
-  const messageContent = Buffer.from('{"foo": "bar"}', 'utf8')
   let addSetupMock: jest.MockedFunction<
     (func: (channel: ConfirmChannel) => Promise<void>) => Promise<void>
   >

test/adapter/amqp-sender.test.ts

@@ -1,7 +1,91 @@
+import { AmqpSender } from '../../src/adapter/amqp/amqp-sender'
+
+import { ConfirmChannel } from 'amqplib'
+import { ChannelWrapper } from 'amqp-connection-manager'
+import {
+  QueueSpecitication,
+  TopicSpecification,
+  BindingSpecification
+} from '../../src/domain/model/broker.model'
+
+const queueName = 'myQueue'
+const topicName = 'mytopic'
+const routingKey = 'myRoutingKey'
+
 describe(`AMQP sender`, () => {
-  it(`declares a queue`, () => {})
+  let addSetupMock: jest.MockedFunction<
+    (func: (channel: ConfirmChannel) => Promise<void>) => Promise<void>
+  >
+  let publishMock: jest.MockedFunction<
+    (exchange: string, routingKey: string, content: Buffer) => Promise<void>
+  >
+  let channelWrapper: ChannelWrapper
+  let sender: AmqpSender
+
+  beforeEach(() => {
+    jest.clearAllMocks()
+    addSetupMock = jest.fn(func => Promise.resolve())
+    publishMock = jest.fn((exchange, routingKey, content) => Promise.resolve())
+    channelWrapper = ({ addSetup: addSetupMock, publish: publishMock } as any) as ChannelWrapper
+    sender = new AmqpSender(channelWrapper)
+  })
+
+  it(`declares a queue`, async () => {
+    const queue: QueueSpecitication = {
+      name: queueName,
+      exclusive: true
+    }
+
+    const assertQueueMock = jest.fn((name, options) => undefined)
+    const channel = ({ assertQueue: assertQueueMock } as any) as ConfirmChannel
+
+    await sender.declareQueue(queue)
+    await addSetupMock.mock.calls[0][0](channel)
+
+    expect(assertQueueMock.mock.calls[0][0]).toBe(queueName)
+    expect(assertQueueMock.mock.calls[0][1]).toStrictEqual({
+      exclusive: true
+    })
+  })
+
+  it(`declares a topic`, async () => {
+    const topic: TopicSpecification = {
+      name: topicName
+    }
+
+    const assertExchangeMock = jest.fn((name, type) => undefined)
+    const channel = ({ assertExchange: assertExchangeMock } as any) as ConfirmChannel
+
+    await sender.declareTopic(topic)
+    await addSetupMock.mock.calls[0][0](channel)
+
+    expect(assertExchangeMock.mock.calls[0][0]).toBe(topicName)
+    expect(assertExchangeMock.mock.calls[0][1]).toEqual('topic')
+  })
+
+  it(`do a binding`, async () => {
+    const binding: BindingSpecification = {
+      queue: queueName,
+      topic: topicName,
+      routingKey: routingKey
+    }
+
+    const bindQueueMock = jest.fn((queue, topic, routingKey) => undefined)
+    const channel = ({ bindQueue: bindQueueMock } as any) as ConfirmChannel
+
+    await sender.bind(binding)
+    await addSetupMock.mock.calls[0][0](channel)
+
+    expect(bindQueueMock.mock.calls[0][0]).toBe(queueName)
+    expect(bindQueueMock.mock.calls[0][1]).toEqual(topicName)
+    expect(bindQueueMock.mock.calls[0][2]).toEqual(routingKey)
+  })
 
-  it(`declares a topic`, () => {})
+  it(`publish messages`, async () => {
+    await sender.publish(topicName, routingKey, { foo: 'bar' })
 
-  it(`do a binding`, () => {})
+    expect(publishMock.mock.calls[0][0]).toBe(topicName)
+    expect(publishMock.mock.calls[0][1]).toBe(routingKey)
+    expect(publishMock.mock.calls[0][2]).toStrictEqual({ foo: 'bar' })
+  })
 })