feat: Add metrics for user creation/deletion.

autoconnect/autoconnect-ws/autoconnect-ws-sm/src/identified/mod.rs

@@ -297,6 +297,8 @@ pub async fn process_existing_user(
                 .metrics
                 .incr_with_tags("ua.expiration")
                 .with_tag("code", "104")
+                .with_tag("autoconnect", "true")
+                .with_tag("reason", "no_current_month")
                 .send();
             app_state.db.remove_user(&user.uaid).await?;
             return Ok(None);
@@ -311,6 +313,8 @@ pub async fn process_existing_user(
                 .metrics
                 .incr_with_tags("ua.expiration")
                 .with_tag("code", "105")
+                .with_tag("autoconnect", "true")
+                .with_tag("reason", "invalid_current_month")
                 .send();
             app_state.db.remove_user(&user.uaid).await?;
             return Ok(None);

autoconnect/autoconnect-ws/autoconnect-ws-sm/src/identified/on_client_msg.rs

@@ -316,6 +316,12 @@ impl WebPushClient {
         let flags = &self.flags;
         if flags.reset_uaid {
             debug!("▶️ WebPushClient:post_process_all_acked reset_uaid");
+            self.app_state
+                .metrics
+                .incr_with_tags("ua.expiration")
+                .with_tag("autoconnect", "true")
+                .with_tag("reason", "reset_uaid")
+                .send();
             self.app_state.db.remove_user(&self.uaid).await?;
             Err(SMErrorKind::UaidReset.into())
         } else {

autoconnect/autoconnect-ws/autoconnect-ws-sm/src/identified/on_server_notif.rs

@@ -295,6 +295,12 @@ impl WebPushClient {
         if self.sent_from_storage > self.app_state.settings.msg_limit {
             // Exceeded the max limit of stored messages: drop the user to
             // trigger a re-register
+            self.app_state
+                .metrics
+                .incr_with_tags("ua.expiration")
+                .with_tag("autoconnect", "true")
+                .with_tag("reason", "too_many_messages")
+                .send();
             self.app_state.db.remove_user(&self.uaid).await?;
             return Err(SMErrorKind::UaidReset.into());
         }

autoconnect/autoconnect-ws/autoconnect-ws-sm/src/unidentified.rs

@@ -67,19 +67,27 @@ impl UnidentifiedClient {
         );
 
         // Ignore invalid uaids (treat as None) so they'll be issued a new one
-        let uaid = uaid.as_deref().and_then(|uaid| Uuid::try_parse(uaid).ok());
+        let original_uaid = uaid.as_deref().and_then(|uaid| Uuid::try_parse(uaid).ok());
 
         let GetOrCreateUser {
             user,
             existing_user,
             flags,
-        } = self.get_or_create_user(uaid).await?;
+        } = self.get_or_create_user(original_uaid).await?;
         let uaid = user.uaid;
         debug!(
             "💬UnidentifiedClient::on_client_msg Hello! uaid: {} existing_user: {}",
             uaid, existing_user,
         );
-        let _ = self.app_state.metrics.incr("ua.command.hello");
+        self.app_state
+            .metrics
+            .incr_with_tags("ua.command.hello")
+            .with_tag("existing_user", &original_uaid.is_some().to_string())
+            .with_tag(
+                "reassigned",
+                &(original_uaid.unwrap_or(uaid) != uaid).to_string(),
+            )
+            .send();
 
         let (broadcast_subs, broadcasts) = self
             .broadcast_init(&Broadcast::from_hashmap(broadcasts.unwrap_or_default()))