fmt

Author: MaxHeimbrock

examples/token_source/src/main.rs

@@ -1,7 +1,8 @@
+use async_trait::async_trait;
 use livekit_token_source::{
-    TokenSourceConfigurable, TokenSourceFetchOptions, TokenSourceFixed, TokenSourceResponse, TokenSourceResult
+    TokenSourceConfigurable, TokenSourceFetchOptions, TokenSourceFixed, TokenSourceResponse,
+    TokenSourceResult,
 };
-use async_trait::async_trait;
 
 /// An example for a custom token source that reads credentials from a JSON file, e.g.
 /// `{"server_url": "wss://...", "participant_token": "..."}`.
@@ -11,9 +12,7 @@ struct FileTokenSource {
 
 #[async_trait]
 impl TokenSourceFixed for FileTokenSource {
-    async fn fetch(
-        &self
-    ) -> TokenSourceResult<TokenSourceResponse> {
+    async fn fetch(&self) -> TokenSourceResult<TokenSourceResponse> {
         let contents = std::fs::read_to_string(&self.path).map_err(serde_json::Error::io)?;
         let response = serde_json::from_str(&contents)?;
         Ok(response)
@@ -23,10 +22,8 @@ impl TokenSourceFixed for FileTokenSource {
 #[tokio::main]
 async fn main() {
     // A literal token source returns a fixed set of pre-provisioned credentials.
-    let literal = livekit_token_source::literal(
-        "wss://example.livekit.cloud", 
-        "<a pre-generated token>"
-    );
+    let literal =
+        livekit_token_source::literal("wss://example.livekit.cloud", "<a pre-generated token>");
     match literal.fetch().await {
         Ok(response) => println!(
             "literal: server_url={} participant_token={}",
@@ -37,9 +34,8 @@ async fn main() {
 
     // A custom token source can procure credentials from anywhere; this one
     // reads them from a JSON file next to this example's Cargo.toml.
-    let file_source = FileTokenSource {
-        path: concat!(env!("CARGO_MANIFEST_DIR"), "/token.txt").into(),
-    };
+    let file_source =
+        FileTokenSource { path: concat!(env!("CARGO_MANIFEST_DIR"), "/token.txt").into() };
     match file_source.fetch().await {
         Ok(response) => println!(
             "file: server_url={} participant_token={}",
@@ -57,7 +53,8 @@ async fn main() {
         .with_participant_identity("example-user");
 
     // Development token server: for prototyping only, NOT for production use.
-    let development_token_server = livekit_token_source::development_token_server(sandbox_id.clone());
+    let development_token_server =
+        livekit_token_source::development_token_server(sandbox_id.clone());
     match development_token_server.fetch(&options).await {
         Ok(response) => println!(
             "development token server: server_url={} participant_token={}",
@@ -69,8 +66,9 @@ async fn main() {
     // Endpoint: POSTs the fetch options to a token endpoint using the standard
     // format; here pointed at the same development token server.
     let endpoint = livekit_token_source::endpoint(
-        "https://cloud-api.livekit.io/api/v2/sandbox/connection-details"
-        ).with_header("X-Sandbox-ID", sandbox_id);
+        "https://cloud-api.livekit.io/api/v2/sandbox/connection-details",
+    )
+    .with_header("X-Sandbox-ID", sandbox_id);
     match endpoint.fetch(&options).await {
         Ok(response) => println!(
             "endpoint: server_url={} participant_token={}",