Add User Federated Identity Credential (user_fic) grant type support

msal4j-sdk/src/integrationtest/java/com/microsoft/aad/msal4j/AgenticIT.java

@@ -15,12 +15,14 @@
 import java.security.cert.CertificateException;
 import java.security.cert.X509Certificate;
 import java.util.Collections;
+import java.util.Set;
 import java.util.concurrent.atomic.AtomicReference;
 import java.util.function.Function;
 
 /**
  * Integration tests for agentic (agent identity) scenarios using MSAL Java APIs.
- * Tests FMI credential acquisition via assertion callbacks and cache isolation.
+ * Corresponds to .NET's Agentic.cs — tests the MSAL-level APIs for the agent identity flow
+ * (specifically the FMI portions that are available on this branch, plus FIC user_fic flows).
  *
  * <p>These tests use MSAL token acquisition APIs (unlike AgenticRawHttpIT which uses raw HTTP).
  *
@@ -31,20 +33,26 @@
  *   <li>Tenant: {@link #TENANT_ID}</li>
  * </ul>
  *
- * <p>Flows tested (FMI-only, no FIC/user_fic on this branch):
+ * <p>Flows tested:
  * <ul>
  *   <li>Assertion callback receives correct context (AssertionRequestOptions)</li>
  *   <li>Cache isolation between different fmi_path values</li>
+ *   <li>Full 3-leg flow: FMI → assertion → user_fic → user token</li>
+ *   <li>Multi-user cache isolation via user_fic</li>
  * </ul>
  */
 @TestInstance(TestInstance.Lifecycle.PER_CLASS)
 class AgenticIT {
 
     // Lab test configuration
+    private static final String BLUEPRINT_CLIENT_ID = "aab5089d-e764-47e3-9f28-cc11c2513821";
     private static final String RMA_CLIENT_ID = "3bf56293-fbb5-42bd-a407-248ba7431a8c";
     private static final String TENANT_ID = "10c419d4-4a50-45b2-aa4e-919fb84df24f";
     private static final String AGENT_APP_ID = "ab18ca07-d139-4840-8b3b-4be9610c6ed5";
+    private static final String USER_UPN = "agentuser1@id4slab1.onmicrosoft.com";
+    private static final String TOKEN_EXCHANGE_SCOPE = "api://AzureADTokenExchange/.default";
     private static final String FMI_EXCHANGE_SCOPE = "api://AzureFMITokenExchange/.default";
+    private static final String GRAPH_SCOPE = "https://graph.microsoft.com/.default";
     private static final String AZURE_REGION = "westus3";
 
     private static final String AUTHORITY = "https://login.microsoftonline.com/" + TENANT_ID + "/";
@@ -66,6 +74,42 @@ void init() throws KeyStoreException, NoSuchProviderException,
         assertNotNull(certificate, "Lab certificate not found. Ensure the lab cert is installed.");
     }
 
+    /**
+     * Agent gets an app-only token for Graph using an FMI-sourced client assertion.
+     * This tests Leg 2 of the agent identity flow:
+     * 1. Blueprint CCA acquires FMI credential (fmi_path = agentAppId)
+     * 2. Agent CCA uses that credential as client_assertion to get Graph token
+     *
+     * Corresponds to .NET's AgentGetsAppTokenForGraphTest.
+     */
+    @Test
+    void agentGetsAppToken_UsingFmiAssertion() throws Exception {
+        // The assertion callback simulates what an SDK or middleware would do:
+        // it calls the blueprint app to get an FMI credential for the agent
+        Function<AssertionRequestOptions, String> assertionProvider = options -> {
+            try {
+                return acquireFmiCredentialForAgent(AGENT_APP_ID);
+            } catch (Exception e) {
+                throw new RuntimeException("Failed to acquire FMI credential", e);
+            }
+        };
+
+        IClientCredential credential = ClientCredentialFactory.createFromCallback(assertionProvider);
+
+        ConfidentialClientApplication agentCca = ConfidentialClientApplication.builder(AGENT_APP_ID, credential)
+                .authority(AUTHORITY)
+                .build();
+
+        IAuthenticationResult result = agentCca.acquireToken(ClientCredentialParameters
+                        .builder(Collections.singleton(GRAPH_SCOPE))
+                        .build())
+                .get();
+
+        assertNotNull(result, "Auth result should not be null");
+        assertNotNull(result.accessToken(), "Access token should not be null");
+        assertFalse(result.accessToken().isEmpty(), "Access token should not be empty");
+    }
+
     /**
      * Verifies that the context-aware assertion callback receives the correct fmiPath
      * when the ClientCredentialParameters include an fmiPath.
@@ -159,8 +203,105 @@ void agentFmiToken_CacheIsolation_DifferentFmiPaths() throws Exception {
     }
 
     /**
-     * Helper: acquires an FMI credential from the RMA using a certificate.
-     * Uses the FMI-specific exchange scope (api://AzureFMITokenExchange).
+     * Full 3-leg agent identity flow: FMI → assertion → user_fic → user-scoped Graph token.
+     * Uses the assertion callback pattern where the blueprint CCA acquires the FMI credential
+     * and the agent CCA exchanges it for a user token.
+     */
+    @Test
+    void agentUserIdentity_GetsTokenForGraph() throws Exception {
+        // Build agent CCA with assertion callback that acquires FMI credential
+        Function<AssertionRequestOptions, String> assertionProvider = options -> {
+            try {
+                return acquireFmiCredentialForAgent(AGENT_APP_ID);
+            } catch (Exception e) {
+                throw new RuntimeException("Failed to acquire FMI credential", e);
+            }
+        };
+
+        IClientCredential credential = ClientCredentialFactory.createFromCallback(assertionProvider);
+
+        ConfidentialClientApplication agentCca = ConfidentialClientApplication.builder(AGENT_APP_ID, credential)
+                .authority(AUTHORITY)
+                .build();
+
+        // Get instance token (T2) for user_fic exchange
+        String t2 = acquireInstanceTokenForAgent();
+
+        // Exchange T2 for user-scoped token via user_fic grant
+        UserFederatedIdentityCredentialParameters params = UserFederatedIdentityCredentialParameters
+                .builder(Collections.singleton(GRAPH_SCOPE), USER_UPN, t2)
+                .build();
+
+        IAuthenticationResult result = agentCca.acquireToken(params).get();
+
+        assertNotNull(result, "Auth result should not be null");
+        assertNotNull(result.accessToken(), "Access token should not be null");
+        assertFalse(result.accessToken().isEmpty(), "Access token should not be empty");
+        assertNotNull(result.account(), "Account should not be null (user token)");
+
+        // Verify token is cached and silent retrieval works
+        Set<IAccount> accounts = agentCca.getAccounts().get();
+        assertFalse(accounts.isEmpty(), "Accounts should be in cache");
+
+        IAccount account = accounts.iterator().next();
+        IAuthenticationResult silentResult = agentCca.acquireTokenSilently(
+                SilentParameters.builder(Collections.singleton(GRAPH_SCOPE), account).build()).get();
+
+        assertEquals(result.accessToken(), silentResult.accessToken(),
+                "Silent call should return cached token");
+    }
+
+    /**
+     * Verifies that user_fic tokens and app-only tokens are isolated in cache
+     * on the same agent CCA instance. App token acquisition should not interfere
+     * with user token acquisition.
+     */
+    @Test
+    void agentCca_AppAndUserTokens_CacheIsolation() throws Exception {
+        Function<AssertionRequestOptions, String> assertionProvider = options -> {
+            try {
+                return acquireFmiCredentialForAgent(AGENT_APP_ID);
+            } catch (Exception e) {
+                throw new RuntimeException("Failed to acquire FMI credential", e);
+            }
+        };
+
+        IClientCredential credential = ClientCredentialFactory.createFromCallback(assertionProvider);
+
+        ConfidentialClientApplication agentCca = ConfidentialClientApplication.builder(AGENT_APP_ID, credential)
+                .authority(AUTHORITY)
+                .build();
+
+        // Acquire app-only token
+        IAuthenticationResult appResult = agentCca.acquireToken(ClientCredentialParameters
+                        .builder(Collections.singleton(GRAPH_SCOPE))
+                        .build())
+                .get();
+        assertNotNull(appResult.accessToken());
+
+        // Acquire user token via user_fic (needs T2 = instance token)
+        String t2 = acquireInstanceTokenForAgent();
+        UserFederatedIdentityCredentialParameters userParams = UserFederatedIdentityCredentialParameters
+                .builder(Collections.singleton(GRAPH_SCOPE), USER_UPN, t2)
+                .build();
+
+        IAuthenticationResult userResult = agentCca.acquireToken(userParams).get();
+        assertNotNull(userResult.accessToken());
+        assertNotNull(userResult.account(), "User token should have an account");
+
+        // Tokens should be different (app vs user scoped)
+        assertNotEquals(appResult.accessToken(), userResult.accessToken(),
+                "App token and user token should be different");
+
+        // App cache should have 1 entry, user cache should have user account
+        assertTrue(agentCca.tokenCache.accessTokens.size() >= 2,
+                "Cache should have at least 2 entries (app + user)");
+    }
+
+    /**
+     * Helper: acquires an FMI credential from the RMA (Resource Management Application).
+     * Uses FMI_EXCHANGE_SCOPE, matching FmiIT's Flow3 pattern.
+     * Suitable for use as client_assertion when client_id = "urn:microsoft:identity:fmi".
      */
     private String acquireFmiCredentialFromRma() throws Exception {
         IClientCertificate clientCert = ClientCredentialFactory.createFromCertificate(privateKey, certificate);
@@ -180,4 +321,51 @@ private String acquireFmiCredentialFromRma() throws Exception {
         IAuthenticationResult result = rmaCca.acquireToken(params).get();
         return result.accessToken();
     }
+
+    /**
+     * Helper: acquires an FMI credential from the blueprint app for the given agent app ID.
+     * This is Leg 1 of the agent identity flow — returns T1.
+     */
+    private String acquireFmiCredentialForAgent(String agentAppId) throws Exception {
+        IClientCertificate clientCert = ClientCredentialFactory.createFromCertificate(privateKey, certificate);
+
+        ConfidentialClientApplication blueprintCca = ConfidentialClientApplication.builder(
+                        BLUEPRINT_CLIENT_ID, clientCert)
+                .authority(AUTHORITY)
+                .sendX5c(true)
+                .azureRegion(AZURE_REGION)
+                .build();
+
+        ClientCredentialParameters params = ClientCredentialParameters
+                .builder(Collections.singleton(TOKEN_EXCHANGE_SCOPE))
+                .fmiPath(agentAppId)
+                .build();
+
+        IAuthenticationResult result = blueprintCca.acquireToken(params).get();
+        return result.accessToken();
+    }
+
+    /**
+     * Helper: acquires an instance token (T2) for the agent app via the full 2-leg flow.
+     * Leg 1: Blueprint → T1 (FMI credential)
+     * Leg 2: Agent uses T1 as client_assertion → T2 (instance token)
+     * T2 is used as the user_federated_identity_credential in Leg 3 (user_fic exchange).
+     */
+    private String acquireInstanceTokenForAgent() throws Exception {
+        String t1 = acquireFmiCredentialForAgent(AGENT_APP_ID);
+
+        IClientCredential agentCredential = ClientCredentialFactory.createFromClientAssertion(t1);
+
+        ConfidentialClientApplication agentCca = ConfidentialClientApplication.builder(AGENT_APP_ID, agentCredential)
+                .authority(AUTHORITY)
+                .build();
+
+        ClientCredentialParameters instanceParams = ClientCredentialParameters
+                .builder(Collections.singleton(TOKEN_EXCHANGE_SCOPE))
+                .skipCache(true)
+                .build();
+
+        IAuthenticationResult instanceResult = agentCca.acquireToken(instanceParams).get();
+        return instanceResult.accessToken();
+    }
 }