ok2/RFKPOS - Change HAVWPOXJXKLKF6P4ATMK52LEVARG4UURFFGCFN5EA4ZMF4JZGARAC

Authenticate through Authenticator object, shared by all services.

Created by ok2 on November 2, 2022

HAVWPOXJXKLKF6P4ATMK52LEVARG4UURFFGCFN5EA4ZMF4JZGARAC

Dependencies

In channels

main

Change contents

Insertion in src/main.rs at line 7 [4.49]
[2.68]
[3.173]
```
use std::sync::{Arc, Mutex};
```

Insertion in src/main.rs at line 41 [4.49]

[2.282]

[3.897]

    }
}
struct Authenticator { token: String }
impl Authenticator {
    fn get_token(&self) -> &str {
        self.token.as_str()

Insertion in src/main.rs at line 58 [4.49]

[5.322]

[3.1027]

    let authenticator = Arc::new(Mutex::new(Authenticator { token: "Bearer test-token".to_string() }));

Replacement in src/main.rs at line 60 [4.49]

B:BD[3.1073] → [5.323:405]

    let bookstore_svc = BookstoreServer::with_interceptor(bookstore, check_auth);

[3.1073]

    let bookstore_auth = Arc::clone(&authenticator);
    let bookstore_svc = BookstoreServer::with_interceptor(bookstore, move |r| check_auth(r, bookstore_auth.clone()));

Replacement in src/main.rs at line 67 [4.49]

B:BD[3.1280] → [5.406:496]

    let reflection_service_svc = InterceptedService::new(reflection_service, check_auth);

[3.1280]

[2.283]

    let reflection_service_auth = Arc::clone(&authenticator);
    let reflection_service_svc = InterceptedService::new(reflection_service, move |r| check_auth(r, reflection_service_auth.clone()));

Replacement in src/main.rs at line 86 [4.49]

B:BD[5.658] → [5.658:795]

fn check_auth(req: Request<()>) -> Result<Request<()>, Status> {
    let token: MetadataValue<_> = "Bearer test-token".parse().unwrap();

[5.658]

[5.795]

fn check_auth(req: Request<()>, authenticator: Arc<Mutex<Authenticator>>) -> Result<Request<()>, Status> {
    let token: MetadataValue<_> = authenticator.lock().unwrap().get_token().parse().unwrap();