chore: example for oauth

Author: prestwich

Cargo.toml

@@ -54,6 +54,7 @@ reqwest = { version = "0.12.15", optional = true }
 [dev-dependencies]
 ajj = "0.3.1"
 axum = "0.8.1"
+eyre = "0.6.12"
 serial_test = "3.2.0"
 signal-hook = "0.3.17"
 tokio = { version = "1.43.0", features = ["macros"] }

examples/oauth.rs

@@ -0,0 +1,15 @@
+use init4_bin_base::{perms::OAuthConfig, utils::from_env::FromEnv};
+
+#[tokio::main]
+async fn main() -> eyre::Result<()> {
+    let cfg = OAuthConfig::from_env()?;
+    let authenticator = cfg.authenticator();
+    let token = authenticator.token();
+
+    let _jh = authenticator.spawn();
+
+    tokio::time::sleep(std::time::Duration::from_secs(5)).await;
+    dbg!(token.read());
+
+    Ok(())
+}

src/perms/mod.rs

@@ -5,4 +5,4 @@ pub(crate) mod config;
 pub use config::{SlotAuthzConfig, SlotAuthzConfigEnvError};
 
 pub(crate) mod oauth;
-pub use oauth::{Authenticator, SharedToken};
+pub use oauth::{Authenticator, OAuthConfig, SharedToken};

src/perms/oauth.rs

@@ -50,6 +50,13 @@ pub struct OAuthConfig {
     pub oauth_token_refresh_interval: u64,
 }
 
+impl OAuthConfig {
+    /// Create a new [`Authenticator`] from the provided config.
+    pub fn authenticator(&self) -> Authenticator {
+        Authenticator::new(self)
+    }
+}
+
 /// A shared token that can be read and written to by multiple threads.
 #[derive(Debug, Clone, Default)]
 pub struct SharedToken(Arc<Mutex<Option<Token>>>);