Issue and context why we need this: ENG-5171.
Details
Details
- Send some messages and check if they're properly saved in DB:
- Run test_messages_order to make sure:
- messages can be properly retrieved and deleted
- order is correct
Diff Detail
Diff Detail
- Repository
- rCOMM Comm
- Lint
Lint Not Applicable - Unit
Tests Not Applicable
Event Timeline
| services/tunnelbroker/src/database/mod.rs | ||
|---|---|---|
| 52 ↗ | (On Diff #31957) | Returned message_id is needed later in the stack |
| services/tunnelbroker/src/grpc/mod.rs | ||
| 42 ↗ | (On Diff #31957) | the correct value here will be added in the next diff |
| services/tunnelbroker/src/websockets/session.rs | ||
| 178 ↗ | (On Diff #31957) | the correct value here will be added in the next diff |
Comment Actions
It might be worth to introduce something like
struct MessageID {
timestamp: DateTime<Utc>,
client_message_id: String,
}
impl MessageID {
pub fn new(client_message_id: String) -> Self {Self {timestmap: Utc::now(), client_message_id} }
}And impls for converting to and from a string (timestamp#messageID)