Add logging to sessionize service update

Author: dynamictulip

PocketDDD.Server/PocketDDD.Server.Services/SessionizeService.cs

@@ -1,33 +1,45 @@
-using Microsoft.EntityFrameworkCore;
+using System.Net.Http.Json;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Logging;
 using PocketDDD.Server.DB;
 using PocketDDD.Server.Model.DBModel;
 using PocketDDD.Server.Model.Sessionize;
-using System.Net.Http.Json;
+using Session = PocketDDD.Server.Model.DBModel.Session;
 
 namespace PocketDDD.Server.Services;
 
 public class SessionizeService
 {
-    private readonly HttpClient httpClient;
     private readonly PocketDDDContext dbContext;
+    private readonly HttpClient httpClient;
 
-    public SessionizeService(HttpClient httpClient, PocketDDDContext dbContext)
+    public SessionizeService(HttpClient httpClient, PocketDDDContext dbContext, ILogger<SessionizeService> logger)
     {
+        Logger = logger;
         this.httpClient = httpClient;
         this.dbContext = dbContext;
         httpClient.BaseAddress = new Uri("https://sessionize.com/api/v2/");
     }
 
+    private ILogger<SessionizeService> Logger { get; }
+
     public async Task UpdateFromSessionize()
     {
-        var dbEvent = await dbContext.EventDetail.SingleAsync(x => x.Id == 1);
+        Logger.LogInformation("Looking for event detail in database");
 
+        var dbEvent = await dbContext.EventDetail.SingleAsync(x => x.Id == 1);
         var sessionizeEventId = dbEvent.SessionizeId;
+
+        Logger.LogInformation("About to get data from Sessionize API");
+
         var sessionizeEvent = await httpClient.GetFromJsonAsync<SessionizeEvent>($"{sessionizeEventId}/view/All");
 
         if (sessionizeEvent is null)
             throw new ArgumentNullException(nameof(sessionizeEvent));
 
+        Logger.LogInformation("Information retrieved from Sessionize API");
+        Logger.LogInformation("Looking for changes to rooms");
+
         var dbTracks = await dbContext.Tracks.ToListAsync();
         foreach (var item in sessionizeEvent.rooms)
         {
@@ -46,8 +58,17 @@ public async Task UpdateFromSessionize()
             dbTrack.Name = $"Track {item.sort}";
         }
 
-        await dbContext.SaveChangesAsync();
-
+        if (dbContext.ChangeTracker.HasChanges())
+        {
+            Logger.LogInformation("Updating db with changes to rooms");
+            await dbContext.SaveChangesAsync();
+        }
+        else
+        {
+            Logger.LogInformation("No changes to rooms were detected");
+        }
+        
+        Logger.LogInformation("Looking for changes to time slots and breaks");
 
         var dbTimeSlots = await dbContext.TimeSlots.ToListAsync();
         var sessionizeTimeSlots = sessionizeEvent.sessions
@@ -71,10 +92,18 @@ public async Task UpdateFromSessionize()
                 dbContext.TimeSlots.Add(dbTimeSlot);
             }
         }
+        if (dbContext.ChangeTracker.HasChanges())
+        {
+            Logger.LogInformation("Updating db with changes to time slots and breaks");
+            await dbContext.SaveChangesAsync();
+        }
+        else
+        {
+            Logger.LogInformation("No changes to time slots or breaks were detected");
+        }
 
-        await dbContext.SaveChangesAsync();
-
-
+        Logger.LogInformation("Looking for changes to sessions");
+        
         var dbSessions = await dbContext.Sessions.ToListAsync();
         var speakers = sessionizeEvent.speakers;
         dbTracks = await dbContext.Tracks.ToListAsync();
@@ -89,7 +118,7 @@ public async Task UpdateFromSessionize()
             var dbSession = dbSessions.SingleOrDefault(x => x.SessionizeId == sessionizeId);
             if (dbSession == null)
             {
-                dbSession = new Model.DBModel.Session
+                dbSession = new Session
                 {
                     SessionizeId = sessionizeId,
                     EventDetail = dbEvent,
@@ -105,8 +134,15 @@ public async Task UpdateFromSessionize()
             dbSession.Track = dbTracks.Single(x => x.SessionizeId == item.roomId);
             dbSession.TimeSlot = GetTimeSlot(dbTimeSlots, item.startsAt, item.endsAt);
         }
-
-        await dbContext.SaveChangesAsync();
+        if (dbContext.ChangeTracker.HasChanges())
+        {
+            Logger.LogInformation("Updating db with changes to sessions");
+            await dbContext.SaveChangesAsync();
+        }
+        else
+        {
+            Logger.LogInformation("No changes to sessions were detected");
+        }
     }
 
     private string GetSpeakers(List<Speaker> speakers, List<string> speakerIds)