summaryrefslogtreecommitdiff
path: root/src/authorization/server.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/authorization/server.rs')
-rw-r--r--src/authorization/server.rs12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/authorization/server.rs b/src/authorization/server.rs
index 23b7720e..759a550d 100644
--- a/src/authorization/server.rs
+++ b/src/authorization/server.rs
@@ -8,13 +8,13 @@ pub struct Server {
}
impl Server {
- pub fn new() -> Result<Server, Box<dyn std::error::Error>> {
+ pub fn new<T: super::Authorizer>(authorizer: T) -> Result<Server, Box<dyn std::error::Error>> {
let (health_reporter, health_service) = tonic_health::server::health_reporter();
std::mem::drop(
health_reporter.set_service_status("", tonic_health::ServingStatus::Serving),
);
let authorization_service =
- AuthorizationServer::new(CheckService::new(Arc::new(CedarAuthorizer::default())));
+ AuthorizationServer::new(CheckService::new(Arc::new(authorizer)));
let reflection_service = tonic_reflection::server::Builder::configure()
.register_encoded_file_descriptor_set(tonic_health::pb::FILE_DESCRIPTOR_SET)
@@ -40,9 +40,9 @@ impl Server {
tracing::info!(
method = %req.method(),
path = %req.uri().path(),
- content_type = ?req.headers().get("content-type").and_then(|v| v.to_str().ok()),
- user_agent = ?req.headers().get("user-agent").and_then(|v| v.to_str().ok()),
- x_request_id = ?req.headers().get("x-request-id").and_then(|v| v.to_str().ok()),
+ content_type = req.headers().get("content-type").map_or("unknown", |v| v.to_str().unwrap_or("unknown")),
+ user_agent = req.headers().get("user-agent").map_or("unknown", |v| v.to_str().unwrap_or("unknown")),
+ x_request_id = req.headers().get("x-request-id").map_or("none", |v| v.to_str().unwrap_or("none")),
"gRPC request"
);
@@ -64,6 +64,6 @@ impl Server {
impl Default for Server {
fn default() -> Self {
- Self::new().unwrap()
+ Self::new(CedarAuthorizer::default()).unwrap()
}
}