Show First 20 Lines • Show All 65 Lines • ▼ Show 20 Lines	pub enum SessionError {
InternalError,		InternalError,
UnauthorizedDevice,		UnauthorizedDevice,
PersistenceError(SdkError<PutItemError>),		PersistenceError(SdkError<PutItemError>),
DatabaseError(comm_lib::database::Error),		DatabaseError(comm_lib::database::Error),
MissingAPNsClient,		MissingAPNsClient,
MissingFCMClient,		MissingFCMClient,
MissingWebPushClient,		MissingWebPushClient,
MissingDeviceToken,		MissingDeviceToken,
		InvalidDeviceToken,
}		}

// Parse a session request and retrieve the device information		// Parse a session request and retrieve the device information
pub async fn handle_first_message_from_device(		pub async fn handle_first_message_from_device(
message: &str,		message: &str,
) -> Result<DeviceInfo, SessionError> {		) -> Result<DeviceInfo, SessionError> {
let serialized_message =		let serialized_message =
serde_json::from_str::<DeviceToTunnelbrokerMessage>(message)?;		serde_json::from_str::<DeviceToTunnelbrokerMessage>(message)?;
▲ Show 20 Lines • Show All 483 Lines • ▼ Show 20 Lines	async fn get_device_token(
&self,		&self,
device_id: String,		device_id: String,
) -> Result<String, SessionError> {		) -> Result<String, SessionError> {
let db_token = self		let db_token = self
.db_client		.db_client
.get_device_token(&device_id)		.get_device_token(&device_id)
.await		.await
.map_err(SessionError::DatabaseError)?;		.map_err(SessionError::DatabaseError)?;
db_token.ok_or_else(\|\| SessionError::MissingDeviceToken)
		match db_token {
		Some(token) => {
		if token.token_invalid {
		Err(SessionError::InvalidDeviceToken)
		} else {
		Ok(token.device_token)
		}
		}
		None => Err(SessionError::MissingDeviceToken),
		}
}		}
}		}

[services] Backup - Use terminateCallback for create new backup reactorClosedPublicActions

Details

Diff Detail

Event Timeline

Revision ContentsChangeset List

Diff 11157

services/backup/docker-server/contents/server/src/Reactors/server/CreateNewBackupReactor.h

[services] Backup - Use terminateCallback for create new backup reactor
ClosedPublic
Actions

Revision Contents
Changeset List