[shared/grpc_clients] Add verify_user_access_token()
ClosedPublic
Actions

	[package]			[package]
	name = "commtest"			name = "commtest"
	version = "0.1.0"			version = "0.1.0"
	edition = "2021"			edition = "2021"
	license = "BSD-3-Clause"			license = "BSD-3-Clause"

	[dependencies]			[dependencies]
	comm-opaque2 = { path = "../../shared/comm-opaque2" }			comm-opaque2 = { path = "../../shared/comm-opaque2" }
				grpc_clients = { path = "../../shared/grpc_clients" }
	tonic = "0.8"			tonic = "0.8"
	tokio = { version = "1.24", features = ["macros", "rt-multi-thread"] }			tokio = { version = "1.24", features = ["macros", "rt-multi-thread"] }
	prost = "0.11"			prost = "0.11"
	anyhow = "1.0"			anyhow = "1.0"
	base64 = "0.20"			base64 = "0.20"
	openssl = "0.10"			openssl = "0.10"
	futures = "0.1"			futures = "0.1"
	async-stream = "0.3.2"			async-stream = "0.3.2"
	Show All 18 Lines

services/commtest/tests/grpc_client_test.rs

				use commtest::identity::device::create_device;

				#[tokio::test]
				async fn verify_access_token() {
				use grpc_clients::identity::unauthenticated::client::verify_user_access_token;
				let device_info = create_device().await;

				let token_valid = verify_user_access_token(
				"http://127.0.0.1:50054",
				&device_info.user_id,
				&device_info.device_id,
				&device_info.access_token,
				)
				.await
				.expect("Failed to call identity's verify_user_access_token endpoint");

				assert_eq!(token_valid, true);

				// Try again with invalid access token
				let token_valid = verify_user_access_token(
				"http://127.0.0.1:50054",
				&device_info.user_id,
				&device_info.device_id,
				"garbage",
				)
				.await
				.expect("Failed to call identity's verify_user_access_token endpoint");

				assert_eq!(token_valid, false);
				}

	use tonic::codegen::http::uri::InvalidUri;			use tonic::{codegen::http::uri::InvalidUri, Status};

	#[derive(			#[derive(
	Debug, derive_more::Display, derive_more::From, derive_more::Error,			Debug, derive_more::Display, derive_more::From, derive_more::Error,
	)]			)]
	pub enum Error {			pub enum Error {
	#[display(...)]			#[display(...)]
	TransportError(tonic::transport::Error),			TransportError(tonic::transport::Error),
	#[display(...)]			#[display(...)]
	InvalidUri(InvalidUri),			InvalidUri(InvalidUri),
				#[display(...)]
				GrpcStatus(Status),
	}			}