admin/bodyshop-uploader
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Decoder changes for adjustrite.

Browse Source
This commit is contained in:
Patrick Fic
2022-08-30 15:06:44 -07:00
parent ab3e947e8e
commit 9c3585d107
6 changed files with 322 additions and 246 deletions
Download Patch File Download Diff File Expand all files Collapse all files

71
BodyshopUploader/Utils/GraphQL.cs
View File

@@ -45,48 +45,59 @@ namespace BodyshopPartner.Utils
try
{
// httpClient.PostAsync("https://api.imex.online/ioevent", content);
// httpClient.PostAsync("https://api.imex.online/ioevent", content);
}
catch (Exception ex)
{
logger.Error(ex,"Unable to post to IOEVENT.");
logger.Error(ex, "Unable to post to IOEVENT.");
}
var graphQLResponse = await g.SendQueryAsync<dynamic>(r);
if (graphQLResponse.Errors == null)
try
{
//logger.Trace("GQL Response: {0}", graphQLResponse.Data);
return graphQLResponse.Data;
}
else
{
string exceptionString = "";
bool jwtExpired = false;
logger.Error("Error executing query.");
Array.ForEach(graphQLResponse.Errors, x =>
{
logger.Error("Graphql Error: " + x.Message);
if (x.Message.Contains("JWTExpired"))
{
jwtExpired = true;
};
exceptionString = exceptionString + x + ";";
});
if (jwtExpired && !lastTry)
var graphQLResponse = await g.SendQueryAsync<dynamic>(r);
logger.Debug("Graphql response:");
logger.Debug("Data: " + graphQLResponse.Data);
logger.Debug("Error: " + graphQLResponse.Errors);
if (graphQLResponse.Errors == null)
{
await Utils.Auth.Refresh();
return (ExecuteQuery(r, true));
//logger.Trace("GQL Response: {0}", graphQLResponse.Data);
return graphQLResponse.Data;
}
else
{
logger.Error("---------------------");
throw new Exception(exceptionString);
}
string exceptionString = "";
bool jwtExpired = false;
logger.Error("Error executing query.");
Array.ForEach(graphQLResponse.Errors, x =>
{
logger.Error("Graphql Error: " + x.Message);
if (x.Message.Contains("JWTExpired"))
{
jwtExpired = true;
};
exceptionString = exceptionString + x + ";";
});
if (jwtExpired && !lastTry)
{
await Utils.Auth.Refresh();
return (ExecuteQuery(r, true));
}
else
{
logger.Error("---------------------");
throw new Exception(exceptionString);
}
}
}
catch (Exception ex)
{
logger.Error("Error firing GQL query.");
logger.Error(ex);
throw ex;
}
}
}
}