Feature: Add events to differentiate creations vs updates

Valour/Server/Services/AutomodService.cs

@@ -96,7 +96,7 @@ public async Task<TaskResult<AutomodTrigger>> CreateTriggerAsync(AutomodTrigger
         // Invalidate cache
         _triggerCache.TryRemove(trigger.PlanetId, out _);
 
-        _coreHub.NotifyPlanetItemChange(trigger);
+        _coreHub.NotifyPlanetItemCreate(trigger);
         return new(true, "Success", trigger);
     }
 
@@ -131,9 +131,9 @@ public async Task<TaskResult<AutomodTrigger>> CreateTriggerWithActionsAsync(Auto
         _triggerCache.TryRemove(trigger.PlanetId, out _);
         _actionCache.TryRemove(trigger.Id, out _);
 
-        _coreHub.NotifyPlanetItemChange(trigger);
+        _coreHub.NotifyPlanetItemCreate(trigger);
         foreach (var action in actions)
-            _coreHub.NotifyPlanetItemChange(action.PlanetId, action);
+            _coreHub.NotifyPlanetItemCreate(action.PlanetId, action);
 
         return new(true, "Success", trigger);
     }
@@ -220,7 +220,7 @@ public async Task<TaskResult<AutomodAction>> CreateActionAsync(AutomodAction act
         // Invalidate cache
         _actionCache.TryRemove(action.TriggerId, out _);
 
-        _coreHub.NotifyPlanetItemChange(action.PlanetId, action);
+        _coreHub.NotifyPlanetItemCreate(action.PlanetId, action);
         return new(true, "Success", action);
     }
 

Valour/Server/Services/ChannelService.cs

@@ -382,10 +382,10 @@ public async Task<TaskResult<Channel>> CreateAsync(Channel channel, List<Permiss
             if (associatedChatChannel is not null)
             {
                 hostedPlanet.UpsertChannel(associatedChatChannel);
-                _coreHub.NotifyPlanetItemChange(channel.PlanetId!.Value, associatedChatChannel);
+                _coreHub.NotifyPlanetItemCreate(channel.PlanetId!.Value, associatedChatChannel);
             }
             await _planetPermissionService.HandleChannelTopologyChange(channel.PlanetId!.Value);
-            _coreHub.NotifyPlanetItemChange(channel.PlanetId!.Value, channel);
+            _coreHub.NotifyPlanetItemCreate(channel.PlanetId!.Value, channel);
         }
 
         return TaskResult<Channel>.FromData(channel);

Valour/Server/Services/CoreHubService.cs

@@ -213,9 +213,15 @@ public void NotifyVoiceSessionReplace(long userId, VoiceSessionReplaceEvent upda
     public void NotifyVoiceChannelParticipants(long planetId, VoiceChannelParticipantsUpdate update) =>
         _ = _hub.Clients.Group($"p-{planetId}").SendAsync("Voice-Channel-Participants", update);
 
+    public void NotifyPlanetItemCreate<T>(long planetId, T model, int flags = 0) =>
+        _ = _hub.Clients.Group($"p-{planetId}").SendAsync($"{typeof(T).Name}-Create", model, flags);
+
     public void NotifyPlanetItemChange<T>(long planetId, T model, int flags = 0) =>
         _ = _hub.Clients.Group($"p-{planetId}").SendAsync($"{typeof(T).Name}-Update", model, flags);
 
+    public async void NotifyPlanetItemCreate<T>(T model, int flags = 0) where T : ISharedPlanetModel => 
+        await _hub.Clients.Group($"p-{model.PlanetId}").SendAsync($"{typeof(T).Name}-Create", model, flags);
+
     public async void NotifyPlanetItemChange<T>(T model, int flags = 0) where T : ISharedPlanetModel => 
         await _hub.Clients.Group($"p-{model.PlanetId}").SendAsync($"{typeof(T).Name}-Update", model, flags);
 

Valour/Server/Services/PlanetBanService.cs

@@ -97,7 +97,7 @@ public async Task<TaskResult<PlanetBan>> CreateAsync(
         await tran.CommitAsync();
 
         // Notify of changes
-        _coreHub.NotifyPlanetItemChange(ban);
+        _coreHub.NotifyPlanetItemCreate(ban);
         _coreHub.NotifyPlanetItemDelete(target);
 
         var actorUserId = source == ModerationActionSource.Automod

Valour/Server/Services/PlanetEmojiService.cs

@@ -87,7 +87,7 @@ public async Task<TaskResult<PlanetEmoji>> CreateAsync(
         hosted.UpsertEmoji(model);
 
         if (notify)
-            _coreHub.NotifyPlanetItemChange(model);
+            _coreHub.NotifyPlanetItemCreate(model);
 
         return TaskResult<PlanetEmoji>.FromData(model);
     }
@@ -122,7 +122,7 @@ public async Task<TaskResult> DeleteAsync(long planetId, long emojiId, bool noti
 
     public void NotifyCreated(PlanetEmoji emoji)
     {
-        _coreHub.NotifyPlanetItemChange(emoji);
+        _coreHub.NotifyPlanetItemCreate(emoji);
     }
 
     public async Task<bool> AreAllIdsValidForPlanetAsync(long planetId, IEnumerable<long> ids)

Valour/Server/Services/PlanetInviteService.cs

@@ -53,7 +53,7 @@ public async Task<TaskResult<PlanetInvite>> CreateAsync(PlanetInvite invite, Pla
             return new(false, e.Message);
         }
 
-        _coreHub.NotifyPlanetItemChange(invite);
+        _coreHub.NotifyPlanetItemCreate(invite);
 
         return new(true, "Success", invite);
     }

Valour/Server/Services/PlanetMemberService.cs

@@ -378,7 +378,8 @@ public async Task<TaskResult<PlanetMember>> AddMemberAsync(long planetId, long u
 
         var model = member.ToModel();
 
-        _coreHub.NotifyPlanetItemChange(model);
+        // Notify subscribers that an item has been created (Member added)
+        _coreHub.NotifyPlanetItemCreate(model);
 
         await _automodService.HandleMemberJoinAsync(model);
 

Valour/Server/Services/PlanetRoleService.cs

@@ -108,7 +108,7 @@ public async Task<TaskResult<PlanetRole>> CreateAsync(PlanetRole role)
         }
 
         hostedPlanet.UpsertRole(role);
-        _coreHub.NotifyPlanetItemChange(role);
+        _coreHub.NotifyPlanetItemCreate(role);
 
         // If we bumped the default role, update cache and notify clients
         if (defaultRoleUpdated)