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
Branch
D5592
Lint
No Lint Coverage
Unit
No Test Coverage

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.