Page MenuHomePhabricator
Differential D12938

[Tunnelbroker] add Platform column to `device_token` DDB table
ClosedPublic
Actions

Authored by kamil on Jul 30 2024, 4:04 AM.
Tags
None
Referenced Files
Unknown Object (File)
Sun, Mar 2, 10:47 PM
Unknown Object (File)
Sat, Feb 22, 10:48 AM
Unknown Object (File)
Thu, Feb 20, 1:03 AM
Unknown Object (File)
Tue, Feb 18, 4:25 AM
Unknown Object (File)
Tue, Feb 18, 4:24 AM
Unknown Object (File)
Tue, Feb 18, 4:24 AM
Unknown Object (File)
Feb 1 2025, 11:25 AM
Unknown Object (File)
Feb 1 2025, 10:13 AM
View All 91 Files
Subscribers
ashoat

Details

Reviewers
bartek
tomek
Commits
rCOMM9306dc4214ea: [Tunnelbroker] add Platform column to `device_token` DDB table
Summary

ENG-8903.

Platform is optional to support old clients which uploaded device token without platform.

Depends on D12937

Test Plan

Test inserting and getting device token with platform

Diff Detail

Repository
rCOMM Comm
Branch
final-stack
Lint
No Lint Coverage
Unit
No Test Coverage

Revision Contents
Changeset List

PathSize
services/
tunnelbroker/
src/
1 line
database/
45 lines
websockets/
6 lines

Diff 42990

View Options

services/tunnelbroker/src/constants.rs

Show First 20 Lines • Show All 287 Lines • ▼ Show 20 Lines match message_to_tunnelbroker {
.db_client .db_client
.set_device_token( .set_device_token(
&self.device_info.device_id, &self.device_info.device_id,
&token.device_token, &token.device_token,
None, None,
) )
.await?; .await?;
} }
MessageToTunnelbroker::SetDeviceTokenWithPlatform(
token_with_platform,
) => {
self
.db_client
.set_device_token(
&self.device_info.device_id,
&token_with_platform.device_token,
Some(token_with_platform.platform.clone()),
)
.await?;
}
} }
Ok(()) Ok(())
} }
pub async fn handle_websocket_frame_from_device( pub async fn handle_websocket_frame_from_device(
&mut self, &mut self,
msg: String, msg: String,
▲ Show 20 Lines • Show All 331 Lines • Show Last 20 Lines
View Options

services/tunnelbroker/src/database/mod.rs

Show First 20 Lines • Show All 287 Lines • ▼ Show 20 Lines match message_to_tunnelbroker {
.db_client .db_client
.set_device_token( .set_device_token(
&self.device_info.device_id, &self.device_info.device_id,
&token.device_token, &token.device_token,
None, None,
) )
.await?; .await?;
} }
MessageToTunnelbroker::SetDeviceTokenWithPlatform(
token_with_platform,
) => {
self
.db_client
.set_device_token(
&self.device_info.device_id,
&token_with_platform.device_token,
Some(token_with_platform.platform.clone()),
)
.await?;
}
} }
Ok(()) Ok(())
} }
pub async fn handle_websocket_frame_from_device( pub async fn handle_websocket_frame_from_device(
&mut self, &mut self,
msg: String, msg: String,
▲ Show 20 Lines • Show All 331 Lines • Show Last 20 Lines
View Options

services/tunnelbroker/src/websockets/session.rs

Show First 20 Lines • Show All 287 Lines • ▼ Show 20 Lines match message_to_tunnelbroker {
.db_client .db_client
.set_device_token( .set_device_token(
&self.device_info.device_id, &self.device_info.device_id,
&token.device_token, &token.device_token,
None, None,
) )
.await?; .await?;
} }
MessageToTunnelbroker::SetDeviceTokenWithPlatform(
token_with_platform,
) => {
self
.db_client
.set_device_token(
&self.device_info.device_id,
&token_with_platform.device_token,
Some(token_with_platform.platform.clone()),
)
.await?;
}
} }
Ok(()) Ok(())
} }
pub async fn handle_websocket_frame_from_device( pub async fn handle_websocket_frame_from_device(
&mut self, &mut self,
msg: String, msg: String,
▲ Show 20 Lines • Show All 331 Lines • Show Last 20 Lines