admin/ayanova7
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
John Cardinal
2021-08-30 22:30:44 +00:00
parent b9f7045093
commit 2718bebe38
2 changed files with 39 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
source/Plugins/AyaNova.Plugin.V8/V8.cs
View File

@@ -5731,10 +5731,17 @@ namespace AyaNova.PlugIn.V8
//Upload
try
{
#if(DEBUG)
progress.Append("Sending file " + fi.Name);
#endif
await util.PostFormDataAsync("attachment", formDataContent);
}
catch (Exception ex)
{
#if(DEBUG)
progress.Append("ERROR Sending file " + fi.Name);
#endif
if (ex.Message.Contains("413"))
{
if (SmallestFileUploadRejectedAsTooBig > fi.Length)
@@ -5750,7 +5757,9 @@ namespace AyaNova.PlugIn.V8
}
}
//No need to map it or save response as long as it works that's all that matters
#if(DEBUG)
progress.Append("File attached successfully " + fi.Name);
#endif
}

51
source/Plugins/AyaNova.Plugin.V8/util.cs
View File

@@ -23,7 +23,7 @@ namespace AyaNova.PlugIn.V8
public const string API_BASE_ROUTE = "api/v8/";
private const int MAX_TRIES = 3;//max times to retry an api call before giving up
private const int API_RETRY_DELAY = 3000;//pause in ms before retrying api call
private const int HTTPCLIENT_TIMEOUT_SECONDS = 300;//default for all ops, normally 100seconds but would kill large file uploads
private const int HTTPCLIENT_TIMEOUT_SECONDS = 1200;//default for all ops, normally 100seconds but would kill large file uploads
public static HttpClient client = null;
//url once known to be good
internal static string ApiBaseUrl { get; set; }
@@ -355,33 +355,38 @@ namespace AyaNova.PlugIn.V8
//public async static Task<ApiResponse> PostFormDataAsync(string route, MultipartFormDataContent formContent)
//{
// Exception FirstException = null;
// for (int x = 0; x < MAX_TRIES; x++)
// {
// try
// {
// return await TryPostFormDataAsync(route, formContent);
// }
// catch (Exception ex)
// {
// if (ex.Message.Contains("413")) throw;//too large, no point in retrying at all let upstream caller handle it immediately
// if (FirstException == null)
// FirstException = ex;
// }
// await Task.Delay(API_RETRY_DELAY);
// }
// //no luck re-throw the exception
// throw new Exception("API call failed after " + MAX_TRIES.ToString() + " attempts", FirstException);
//}
//NO RETRY TEST VERSION OF ABOVE
//UNCOMMENT ABOVE AND COMMENT THIS TO GO BACK
public async static Task<ApiResponse> PostFormDataAsync(string route, MultipartFormDataContent formContent)
{
Exception FirstException = null;
for (int x = 0; x < MAX_TRIES; x++)
{
try
{
return await TryPostFormDataAsync(route, formContent);
}
catch (Exception ex)
{
if (ex.Message.Contains("413")) throw;//too large, no point in retrying at all let upstream caller handle it immediately
if (FirstException == null)
FirstException = ex;
}
await Task.Delay(API_RETRY_DELAY);
}
//no luck re-throw the exception
throw new Exception("API call failed after " + MAX_TRIES.ToString() + " attempts", FirstException);
return await TryPostFormDataAsync(route, formContent);
}
private async static Task<ApiResponse> TryPostFormDataAsync(string route, MultipartFormDataContent formContent)
{
var requestMessage = new HttpRequestMessage(HttpMethod.Post, ApiBaseUrl + route);