feat(FX-4495): RabbitMQ event when an article is published / un-published

[nickskalkin]

• Jira story

Emits a RabbitMQ message when an article is published.

Deployment

• [x] Create exchange and queue on staging
• [x] Create exchange and queue on production
• [x] Create RabbitMQ user & add env variables (RABBITMQ_URL and ENABLE_PUBLISH_RABBITMQ_EVENTS) on staging
• [x] Create RabbitMQ user & add env variables (RABBITMQ_URL and ENABLE_PUBLISH_RABBITMQ_EVENTS) on production

[codecov[bot]]

Codecov Report

Merging #3083 (3087416) into main (5d313c7) will decrease coverage by 0.0%. The diff coverage is 66.6%.

:exclamation: Current head 3087416 differs from pull request most recent head 4b6f2fb. Consider uploading reports for the commit 4b6f2fb to get more accurate results

@@           Coverage Diff           @@
##            main   #3083     +/-   ##
=======================================
- Coverage   83.1%   83.0%   -0.1%     
=======================================
  Files        196     197      +1     
  Lines       5385    5412     +27     
  Branches     988     989      +1     
=======================================
+ Hits        4477    4497     +20     
- Misses       656     662      +6     
- Partials     252     253      +1     

[artsy-peril[bot]]

amqplib

Author: Michael Bridgen

Description: An AMQP 0-9-1 (e.g., RabbitMQ) library and client.

Homepage: http://amqp-node.github.io/amqplib/

Created	over 9 years ago
Last Updated	5 months ago
License	MIT
Maintainers	2
Releases	31
Direct Dependencies	@acuminous/bitsyntax, buffer-more-ints, readable-stream and url-parse
Keywords	AMQP, AMQP 0-9-1 and RabbitMQ

README

# AMQP 0-9-1 library and client for Node.JS [](https://www.npmjs.com/package/amqplib) [](https://www.npmjs.com/package/amqplib) [](https://github.com/amqp-node/amqplib/actions?query=workflow%3A%22Node.js+CI%22) [](https://snyk.io/advisor/npm-package/amqplib) npm install amqplib * [Change log][changelog] * [GitHub pages][gh-pages] * [API reference][gh-pages-apiref] * [Troubleshooting][gh-pages-trouble] * [Examples from RabbitMQ tutorials][tutes] A library for making AMQP 0-9-1 clients for Node.JS, and an AMQP 0-9-1 client for Node.JS v10+. This library does not implement [AMQP 1.0](https://github.com/squaremo/amqp.node/issues/63) or [AMQP 0-10](https://github.com/squaremo/amqp.node/issues/94). Project status: - Expected to work - Complete high-level and low-level APIs (i.e., all bits of the protocol) - Stable APIs - A fair few tests - Measured test coverage - Ports of the [RabbitMQ tutorials][rabbitmq-tutes] as [examples][tutes] - Used in production Still working on: - Getting to 100% (or very close to 100%) test coverage ## Callback API example ```javascript const amqplib = require('amqplib/callback_api'); const queue = 'tasks'; amqplib.connect('amqp://localhost', (err, conn) => { if (err) throw err; // Listener conn.createChannel((err, ch2) => { if (err) throw err; ch2.assertQueue(queue); ch2.consume(queue, (msg) => { if (msg !== null) { console.log(msg.content.toString()); ch2.ack(msg); } else { console.log('Consumer cancelled by server'); } }); }); // Sender conn.createChannel((err, ch1) => { if (err) throw err; ch1.assertQueue(queue); setInterval(() => { ch1.sendToQueue(queue, Buffer.from('something to do')); }, 1000); }); }); ``` ## Promise/Async API example ```javascript const amqplib = require('amqplib'); (async () => { const queue = 'tasks'; const conn = await amqplib.connect('amqp://localhost'); const ch1 = await conn.createChannel(); await ch1.assertQueue(queue); // Listener ch1.consume(queue, (msg) => { if (msg !== null) { console.log('Recieved:', msg.content.toString()); ch1.ack(msg); } else { console.log('Consumer cancelled by server'); } }); // Sender const ch2 = await conn.createChannel(); setInterval(() => { ch2.sendToQueue(queue, Buffer.from('something to do')); }, 1000); })(); ``` ## Running tests npm test To run the tests RabbitMQ is required. Either install it with your package manager, or use [docker][] to run a RabbitMQ instance. docker run -d --name amqp.test -p 5672:5672 rabbitmq If prefer not to run RabbitMQ locally it is also possible to use a instance of RabbitMQ hosted elsewhere. Use the `URL` environment variable to configure a different amqp host to connect to. You may also need to do this if docker is not on localhost; e.g., if it's running in docker-machine. One public host is dev.rabbitmq.com: URL=amqp://dev.rabbitmq.com npm test **NB** You may experience test failures due to timeouts if using the dev.rabbitmq.com instance. You can run it under different versions of Node.JS using [nave][]: nave use 10 npm test or run the tests on all supported versions of Node.JS in one go: make test-all-nodejs (which also needs `nave` installed, of course). Lastly, setting the environment variable `LOG_ERRORS` will cause the tests to output error messages encountered, to the console; this is really only useful for checking the kind and formatting of the errors. LOG_ERRORS=true npm test ## Test coverage make coverage open file://`pwd`/coverage/lcov-report/index.html [gh-pages]: https://amqp-node.github.io/amqplib/ [gh-pages-apiref]: https://amqp-node.github.io/amqplib/channel_api.html [gh-pages-trouble]: https://amqp-node.github.io/amqplib/#troubleshooting [nave]: https://github.com/isaacs/nave [tutes]: https://github.com/amqp-node/amqplib/tree/main/examples/tutorials [rabbitmq-tutes]: http://www.rabbitmq.com/getstarted.html [changelog]: https://github.com/amqp-node/amqplib/blob/main/CHANGELOG.md [docker]: https://www.docker.com/

New dependencies added: amqplib.

Generated by :no_entry_sign: dangerJS against 4b6f2fb1bffc3dfbae8ae78bfc88dd291c60ddd8