fix: make the CI pass

crates/supabase-auth/src/jwt_expiry.rs

@@ -1,12 +1,13 @@
-use std::task::{Context, Poll};
-use std::time::Duration;
+use core::pin::Pin;
+use core::task::{Context, Poll};
+use core::time::Duration;
 
 use futures::Future;
 use futures_timer::Delay;
 use pin_project::pin_project;
 
 #[pin_project]
-pub(crate) struct JwtExpiry {
+pub struct JwtExpiry {
     #[pin]
     delay: Delay,
 }
@@ -22,7 +23,7 @@ impl JwtExpiry {
 impl Future for JwtExpiry {
     type Output = ();
 
-    fn poll(self: std::pin::Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
+    fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
         self.project().delay.poll(cx)
     }
 }

crates/supabase-auth/src/lib.rs

@@ -1,8 +1,10 @@
+extern crate alloc;
+
 mod jwt_expiry;
-use std::borrow::Cow;
-use std::ops::{Div, Mul};
-use std::pin::Pin;
-use std::task::{Context, Poll};
+use alloc::borrow::Cow;
+use core::ops::{Div, Mul};
+use core::pin::Pin;
+use core::task::{Context, Poll};
 use std::time::{Duration, SystemTime, UNIX_EPOCH};
 
 use base64::prelude::*;
@@ -26,7 +28,8 @@ pub struct SupabaseAuth {
 
 impl SupabaseAuth {
     /// Creates a new [`SupabaseAuth`].
-    pub fn new(url: url::Url, api_key: String) -> Self {
+    #[must_use]
+    pub const fn new(url: url::Url, api_key: String) -> Self {
         Self { url, api_key }
     }
 
@@ -63,7 +66,8 @@ pub struct TokenBody<'a> {
 }
 
 impl<'a> TokenBody<'a> {
-    pub fn new(email: &'a str, password: &'a str) -> Self {
+    #[must_use]
+    pub const fn new(email: &'a str, password: &'a str) -> Self {
         Self {
             email: Cow::Borrowed(email),
             password: redact::Secret::new(Cow::Borrowed(password)),
@@ -73,17 +77,17 @@ impl<'a> TokenBody<'a> {
 
 #[pin_project]
 pub struct RefreshStream<'a> {
-    password_url: url::Url,
-    refresh_url: url::Url,
+    pub password_url: url::Url,
+    pub refresh_url: url::Url,
     pub api_key: String,
-    client: Client,
-    token_body: TokenBody<'a>,
+    pub client: Client,
+    pub token_body: TokenBody<'a>,
     #[pin]
-    state: RefreshStreamState,
+    pub state: RefreshStreamState,
 }
 
 #[pin_project]
-enum RefreshStreamState {
+pub enum RefreshStreamState {
     PasswordLogin,
     WaitingForResponse(
         #[pin] futures::future::BoxFuture<'static, Result<Response, reqwest::Error>>,
@@ -147,15 +151,15 @@ impl<'a> Stream for RefreshStream<'a> {
                             // Get the current time as Unix timestamp
                             let current_ts = SystemTime::now()
                                 .duration_since(UNIX_EPOCH)
-                                .expect("Time went backwards")
+                                .unwrap_or_else(|_| Duration::from_secs(0)) // Fallback to 0
                                 .as_secs();
 
                             // Calculate the duration until expiration
                             let valid_for = if expires_at_ts > current_ts {
-                                // and divide by `2/3` just to be on the safe side
-                                Duration::from_secs(expires_at_ts - current_ts)
-                                    .mul(3)
-                                    .div(2)
+                                // Use saturating_sub to handle underflow
+                                let remaining_secs = expires_at_ts.saturating_sub(current_ts);
+                                // Divide by `2/3` just to be on the safe side
+                                Duration::from_secs(remaining_secs).mul(2).div(3)
                             } else {
                                 Duration::from_secs(1)
                             };
@@ -182,7 +186,8 @@ impl<'a> Stream for RefreshStream<'a> {
                     refresh_token,
                     access_expiry,
                 } => {
-                    let _res = std::task::ready!(access_expiry.poll_unpin(cx));
+                    std::task::ready!(access_expiry.poll_unpin(cx));
+
                     let request_future = this
                         .client
                         .post(this.refresh_url.clone())

crates/supabase-client/Cargo.toml

@@ -10,6 +10,7 @@ reqwest.workspace = true
 tokio.workspace = true
 tracing.workspace = true
 thiserror.workspace = true
+futures.workspace = true
 
 [lints]
 workspace = true

crates/supabase-client/src/client/authenticated.rs

@@ -1,3 +1,4 @@
+extern crate alloc;
 use std::sync::Arc;
 
 use tokio::sync::RwLock;

crates/supabase-client/src/client/unauthenticated.rs

@@ -1,6 +1,6 @@
 use std::sync::Arc;
 
-use supabase_auth::futures::StreamExt;
+use futures::StreamExt;
 use supabase_auth::TokenBody;
 use tokio::sync::RwLock;
 

crates/supabase-mock/src/lib.rs

@@ -44,7 +44,7 @@ impl SupabaseMockServer {
     }
 
     fn register_jwt_custom_grant_type(&mut self, jwt: &str, grant_type: &str) -> &mut Self {
-        let _m = self
+        let mock = self
             .mockito_server
             .mock("POST", "/auth/v1/token")
             .match_query(Matcher::Regex(format!("grant_type={grant_type}")))
@@ -54,7 +54,7 @@ impl SupabaseMockServer {
                 json!({
                     "access_token": jwt,
                     "refresh_token": "some-refresh-token",
-                    "expires_in": 3600,
+                    "expires_in": 3_600_i32,
                     "token_type": "bearer",
                     "user": {
                         "id": "user-id",
@@ -64,7 +64,7 @@ impl SupabaseMockServer {
                 .to_string(),
             )
             .create();
-        self.api_mock.push(_m);
+        self.api_mock.push(mock);
         self
     }
 }