After auth reset force_expired flag (#100)

* After auth reset force_expired flag

* Bump versions

Cargo.toml

@@ -8,7 +8,7 @@ members = [
 ]
 
 [workspace.package]
-version = "0.15.22"
+version = "0.15.23"
 
 [workspace.dependencies]
 tokio = { version = "1.39", features = ["full"] }

packages/agent_core/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "playit-agent-core"
-version = "0.17.5"
+version = "0.17.6"
 edition = "2021"
 description = "Contains the logic to create a playit.gg agent"
 license = "BSD-2-Clause"

packages/agent_core/src/agent_control/established_control.rs

@@ -44,8 +44,17 @@ impl<A: AuthResource, IO: PacketIO> EstablishedControl<A, IO> {
         self.registered.expires_at
     }
 
-    pub fn is_expired(&self) -> bool {
-        self.force_expired || self.pong_at_auth.session_expire_at.is_none() || self.flow_changed()
+    pub fn is_expired(&self) -> Option<ExpiredReason> {
+        if self.force_expired {
+            return Some(ExpiredReason::Forced);
+        }
+        if self.pong_at_auth.session_expire_at.is_none() {
+            return Some(ExpiredReason::SessionNotSetup);
+        }
+        if self.flow_changed() {
+            return Some(ExpiredReason::FlowChanged);
+        }
+        None
     }
 
     pub fn set_expired(&mut self) {
@@ -65,6 +74,7 @@ impl<A: AuthResource, IO: PacketIO> EstablishedControl<A, IO> {
     pub async fn authenticate(&mut self) -> Result<(), SetupError> {
         let registered = self.conn.authenticate(&self.auth).await?;
 
+        self.force_expired = false;
         self.registered = registered;
         self.pong_at_auth = self.conn.pong_latest.clone();
 
@@ -115,3 +125,11 @@ impl<A: AuthResource, IO: PacketIO> EstablishedControl<A, IO> {
         Ok(feed)
     }
 }
+
+
+#[derive(Debug, PartialEq, Eq)]
+pub enum ExpiredReason {
+    Forced,
+    SessionNotSetup,
+    FlowChanged,
+}

packages/agent_core/src/agent_control/maintained_control.rs

@@ -88,7 +88,9 @@ impl<I: PacketIO, A: AuthResource> MaintainedControl<I, A> {
     }
 
     pub async fn update(&mut self) -> Option<NewClient> {
-        if self.control.is_expired() {
+        if let Some(reason) = self.control.is_expired() {
+            tracing::warn!(?reason, "session expired");
+
             if let Err(error) = self.control.authenticate().await {
                 tracing::error!(?error, "failed to authenticate");
                 tokio::time::sleep(Duration::from_secs(2)).await;