-
Notifications
You must be signed in to change notification settings - Fork 0
/
GetAadUser.cs
72 lines (61 loc) · 2.47 KB
/
GetAadUser.cs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
using System;
using System.IO;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;
using Microsoft.Identity.Client;
using System.Net.Http;
using Newtonsoft.Json.Linq;
using Azure.Core;
using Azure.Identity;
namespace MyAadFunction
{
public static class GetAadUser
{
[FunctionName("GetAadUser")]
public static async Task<IActionResult> Run(
[HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = null)] HttpRequest req,
ILogger log)
{
log.LogInformation("C# HTTP trigger function processed a request.");
//string name = req.Query["name"];
string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
dynamic data = JsonConvert.DeserializeObject(requestBody);
//name = name ?? data?.name;
//string responseMessage = string.IsNullOrEmpty(name)
// ? "This HTTP triggered function executed successfully. Pass a name in the query string or in the request body for a personalized response."
// : $"Hello, {name}. This HTTP triggered function executed successfully.";
Config config = Config.ReadFromJsonFile("appsettings.json");
var app = new DefaultAzureCredential();
string[] scopes = new string[] { $"{config.ApiUrl}.default" };
AccessToken accessToken;
try
{
var tokenContext = new TokenRequestContext(scopes);
var cancellationToken = new CancellationToken(default);
accessToken = await app.GetTokenAsync(tokenContext, cancellationToken);
}
catch (MsalServiceException ex) when (ex.Message.Contains("AADSTS70011"))
{
throw;
}
JObject outcome = null;
if (accessToken.Token != null)
{
var httpClient = new HttpClient();
var apiCaller = new ProtectedApiCallHelper(httpClient);
outcome = await apiCaller.CallWebApiAndProcessResultASync($"{config.ApiUrl}v1.0/users", accessToken.Token);
}
else
{
return new UnauthorizedResult();
}
return new OkObjectResult(outcome);
}
}
}