[identity] Return use_new_flow in V1 login RPCs

Summary:
Address part of [[ https://linear.app/comm/issue/ENG-9697/return-use-new-flows-for-old-flow-only-rpcs | ENG-9697 ]].

Depends on D14073

Test Plan: Used primary device logout to sign the device list, then tried V1 login again, the `use_new_flow` was returned.

Reviewers: kamil, varun

Reviewed By: kamil

Subscribers: ashoat, tomek

Differential Revision: https://phab.comm.dev/D14074

services/identity/src/client_service.rs

@@ -333,6 +333,17 @@ impl IdentityClientService for ClientService {
       ));
     };
 
+    if self
+      .client
+      .get_user_login_flow(&user_id)
+      .await?
+      .is_signed_device_list_flow()
+    {
+      return Err(tonic::Status::failed_precondition(
+        tonic_status_messages::USE_NEW_FLOW,
+      ));
+    }
+
     let flattened_device_key_upload =
       construct_flattened_device_key_upload(&message)?;
     self
@@ -484,6 +495,17 @@ impl IdentityClientService for ClientService {
       .get_user_id_from_user_info(wallet_address.clone(), &AuthType::Wallet)
       .await?
     {
+      if self
+        .client
+        .get_user_login_flow(&user_id)
+        .await?
+        .is_signed_device_list_flow()
+      {
+        return Err(tonic::Status::failed_precondition(
+          tonic_status_messages::USE_NEW_FLOW,
+        ));
+      }
+
       self
         .check_device_id_taken(&flattened_device_key_upload, Some(&user_id))
         .await?;
@@ -510,6 +532,17 @@ impl IdentityClientService for ClientService {
         ));
       };
 
+      if self
+        .client
+        .get_user_login_flow(&user_id)
+        .await?
+        .is_signed_device_list_flow()
+      {
+        return Err(tonic::Status::failed_precondition(
+          tonic_status_messages::USE_NEW_FLOW,
+        ));
+      }
+
       // It's possible that the user attempting login is already registered
       // on Ashoat's keyserver. If they are, we should try to register them if
       // they're on a mobile device, otherwise we should send back a gRPC status