⚡ Optimize the post notification

DysonNetwork.Pass/Program.cs

@@ -45,13 +45,6 @@ using (var scope = app.Services.CreateScope())
 {
     var db = scope.ServiceProvider.GetRequiredService<AppDatabase>();
     await db.Database.MigrateAsync();
-
-    // _ = Task.Run(async () =>
-    // {
-    //     var migrationScope = app.Services.CreateScope();
-    //     var migrationAuthService = migrationScope.ServiceProvider.GetRequiredService<AuthService>();
-    //     await migrationAuthService.MigrateDeviceIdToClient();
-    // });
 }
 
 // Configure application middleware pipeline

DysonNetwork.Sphere/Publisher/PublisherSubscriptionService.cs

@@ -78,30 +78,25 @@ public class PublisherSubscriptionService(
         queryRequest.Id.AddRange(subscribers.DistinctBy(s => s.AccountId).Select(m => m.AccountId.ToString()));
         var queryResponse = await accounts.GetAccountBatchAsync(queryRequest);
 
-        var notification = new PushNotification
-        {
-            Topic = "posts.new",
-            Title = localizer["PostSubscriptionTitle", post.Publisher.Name, title],
-            Body = message,
-            Meta = GrpcTypeHelper.ConvertObjectToByteString(data),
-            IsSavable = true,
-            ActionUri = $"/posts/{post.Id}"
-        };
-
         // Notify each subscriber
         var notifiedCount = 0;
-        foreach (var target in queryResponse.Accounts)
+        foreach (var target in queryResponse.Accounts.GroupBy(x => x.Language))
         {
             try
             {
-                CultureService.SetCultureInfo(target);
+                CultureService.SetCultureInfo(target.Key);
-                await pusher.SendPushNotificationToUserAsync(
+                var notification = new PushNotification
-                    new SendPushNotificationToUserRequest
+                {
-                    {
+                    Topic = "posts.new",
-                        UserId = target.Id,
+                    Title = localizer["PostSubscriptionTitle", post.Publisher.Name, title],
-                        Notification = notification
+                    Body = message,
-                    }
+                    Meta = GrpcTypeHelper.ConvertObjectToByteString(data),
-                );
+                    IsSavable = true,
+                    ActionUri = $"/posts/{post.Id}"
+                };
+                var request = new SendPushNotificationToUsersRequest { Notification = notification };
+                request.UserIds.AddRange(target.Select(x => x.Id.ToString()));
+                await pusher.SendPushNotificationToUsersAsync(request);
                 notifiedCount++;
             }
             catch (Exception)