From f08ef97f4894fde8feff08bb91bed1e1c1105b83 Mon Sep 17 00:00:00 2001 From: mo khan Date: Thu, 19 Jun 2025 11:40:27 -0600 Subject: test: add tests --- src/main.rs | 35 ++++------------------------------- 1 file changed, 4 insertions(+), 31 deletions(-) (limited to 'src/main.rs') diff --git a/src/main.rs b/src/main.rs index 05d57719..25e2c88f 100644 --- a/src/main.rs +++ b/src/main.rs @@ -1,35 +1,8 @@ -use envoy_types::ext_authz::v3::pb::{ - Authorization, AuthorizationServer, CheckRequest, CheckResponse, -}; -use envoy_types::ext_authz::v3::{CheckRequestExt, CheckResponseExt}; -use tonic::{Request, Response, Status, transport::Server}; +use envoy_types::ext_authz::v3::pb::AuthorizationServer; +use tonic::transport::Server; -#[derive(Debug, Default)] -struct PolicyServer; - -#[tonic::async_trait] -impl Authorization for PolicyServer { - async fn check( - &self, - request: Request, - ) -> Result, Status> { - let request = request.into_inner(); - - let client_headers = request - .get_client_headers() - .ok_or_else(|| Status::invalid_argument("client headers not populated by envoy"))?; - - let mut request_status = Status::unauthenticated("not authorized"); - - if let Some(authorization) = client_headers.get("authorization") { - if authorization == "Bearer valid-token" { - request_status = Status::ok("request is valid"); - } - } - - Ok(Response::new(CheckResponse::with_status(request_status))) - } -} +pub mod authorization; +use authorization::PolicyServer; #[tokio::main] async fn main() -> Result<(), Box> { -- cgit v1.2.3