[lib] Enable thick thread creation for all the users
ClosedPublic
Actions

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),
		}
}		}
}		}

View Options

lib/hooks/relationship-hooks.js

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),
		}
}		}
}		}

View Options

lib/hooks/user-identities-hooks.js

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),
		}
}		}
}		}

View Options

lib/selectors/thread-selectors.js

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),
		}
}		}
}		}