[WPB-10308] Use RabbitMQ queues for notifications#4272

Merged

mdimjasevic merged 101 commits intodevelopfrom

WPB-10308-use-rabbti-mq-classic-queues-for-notifications

Nov 12, 2024

Commits on Oct 21, 2024

create rabbitmq exchange

battermann
authored and
akshaymankar
committed
set up DLX

battermann
authored and
akshaymankar
committed
wip

battermann
authored and
akshaymankar
committed
create user queues on client add/update

battermann
authored and
akshaymankar
committed
make it internal server error

battermann
authored and
akshaymankar
committed
make galley compile

battermann
authored and
akshaymankar
committed
make rabbitmq mandatory

battermann
authored and
akshaymankar
committed
fix integration tests

battermann
authored and
akshaymankar
committed
set correct DLX headers

battermann
authored and
akshaymankar
committed
wip

battermann
authored and
akshaymankar
committed
Add a WIP test to consume notifs via `GET /events`
akshaymankar
committed
cannon: Roughly implement subscribing notifs from RabbitMQ
akshaymankar
committed
gundeck: Start implementing push to rabbitmq
akshaymankar
committed
integration: Fix assertion to assert on a real event
akshaymankar
committed
integration: Use correct vHost in cannon
akshaymankar
committed
cannon: Ensure exchange exists and publish event correctly on WS
akshaymankar
committed
NotificationSubsystem: Align names for queues and extract them as top level bindings
akshaymankar
committed
gundeck: Push events to RabbitMQ for compatible clients
akshaymankar
committed
integration: Assert that acked events don't come back
akshaymankar
committed
cannon: Forward client acks to rabbitmq
akshaymankar
committed
WIP: Get rid of channel as an explicit param for NotificationSubsystem actions
akshaymankar
committed
Get galley to compile.

fisx
authored and
akshaymankar
committed
Fix some easy TODOs.

fisx
authored and
akshaymankar
committed
Use these library better.

fisx
authored and
akshaymankar
committed
resolve rebase conflict better.

fisx
authored and
akshaymankar
committed
fix ghc errors.

fisx
authored and
akshaymankar
committed
Extract rabbitmq channel lookup into helper.

fisx
authored and
akshaymankar
committed
Move setupConsumableNotificationsClient from subsystems to gundeck.

fisx
authored and
akshaymankar
committed
Revert "Get galley to compile."
akshaymankar
committed
wire-subsystems: Fix compile errors in tests
akshaymankar
committed
gundeck: doesn't depend on wire-subsystems (yet?)
akshaymankar
committed
brig: Remove unnecessary import
akshaymankar
committed
cannon: Don't create the queue for clients, expect it to already be there
akshaymankar
committed
cannon: close ws connection when something goes wrong
akshaymankar
committed
Funky!
akshaymankar
committed
Undo funkiness: Create Wire.API.WebSocket with types for comms on the new websocket
akshaymankar
committed
WIP: cannon: try to use the new types from wire-api
akshaymankar
committed
wire-api: Cabal file
akshaymankar
committed
gen nix stuff

fisx
authored and
akshaymankar
committed
ormolu

fisx
authored and
akshaymankar
committed
Is this a good way of representing websocket messages?

fisx
authored and
akshaymankar
committed
Resolve TODO.

fisx
authored and
akshaymankar
committed
Refactor test, extend coverage.

fisx
authored and
akshaymankar
committed
Suggestions for better module name; removed "websocket" reference from some names.

fisx
authored and
akshaymankar
committed
Roundtrip tests for Message*To*.

fisx
authored and
akshaymankar
committed
Source comments.

fisx
authored and
akshaymankar
committed
debug failing test [WIP]

fisx
authored and
akshaymankar
committed
refactor tests a bit, fix ack, fix typos

battermann
authored and
akshaymankar
committed
fix test, handle connection closed, format

battermann
authored and
akshaymankar
committed
ping pong test

battermann
authored and
akshaymankar
committed
Maintain stable connection to rabbitmq from cannon. [WIP]

fisx
authored and
akshaymankar
committed
Fix typo.

fisx
authored and
akshaymankar
committed
Tune tests.

fisx
authored and
akshaymankar
committed
Remove ping-pong stuff.

fisx
authored and
akshaymankar
committed
Revert "Maintain stable connection to rabbitmq from cannon. [WIP]"

fisx
authored and
akshaymankar
committed
Test multiple acks and out of order acks
akshaymankar
committed
cannon: Refactor code a little and more logging
akshaymankar
committed
integration: Deal with events websocket more gracefully, ensure all acks are sent
akshaymankar
committed
cannon: Easier to understand cleanup code
akshaymankar
committed
Add TODO for tomorrow
akshaymankar
committed
cannon: Ensure invalid messages don't accumulate
akshaymankar
committed
small re-org of code
akshaymankar
committed
Avoid using unsafeRange
akshaymankar
committed
Reduce top level functions
akshaymankar
committed
integration: Test that old and new clients can co-exist
akshaymankar
committed
gundeck: Optimize number of calls to brig
akshaymankar
committed
gundeck: Try to not kill brig
akshaymankar
committed
Fix typo
akshaymankar
committed
gundeck: Remove pairing comment
akshaymankar
committed
wire-api: Rename Wire.API.WebSocket -> Wire.API.Event.WebSocketProtocol
akshaymankar
committed
gundeck: Don't configure dead-lettering while declaring queues
akshaymankar
committed
More TODOs
akshaymankar
committed
Use direct exchange for user notifications
akshaymankar
committed
integration: Test that users only get notifs meant for them
akshaymankar
committed
integration/Notifications: Allow waiting for notifs without a client
akshaymankar
committed
Deflake newly written tests
akshaymankar
committed
cannon: Don't declare the exchange, its not needed
akshaymankar
committed
integration: Make cannon logLevel Warn again
akshaymankar
committed
integrations: Throw error if websocket responds with invalid JSON
akshaymankar
committed
Add ticket number to FUTUREWORK
akshaymankar
committed
Add notification Id to rabbitmq notifs
akshaymankar
committed
Makefile/clean-rabbit: Also cleanup exchanges
akshaymankar
committed
gundeck: Get preexisting unit tests to pass
akshaymankar
committed
Set correct expiration on events pushed to RabbitMQ
akshaymankar
committed

Commits on Oct 22, 2024

Merge remote-tracking branch 'origin/develop' into WPB-10308-use-rabbti-mq-classic-queues-for-notifications
Marko Dimjašević
committed
fix a typo in the changelog
Marko Dimjašević
committed
Fix a release note
Marko Dimjašević
committed
Add changelogs for public and internal API changes
Marko Dimjašević
committed
Move around routing key helper functions
Marko Dimjašević
committed
Remove commented out code
Marko Dimjašević
committed
Merge remote-tracking branch 'origin/develop' into WPB-10308-use-rabbti-mq-classic-queues-for-notifications
Marko Dimjašević
committed

Commits on Oct 23, 2024

Hi CI
Marko Dimjašević
committed

Commits on Oct 24, 2024

Merge remote-tracking branch 'origin/develop' into WPB-10308-use-rabbti-mq-classic-queues-for-notifications
Marko Dimjašević
committed

Commits on Oct 30, 2024

Merge remote-tracking branch 'origin/develop' into WPB-10308-use-rabbti-mq-classic-queues-for-notifications
Marko Dimjašević
committed
Merge remote-tracking branch 'origin/develop' into WPB-10308-use-rabbti-mq-classic-queues-for-notifications
Marko Dimjašević
committed

Commits on Oct 31, 2024

Merge remote-tracking branch 'origin/develop' into WPB-10308-use-rabbti-mq-classic-queues-for-notifications
Marko Dimjašević
committed

Commits on Nov 4, 2024

Merge remote-tracking branch 'origin/develop' into WPB-10308-use-rabbti-mq-classic-queues-for-notifications
Marko Dimjašević
committed

Commits on Nov 11, 2024

Merge remote-tracking branch 'origin/develop' into WPB-10308-use-rabbti-mq-classic-queues-for-notifications
Marko Dimjašević
committed

Commits on Nov 12, 2024

Hi CI
Marko Dimjašević
committed
Detect and flag missed notifications from RabbitMQ (#4317)
elland
authored
Update a change log to reflect changes from PR #4317
Marko Dimjašević
committed