canvasManagement/Management/Services/Canvas/CanvasService.cs

using System.Security.Policy;

using CanvasModel;
using CanvasModel.Assignments;
using CanvasModel.Courses;
using CanvasModel.Enrollments;
using CanvasModel.EnrollmentTerms;
using CanvasModel.Modules;
using CanvasModel.Pages;
using RestSharp;

namespace Management.Services.Canvas;

public interface ICanvasService
{
  ICanvasAssignmentService Assignments { get; }
  ICanvasAssignmentGroupService AssignmentGroups { get; }
  ICanvasModuleService Modules { get; }
  ICanvasQuizService Quizzes { get; }
  ICanvasCoursePageService Pages { get; }
  Task<IEnumerable<EnrollmentTermModel>> GetTerms();
  Task<IEnumerable<CourseModel>> GetCourses(ulong termId);
  Task<CourseModel> GetCourse(ulong courseId);
  Task<IEnumerable<EnrollmentTermModel>> GetCurrentTermsFor(DateTime? queryDate = null);
  Task UpdateModuleItem(ulong canvasCourseId, ulong canvasModuleId, CanvasModuleItem item);
  Task CreateModuleItem(ulong canvasCourseId, ulong canvasModuleId, string title, string type, ulong contentId);
  Task CreateModuleItem(ulong canvasCourseId, ulong canvasModuleId, string title, string type, string contentId);
  Task CreatePageModuleItem(ulong canvasCourseId, ulong canvasModuleId, string title, CanvasPage canvasPage);
  Task<IEnumerable<EnrollmentModel>> GetEnrolledStudents(ulong canvasCourseId);
}

public class CanvasService(
  IWebRequestor webRequestor,
  CanvasServiceUtils utils,
  ICanvasAssignmentService Assignments,
  ICanvasAssignmentGroupService AssignmentGroups,
  ICanvasModuleService Modules,
  ICanvasQuizService Quizzes,
  ICanvasCoursePageService Pages,
  MyLogger<ICanvasService> logger
) : ICanvasService
{
  private readonly IWebRequestor webRequestor = webRequestor;
  private readonly CanvasServiceUtils utils = utils;
  private readonly MyLogger<ICanvasService> logger = logger;

  public ICanvasAssignmentService Assignments { get; } = Assignments;
  public ICanvasAssignmentGroupService AssignmentGroups { get; } = AssignmentGroups;
  public ICanvasModuleService Modules { get; } = Modules;
  public ICanvasQuizService Quizzes { get; } = Quizzes;
  public ICanvasCoursePageService Pages { get; } = Pages;

  public async Task<IEnumerable<EnrollmentTermModel>> GetTerms()
  {
    var url = $"accounts/10/terms";

    var request = new RestRequest(url);
    var termResponses = await utils.PaginatedRequest<RedundantEnrollmentTermsResponse>(request);
    var terms = termResponses.Select(r => r.EnrollmentTerms).SelectMany(s => s).ToArray();
    return terms;
  }

  public async Task<IEnumerable<CourseModel>> GetCourses(ulong termId)
  {
    var url = $"courses";
    var request = new RestRequest(url);
    var coursesResponse = await utils.PaginatedRequest<IEnumerable<CourseModel>>(request);
    return coursesResponse.SelectMany(c => c).Where(c => c.EnrollmentTermId == termId).ToArray();
  }

  public async Task<CourseModel> GetCourse(ulong courseId)
  {
    var url = $"courses/{courseId}";
    var request = new RestRequest(url);
    var (data, response) = await webRequestor.GetAsync<CourseModel>(request);

    if (data == null)
    {
      logger.Error(response?.Content ?? "");
      logger.Error(response?.ResponseUri?.ToString() ?? "");
      throw new Exception("error getting course from canvas");
    }
    return data;
  }



  public async Task<IEnumerable<EnrollmentTermModel>> GetCurrentTermsFor(
    DateTime? _queryDate = null
  )
  {
    DateTime queryDate = _queryDate ?? DateTime.Now;

    var terms = await GetTerms();

    var currentTerms = terms
      .Where(t => t.EndAt != null && t.EndAt > queryDate && t.EndAt < queryDate.AddYears(1))
      .Take(3)
      .OrderBy(t => t.StartAt);

    return currentTerms;
  }

  public async Task UpdateModuleItem(
    ulong canvasCourseId,
    ulong canvasModuleId,
    CanvasModuleItem item
  )
  {
    logger.Log($"updating module item {item.Title}");
    var url = $"courses/{canvasCourseId}/modules/{canvasModuleId}/items/{item.Id}";
    var body = new { module_item = new { title = item.Title, position = item.Position } };
    var request = new RestRequest(url);
    request.AddBody(body);

    var (newItem, response) = await webRequestor.PutAsync<CanvasModuleItem>(request);
    if (newItem == null)
      throw new Exception("something went wrong updating module item");
  }

  public async Task CreateModuleItem(
    ulong canvasCourseId,
    ulong canvasModuleId,
    string title,
    string type,
    ulong contentId
  )
  {
    logger.Log($"creating new module item {title}");
    var url = $"courses/{canvasCourseId}/modules/{canvasModuleId}/items";
    var body = new
    {
      module_item = new
      {
        title,
        type = type.ToString(),
        content_id = contentId,
      }
    };
    var request = new RestRequest(url);
    request.AddBody(body);

    var (newItem, _response) = await webRequestor.PostAsync<CanvasModuleItem>(request);
    if (newItem == null)
      throw new Exception("something went wrong updating module item");
  }
  public async Task CreateModuleItem(
    ulong canvasCourseId,
    ulong canvasModuleId,
    string title,
    string type,
    string contentId
  )
  {
    logger.Log($"creating new module item {title}");
    var url = $"courses/{canvasCourseId}/modules/{canvasModuleId}/items";
    var body = new
    {
      module_item = new
      {
        title,
        type = type.ToString(),
        content_id = contentId,
      }
    };
    var request = new RestRequest(url);
    request.AddBody(body);

    var (newItem, _response) = await webRequestor.PostAsync<CanvasModuleItem>(request);
    if (newItem == null)
      throw new Exception("something went wrong updating module item with string content id");
  }
  public async Task CreatePageModuleItem(
    ulong canvasCourseId,
    ulong canvasModuleId,
    string title,
    CanvasPage canvasPage
  )
  {
    logger.Log($"creating new module item {title}");
    var url = $"courses/{canvasCourseId}/modules/{canvasModuleId}/items";
    var body = new
    {
      module_item = new
      {
        title,
        type = "Page",
        page_url = canvasPage.Url,
      }
    };
    var request = new RestRequest(url);
    request.AddBody(body);

    var (newItem, _response) = await webRequestor.PostAsync<CanvasModuleItem>(request);
    if (newItem == null)
      throw new Exception("something went wrong updating module item with string content id");
  }

  public async Task<IEnumerable<EnrollmentModel>> GetEnrolledStudents(
    ulong canvasCourseId
  )
  {
    logger.Log($"getting students for corse {canvasCourseId}");

    var url = $"courses/{canvasCourseId}/enrollments?enrollment_type=student";
    var request = new RestRequest(url);
    var (enrollments, _response) = await webRequestor.GetManyAsync<EnrollmentModel>(request);
    if (enrollments == null)
      throw new Exception($"something went wrong getting enrollments for {canvasCourseId}");

    return enrollments;
  }
}