alex/canvasManagement
1
0
Fork 0
mirror of https://github.com/alexmickelson/canvasManagement.git synced 2026-03-26 07:38:33 -06:00
Code Issues Packages Projects Releases Wiki Activity

got canvas service tests passing

Browse Source
This commit is contained in:
Alex Mickelson
2023-01-04 21:39:45 -07:00
parent dcc8fef898
commit c350a8487e
9 changed files with 119 additions and 43 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
Management/Models/CanvasModel/EnrollmentTerms/EnrollmentTermModel.cs
View File

@@ -1,6 +1,6 @@
namespace CanvasModel.EnrollmentTerms;
record EnrollmentTermModel
public record EnrollmentTermModel
(
[property: JsonPropertyName("id")] ulong Id,
[property: JsonPropertyName("name")] string Name,
@@ -14,7 +14,7 @@ record EnrollmentTermModel
Dictionary<string, EnrollmentTermDateOverrideModel>? Overrides = null
);
record EnrollmentTermDateOverrideModel
public record EnrollmentTermDateOverrideModel
(
[property: JsonPropertyName("start_at")] DateTime? StartAt = null,
[property: JsonPropertyName("end_at")] DateTime? EndAt = null

4
Management/Models/CanvasModel/EnrollmentTerms/RedundantEnrollmentTermsResponse.cs
View File

@@ -1,6 +1,6 @@
namespace CanvasModel.EnrollmentTerms;
record RedundantEnrollmentTermsResponse
public record RedundantEnrollmentTermsResponse
(
[property: JsonPropertyName("enrollment_terms")]
IEnumerable<EnrollmentTermModel> EnrollmentTerms

23
Management/Services/CanvasService.cs
View File

@@ -18,7 +18,10 @@ public class CanvasService
var url = $"accounts/10/terms";
var request = new RestRequest(url);
var terms = await PaginatedRequest<EnrollmentTermModel>(request);
var termResponses = await PaginatedRequest<RedundantEnrollmentTermsResponse>(request);
var terms = termResponses
.Select(r => r.EnrollmentTerms)
.SelectMany(s => s).ToArray();
return terms;
}
@@ -26,20 +29,20 @@ public class CanvasService
{
var requestCount = 1;
request.AddQueryParameter("per_page", "100");
IEnumerable<T> returnData = new T[] { };
RestResponse<T[]> response = await webRequestor.GetAsync<T>(request);
returnData = returnData.Concat(response.Data);
var nextUrl = getNextUrl(response);
RestResponse<T> response = await webRequestor.GetAsync<T>(request);
var returnData = response.Data != null
? new T[] { response.Data }
: new T[] { };
var nextUrl = getNextUrl(response.Headers);
while (nextUrl is not null)
{
requestCount += 1;
var nextRequest = new RestRequest(nextUrl);
RestRequest nextRequest = new RestRequest(nextUrl);
var nextResponse = await webRequestor.GetAsync<T>(nextRequest);
if (nextResponse.Data is not null)
returnData = returnData.Concat(nextResponse.Data);
nextUrl = getNextUrl(nextResponse);
returnData = returnData.Append(nextResponse.Data).ToArray();
nextUrl = getNextUrl(nextResponse.Headers);
}
System.Console.WriteLine($"Requesting {typeof(T)} took {requestCount} requests");
@@ -48,7 +51,7 @@ public class CanvasService
}
private static string? getNextUrl<T>(RestResponse<T[]> response) => response.Headers?
private static string? getNextUrl(IEnumerable<HeaderParameter>? headers) => headers?
.ToList()
.Find(h => h.Name == "Link")?
.Value?