116 Commits

Author	SHA1	Message	Date
Jon Chambers	d1eb247d8c	Clarify the purpose of an addListener method	2023-04-18 12:04:54 -04:00
Jon Chambers	11829d1f9f	Refactor provisioning plumbing to use Lettuce	2023-04-18 12:04:54 -04:00
Chris Eager	391aa9c518	Wrap runtime exceptions during WebSocket auth into AuthenticationException	2023-03-29 10:08:55 -05:00
Chris Eager	f5c62a3d85	Migrate from bounded elastic to dedicated executor for message delivery	2023-03-22 12:57:44 -05:00
Chris Eager	292f69256e	Refactor WebSocket message sending error and completion to subscriber from “doOn…”	2023-03-17 12:42:57 -05:00
Jon Chambers	7de5c0a27d	Keep counts of open websockets by client platform	2023-03-03 13:16:24 -06:00
Chris Eager	a6d11789e9	Add ClosedChannelException to expected errors	2023-02-23 10:17:16 -06:00
Chris Eager	43f83076fa	Update to reactor 3.5.3	2023-02-23 10:16:57 -06:00
Sergey Skrobotov	c32067759c	refactoring: use constants for header names	2022-11-15 11:16:49 -08:00
Chris Eager	77d691df59	Always use reactived message processing in WebSocketConnection	2022-11-11 13:14:39 -06:00
Chris Eager	e6e6eb323d	Update metric name	2022-11-08 11:15:42 -06:00
Chris Eager	5bec89ecc8	Measure individual message timeouts	2022-11-08 09:37:37 -06:00
Chris Eager	69ed0edb74	Revert "Add more detailed queue processing rate metrics" ... This reverts commit bbbab4b8a4.	2022-11-08 09:35:39 -06:00
Chris Eager	d186245c5c	Move all receipt sending work to executor	2022-11-04 11:08:06 -05:00
Chris Eager	bbbab4b8a4	Add more detailed queue processing rate metrics	2022-11-04 11:06:38 -05:00
Chris Eager	f83080eb8d	Update metric name	2022-11-03 14:50:20 -05:00
Chris Eager	e0178fa0ea	Move additional handling of MessagesManager#delete to executor	2022-11-03 13:02:25 -05:00
Chris Eager	c6a79ca176	Enable metrics on messages fluxes	2022-11-03 13:02:25 -05:00
Chris Eager	c10fda8363	Use reactive streams for WebSocket message queue ... Initially, uses `ExperimentEnrollmentManager` to do a safe rollout.	2022-10-31 10:35:37 -05:00
erik-signal	966c3a8f47	Add routing for stories.	2022-10-05 10:44:50 -04:00
Jon Chambers	b4281c5a70	Send non-urgent push notifications with lower priority	2022-08-12 11:06:31 -04:00
Jon Chambers	a53a85d788	Refactor scheduled APNs notifications in preparation for future development	2022-08-12 10:47:49 -04:00
Chris Eager	390580a19d	Count cases when the a message’s destination UUID doesn’t match the account’s PNI	2022-08-09 13:06:15 -07:00
Jon Chambers	6f0faae4ce	Introduce common push notification interfaces/pathways	2022-08-03 10:07:53 -04:00
Chris Eager	1175ff5867	Log cause when queue processing hits max retries	2022-08-02 08:36:16 -07:00
Chris Eager	55df593561	Clean up MessageAvailabilityListener if the websocket client is closed	2022-08-02 08:35:16 -07:00
Chris Eager	a06a663b94	Use the envelope’s destination UUID for receipt source UUID	2022-08-02 08:34:20 -07:00
Chris Eager	3d2f7e731f	Remove Envelope.source	2022-08-02 08:34:20 -07:00
Chris Eager	2575372639	Add missing increment() to displacement counter	2022-08-02 08:30:54 -07:00
Jon Chambers	3636626e09	Make Envelope the main unit of currency when working with stored messages	2022-07-29 10:59:02 -04:00
Jon Chambers	d385838dc1	Add methods to convert IncomingMessage/OutgoingMessageEntity instances into Envelope entities	2022-07-29 10:59:02 -04:00
Jon Chambers	3d875f1ce5	Convert incoming/outgoing message entities to records	2022-07-29 10:59:02 -04:00
Jon Chambers	dce391a248	Add support for setting PNI-associated registration IDs and identity keys when changing numbers	2022-07-26 15:19:27 -04:00
Jon Chambers	6754ec5e10	Pass disconnection reason (if known) to clients	2022-07-13 15:30:03 -04:00
Jon Chambers	1ba00a66eb	Pass the reason for displacement to presence displacement listeners	2022-07-13 15:30:03 -04:00
Jon Chambers	92d36b725f	Allow presence keys to expire if not periodically renewed	2022-07-13 11:28:55 -04:00
Jon Chambers	4e131858ca	Generalize scope of and expand size of websocket scheduled executor service	2022-07-13 11:28:55 -04:00
Fedor Indutny	d31ddb72f3	Optimize message deletion by skipping lookup	2022-05-18 13:02:21 -07:00
Jon Chambers	53f17c2baa	Drop the legacy message and relay fields from message entities	2022-03-24 10:50:49 -04:00
Jon Chambers	9b9edbae0e	Drop DeadLetterHandler (which is functionally unused)	2022-03-08 10:03:06 -05:00
Chris Eager	3e777df86c	Timeout sendNextMessagePage after 5 minutes	2021-12-20 11:31:11 -08:00
Chris Eager	346c7cd743	Remove null-check of destination UUID	2021-12-20 11:31:11 -08:00
Jon Chambers	606ddd8a9b	Populate destination UUID for messages delivered via websocket	2021-12-02 12:17:08 -05:00
Chris Eager	c0756e9c60	Attempt an orderly websocket close on displacement before a hard disconnect	2021-11-23 11:36:32 -07:00
Chris Eager	5a99708f56	Update some deprecated usages	2021-11-16 15:56:13 -07:00
Jon Chambers	3398955c1a	Add basic support for phone number identifiers	2021-11-09 10:23:08 -05:00
Chris Eager	3e5087e60b	Remove obsolete ephemeral queue handling	2021-09-29 10:31:39 -07:00
Jon Chambers	09519ae942	Only retry websocket sending if the client is still connected	2021-09-20 14:24:07 -04:00
Fedor Indutny	383d744bd8	Log the error message when retrying queue send	2021-09-16 18:03:42 -04:00
Jon Chambers	c2ba8ab562	Identify receipt destinations by UUID instead of e164	2021-09-16 10:47:03 -04:00