Integration Patterns

System A -(request)->Dataverse->(response)->System A
    |
    |- Blocks business flow if dataverse is slow or throttled

System A -(enqueue)->Queue/Topic->Worker->Dataverse
    |                       |
    |- User continous       |- Retries + Backoff + Idempotency

Dataverse Event(Create/Update)
    |
Event Handler/Integration Layer
    |
    |- Enrich/Validate
    |- Publish downstream events
    |- Update external systems

using Microsoft.Identity.Client;
using System;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Text.Json;
using System.Threading.Tasks;

namespace ConnectDataverseApi
{
    static async Task Main()
    {
        string resourceUrl = "https://yourorg.api.crm.dynamics.com";
        var clientId = "51f81489-12ee-4a9e-aaae-a2591f45987d";
        var redirectUri = "http://localhost";

        var authBuilder = PublicClientApplicationBuilder.Create(clientId)
            .WithAuthority(AadAuthorityAudience.AzureAdMultipleOrgs)
            .WithRedirectUri(redirectUri).Build();

        var scope = resourceUrl + "/user_impersonation";
        string[] scopes = {scope};

        AuthenticationResult token = await authBuilder.AcquireTokenInteractive(scopes).ExecuteAsync();

        var client = new HttpClient()
        {
            BaseAddress = new Uri(resourceUrl+"/api/data/v9.2/"),
            Timeout = TimeSpan(0,2,0)
        };

        HttpRequestHeaders headers = client.DefaultRequestHeaders;
        headers.Authorization = new AuthenticationHeaderValue("Bearer", token.AccessToken);
        headers.Add("OData-MaxVersion", "4.0");
        headers.Add("OData-Version", "4.0");
        headers.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));

        var response = await client.GetAsync("WhoAmI()");
        if (response.IsSuccessStatusCode)
        {
            Guid userId = new Guid();
            string jsonContent = await response.Content.ReadAsStringAsync();
            WhoAmIResponse whoAmIResponse = JsonSerializer.Deserialize<WhoAmIResponse>(jsonContent);
            userId = whoAmIResponse.UserId;
            System.Console.WriteLine( $"UserId: {userId}") ;

        }
        else
        {
            System.Console.WriteLine($"Error: {response.StatusCode} - {response.ReasonPhrase}");
        }
    }

    public class WhoAmIResponse
    {
        public Guid UserId { get; set; }
        public Guid BusinessUnitId { get; set; }
        public Guid OrganizationId { get; set; }
    }
}

const config = {
   baseUrl: process.env.BASE_URL,
   clientId: process.env.CLIENT_ID,
   tenantId: process.env.TENANT_ID,
   redirectUri: process.env.REDIRECT_URI,
};

const msalConfig = {
    auth: {
        clientId: config.clientId,
        authority: `https://login.microsoftonline.com/${config.tenantId}`,
        redirectUri: config.redirectUri,
    },
    cache:{
        cacheLocation: "sessionStorage",
        storeAuthStateInCookie: false,
    }
}

const msalInstance = new msal.PublicClientApplication(msalConfig);

async function getToken() {
    const request = {
        scopes: [config.baseUrl+"/.default"],
    };
    try{
        const response = await msalInstance.acquireTokenSilent(request);
        return response.accessToken;
    }
    catch(error){
        if(error instanceof msal.InteractionRequiredAuthError){
            const response = await msalInstance.acquireTokenPopup(request);
            return response.accessToken;
        }
        else{
            console.error("Token acquisition failed:", error);
            throw error;
        }
    }
}

async function whoAmI() {
    const token = await getToken();
    const request = new Request(`${config.baseUrl}/api/data/v9.2/WhoAmI`, {
        headers: {
            Authorization: `Bearer ${token}`,
            "Content-Type": "application/json",
            Accept: "application/json",
            "OData-MaxVersion": "4.0",
            "OData-Version": "4.0",
        }
    });
    const response = await fetch(request);
    if(!response.ok){
        throw new Error(`API call failed with status ${response.status}`);
    }
    return response.json();
}

attempt = 0
delay = baseDelayMs

while attempt < maxAttempts:
    response = callDataverse()

if success:
    return

if response is 429 or transient 5xx:
    wait(delay + jitter)
    delay = min(delay*2, maxDelay)
    attempt++
    continue
else:
    fail fast(non-retryable)

Batch Request
    |- Create Account
    |- Create Contact
    |- Update Opportunity
    |- Upsert Custom Table