@asingh1-tibco ,
Thank you for reaching out on the Microsoft Fabric Community Forum.
Define Your Custom Auth UI
[DataSource.UI.Prompts]
Custom.PBI.Connector = [
CredentialPrompt = [
AuthenticationKind = "OAuth",
Label = "Enter your OAuth Details",
Fields = [
client_id = [Label = "Client ID", Type = "Text"],
client_secret = [Label = "Client Secret", Type = "Text", IsPassword = true],
tenant_id = [Label = "Tenant ID", Type = "Text"],
redirect_uri = [Label = "Redirect URI", Type = "Text"],
scope = [Label = "Scope", Type = "Text"]
]
]
];
Define OAuth Authentication Kind
In your DataSource.Kind metadata
[DataSource.Kind = "Custom.PBI.Connector"]
shared Custom.PBI.Connector = ... // your data source
Custom.PBI.Connector = [
Authentication = [
OAuth = [
StartLogin = StartLogin,
FinishLogin = FinishLogin,
Label = Extension.LoadString("OAuthLabel")
]
]
];
3. Update StartLogin
StartLogin = (resourceUrl, state, display) =>
let
creds = Extension.CurrentCredential(),
client_id = creds[client_id],
tenant_id = creds[tenant_id],
redirect_uri = creds[redirect_uri],
scope = creds[scope],
authUrl = "https://login.provider.com/" & tenant_id & "/oauth2/authorize?",
queryString = Uri.BuildQueryString([
client_id = client_id,
redirect_uri = redirect_uri,
response_type = "code",
scope = scope,
state = state
])
in
[
LoginUri = authUrl & queryString,
CallbackUri = redirect_uri,
WindowHeight = 720,
WindowWidth = 1024,
Context = null
];
Update FinishLogin and ExchangeAuthorizationCode
FinishLogin = (context, callbackUri, state) =>
let
creds = Extension.CurrentCredential(),
parts = Uri.Parts(callbackUri)[Query],
result =
if Record.HasFields(parts, {"error", "error_description"}) then
error Error.Record(parts[error], parts[error_description], parts)
else
ExchangeAuthorizationCode(parts[code], creds)
in
result;
ExchangeAuthorizationCode = (authCode as text, creds as record) as record =>
let
tokenUrl = "https://login.provider.com/" & creds[tenant_id] & "/oauth2/token",
queryParams = [
grant_type = "authorization_code",
code = authCode,
redirect_uri = creds[redirect_uri],
client_id = creds[client_id],
client_secret = creds[client_secret]
],
tokenResponse = Web.Contents(tokenUrl, [
Content = Text.ToBinary(Uri.BuildQueryString(queryParams)),
Headers = [
"Content-Type" = "application/x-www-form-urlencoded",
"Accept" = "application/json"
]
]),
body = Json.Document(tokenResponse),
result =
if Record.HasFields(body, {"error", "error_description"}) then
error Error.Record(body[error], body[error_description], body)
else
body
in
result;
If this response is helpful, please consider marking it as the accepted solution and giving it a thumbs-up to help others in the community.
Thank you!
