Merge pull request #76 from nullinside-development-group/feat/dup

Feat/dup

Author: ProgrammingByPermutation

src/Nullinside.Api.TwitchBot/ChatRules/TwitchChatMessageMonitorConsumer.cs

@@ -111,14 +111,13 @@ private async void MainLoop() {
         // Try to get a message from one of the two queues.
         ChatMessage? message;
         _queue.TryTake(out message);
-        
+
         // If we didn't get a message, loop.
         if (null == message) {
           Thread.Sleep(LOOP_TIMEOUT);
           continue;
         }
 
-        LOG.Info("Message received: " + message.Id);
         string? channel = message.Channel;
         try {
           // Sanity check.

src/Nullinside.Api.TwitchBot/Model/NullinsideContextExtensions.cs

@@ -168,19 +168,15 @@ await db.TwitchUser.UpsertRange(
       .On(v => new { v.TwitchId })
       .RunAsync(stoppingToken);
 
-    db.TwitchBan.AddRange(
-      bannedUsers.Select(i => new TwitchBan {
-        ChannelId = channelId,
-        BannedUserTwitchId = i.Id,
-        Reason = reason,
-        Timestamp = DateTime.UtcNow
-      }).ToList());
-
-    // Trying to fix bug?
-    foreach (TwitchBan twitchBan in db.TwitchBan) {
-      db.Entry(twitchBan).State = EntityState.Added;
-    }
-
-    await db.SaveChangesAsync(stoppingToken);
+    await db.TwitchBan.UpsertRange(
+        bannedUsers.Select(i => new TwitchBan {
+          ChannelId = channelId,
+          BannedUserTwitchId = i.Id,
+          Reason = reason,
+          Timestamp = DateTime.UtcNow
+        }).ToList()
+      )
+      .On(v => new { v.ChannelId, v.BannedUserTwitchId, v.Timestamp })
+      .RunAsync(stoppingToken);
   }
 }