	pub mod error;			pub mod error;
	pub mod identity;			pub mod identity;
	pub mod tunnelbroker;			pub mod tunnelbroker;

	// Re-export some dependencies which may need to be used by downstream crates			// Re-export some dependencies which may need to be used by downstream crates
	pub use tonic;			pub use tonic;

	use error::Error;			use error::Error;
	use std::path::Path;
	use std::time::Duration;			use std::time::Duration;
	use tonic::transport::{Certificate, Channel, ClientTlsConfig};			use tonic::transport::Channel;
	use tracing::info;			use tracing::info;

	const CERT_PATHS: &[&str] = &[
	// MacOS and newer Ubuntu
	"/etc/ssl/cert.pem",
	// Common CA cert paths
	"/etc/ssl/certs/ca-bundle.crt",
	"/etc/ssl/certs/ca-certificates.crt",
	];
	const CONNECT_TIMEOUT_DURATION: Duration = Duration::from_secs(5);			const CONNECT_TIMEOUT_DURATION: Duration = Duration::from_secs(5);

	pub(crate) fn get_ca_cert_contents() -> Option<String> {
	CERT_PATHS
	.iter()
	.map(Path::new)
	.filter(\|p\| p.exists())
	.filter_map(\|f\| std::fs::read_to_string(f).ok())
	.next()
	}
	pub(crate) async fn get_grpc_service_channel(			pub(crate) async fn get_grpc_service_channel(
	url: &str,			url: &str,
	) -> Result<Channel, Error> {			) -> Result<Channel, Error> {
	let ca_cert = crate::get_ca_cert_contents().expect("Unable to get CA bundle");

	info!("Connecting to gRPC service at {}", url);			info!("Connecting to gRPC service at {}", url);
	let mut channel = Channel::from_shared(url.to_string())?			let channel = Channel::from_shared(url.to_string())?
	.connect_timeout(CONNECT_TIMEOUT_DURATION);			.connect_timeout(CONNECT_TIMEOUT_DURATION);

	// tls_config will fail if the underlying URI is only http://
	if url.starts_with("https:") {
	channel = channel.tls_config(
	ClientTlsConfig::new().ca_certificate(Certificate::from_pem(&ca_cert)),
	)?
	}

	Ok(channel.connect().await?)			Ok(channel.connect().await?)
	}			}

View Options

lib/selectors/user-selectors.js

	pub mod error;			pub mod error;
	pub mod identity;			pub mod identity;
	pub mod tunnelbroker;			pub mod tunnelbroker;

	// Re-export some dependencies which may need to be used by downstream crates			// Re-export some dependencies which may need to be used by downstream crates
	pub use tonic;			pub use tonic;

	use error::Error;			use error::Error;
	use std::path::Path;
	use std::time::Duration;			use std::time::Duration;
	use tonic::transport::{Certificate, Channel, ClientTlsConfig};			use tonic::transport::Channel;
	use tracing::info;			use tracing::info;

	const CERT_PATHS: &[&str] = &[
	// MacOS and newer Ubuntu
	"/etc/ssl/cert.pem",
	// Common CA cert paths
	"/etc/ssl/certs/ca-bundle.crt",
	"/etc/ssl/certs/ca-certificates.crt",
	];
	const CONNECT_TIMEOUT_DURATION: Duration = Duration::from_secs(5);			const CONNECT_TIMEOUT_DURATION: Duration = Duration::from_secs(5);

	pub(crate) fn get_ca_cert_contents() -> Option<String> {
	CERT_PATHS
	.iter()
	.map(Path::new)
	.filter(\|p\| p.exists())
	.filter_map(\|f\| std::fs::read_to_string(f).ok())
	.next()
	}
	pub(crate) async fn get_grpc_service_channel(			pub(crate) async fn get_grpc_service_channel(
	url: &str,			url: &str,
	) -> Result<Channel, Error> {			) -> Result<Channel, Error> {
	let ca_cert = crate::get_ca_cert_contents().expect("Unable to get CA bundle");

	info!("Connecting to gRPC service at {}", url);			info!("Connecting to gRPC service at {}", url);
	let mut channel = Channel::from_shared(url.to_string())?			let channel = Channel::from_shared(url.to_string())?
	.connect_timeout(CONNECT_TIMEOUT_DURATION);			.connect_timeout(CONNECT_TIMEOUT_DURATION);

	// tls_config will fail if the underlying URI is only http://
	if url.starts_with("https:") {
	channel = channel.tls_config(
	ClientTlsConfig::new().ca_certificate(Certificate::from_pem(&ca_cert)),
	)?
	}

	Ok(channel.connect().await?)			Ok(channel.connect().await?)
	}			}

View Options

lib/shared/markdown.js

	pub mod error;			pub mod error;
	pub mod identity;			pub mod identity;
	pub mod tunnelbroker;			pub mod tunnelbroker;

	// Re-export some dependencies which may need to be used by downstream crates			// Re-export some dependencies which may need to be used by downstream crates
	pub use tonic;			pub use tonic;

	use error::Error;			use error::Error;
	use std::path::Path;
	use std::time::Duration;			use std::time::Duration;
	use tonic::transport::{Certificate, Channel, ClientTlsConfig};			use tonic::transport::Channel;
	use tracing::info;			use tracing::info;

	const CERT_PATHS: &[&str] = &[
	// MacOS and newer Ubuntu
	"/etc/ssl/cert.pem",
	// Common CA cert paths
	"/etc/ssl/certs/ca-bundle.crt",
	"/etc/ssl/certs/ca-certificates.crt",
	];
	const CONNECT_TIMEOUT_DURATION: Duration = Duration::from_secs(5);			const CONNECT_TIMEOUT_DURATION: Duration = Duration::from_secs(5);

	pub(crate) fn get_ca_cert_contents() -> Option<String> {
	CERT_PATHS
	.iter()
	.map(Path::new)
	.filter(\|p\| p.exists())
	.filter_map(\|f\| std::fs::read_to_string(f).ok())
	.next()
	}
	pub(crate) async fn get_grpc_service_channel(			pub(crate) async fn get_grpc_service_channel(
	url: &str,			url: &str,
	) -> Result<Channel, Error> {			) -> Result<Channel, Error> {
	let ca_cert = crate::get_ca_cert_contents().expect("Unable to get CA bundle");

	info!("Connecting to gRPC service at {}", url);			info!("Connecting to gRPC service at {}", url);
	let mut channel = Channel::from_shared(url.to_string())?			let channel = Channel::from_shared(url.to_string())?
	.connect_timeout(CONNECT_TIMEOUT_DURATION);			.connect_timeout(CONNECT_TIMEOUT_DURATION);

	// tls_config will fail if the underlying URI is only http://
	if url.starts_with("https:") {
	channel = channel.tls_config(
	ClientTlsConfig::new().ca_certificate(Certificate::from_pem(&ca_cert)),
	)?
	}

	Ok(channel.connect().await?)			Ok(channel.connect().await?)
	}			}

View Options

lib/shared/mention-utils.js

	pub mod error;			pub mod error;
	pub mod identity;			pub mod identity;
	pub mod tunnelbroker;			pub mod tunnelbroker;

	// Re-export some dependencies which may need to be used by downstream crates			// Re-export some dependencies which may need to be used by downstream crates
	pub use tonic;			pub use tonic;

	use error::Error;			use error::Error;
	use std::path::Path;
	use std::time::Duration;			use std::time::Duration;
	use tonic::transport::{Certificate, Channel, ClientTlsConfig};			use tonic::transport::Channel;
	use tracing::info;			use tracing::info;

	const CERT_PATHS: &[&str] = &[
	// MacOS and newer Ubuntu
	"/etc/ssl/cert.pem",
	// Common CA cert paths
	"/etc/ssl/certs/ca-bundle.crt",
	"/etc/ssl/certs/ca-certificates.crt",
	];
	const CONNECT_TIMEOUT_DURATION: Duration = Duration::from_secs(5);			const CONNECT_TIMEOUT_DURATION: Duration = Duration::from_secs(5);

	pub(crate) fn get_ca_cert_contents() -> Option<String> {
	CERT_PATHS
	.iter()
	.map(Path::new)
	.filter(\|p\| p.exists())
	.filter_map(\|f\| std::fs::read_to_string(f).ok())
	.next()
	}
	pub(crate) async fn get_grpc_service_channel(			pub(crate) async fn get_grpc_service_channel(
	url: &str,			url: &str,
	) -> Result<Channel, Error> {			) -> Result<Channel, Error> {
	let ca_cert = crate::get_ca_cert_contents().expect("Unable to get CA bundle");

	info!("Connecting to gRPC service at {}", url);			info!("Connecting to gRPC service at {}", url);
	let mut channel = Channel::from_shared(url.to_string())?			let channel = Channel::from_shared(url.to_string())?
	.connect_timeout(CONNECT_TIMEOUT_DURATION);			.connect_timeout(CONNECT_TIMEOUT_DURATION);

	// tls_config will fail if the underlying URI is only http://
	if url.starts_with("https:") {
	channel = channel.tls_config(
	ClientTlsConfig::new().ca_certificate(Certificate::from_pem(&ca_cert)),
	)?
	}

	Ok(channel.connect().await?)			Ok(channel.connect().await?)
	}			}