Page MenuHomePhabricator

[services] Tunnelbroker - Adding handling of messages to send from the client
ClosedPublic

Authored by max on Nov 10 2022, 5:37 AM.
Tags
None
Referenced Files
Unknown Object (File)
Thu, Jun 27, 7:22 PM
Unknown Object (File)
Wed, Jun 26, 7:13 PM
Unknown Object (File)
Tue, Jun 25, 11:55 PM
Unknown Object (File)
Tue, Jun 25, 11:55 PM
Unknown Object (File)
Tue, Jun 25, 11:55 PM
Unknown Object (File)
Tue, Jun 25, 11:55 PM
Unknown Object (File)
Tue, Jun 25, 11:55 PM
Unknown Object (File)
Tue, Jun 25, 11:54 PM

Details

Summary

This diff introduces handling messages to be sent from the client by messagesToSend incoming gRPC message.

Tunnelbroker receives messages from the client and puts them into a messages table in the database, then put a message into the AMQP queue to trigger the delivery. Tunnelbroker generates a unique message ID for each message and sends it back to the client as a processedMessages.

Linear task: ENG-2060

Test Plan
  1. Connect as a Client 1 by the gRPC client to the bidirectional stream with the sessionID corresponding to the Client 1 deviceID in metadata.
  2. Open another gRPC client and connect as a Client 2 to the bidirectional stream with the sessionID corresponding to the Client 2 deviceID in metadata.
  3. From Client 1 send a messagesToSend message to the gRPC stream with the message data include toDeviceID from Client 2.

The expected result is that Client 2 will receive a gRPC stream message with the data sent from Client 1.

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Event Timeline

max held this revision as a draft.
max edited the test plan for this revision. (Show Details)
max added reviewers: varun, marcin. max added 1 blocking reviewer(s): jon.

Adding sending of AMQP messages.

max published this revision for review.Nov 10 2022, 7:05 AM

Seems reasonable to me

This revision is now accepted and ready to land.Nov 17 2022, 9:26 AM

Rebasing on parents and master changes.