Merge pull request #137 from mineral-dart/fix/members

fix: cache who loose members

Author: PandaGuerrier

lib/src/constants.dart

@@ -49,6 +49,7 @@ enum PacketType {
   guildScheduledEventUpdate('GUILD_SCHEDULED_EVENT_UPDATE'),
   guildScheduledEventUserAdd('GUILD_SCHEDULED_EVENT_USER_ADD'),
   guildScheduledEventUserRemove('GUILD_SCHEDULED_EVENT_USER_REMOVE'),
+  guildMemberChunk('GUILD_MEMBERS_CHUNK'),
 
   webhookUpdate('WEBHOOKS_UPDATE'),
 

lib/src/internal/mixins/mineral_client.dart

@@ -5,6 +5,7 @@ import 'package:mineral/core.dart';
 import 'package:mineral/core/api.dart';
 import 'package:mineral/core/builders.dart';
 import 'package:mineral/framework.dart';
+import 'package:mineral/internal.dart';
 import 'package:mineral/src/api/channels/partial_channel.dart';
 import 'package:mineral/src/api/managers/channel_manager.dart';
 import 'package:mineral/src/api/managers/emoji_manager.dart';
@@ -128,6 +129,14 @@ extension MineralClientExtension on MineralClient {
       users.cache.putIfAbsent(user.id, () => user);
     }
 
+    if(websocketPayload['members'].length > 1000) {
+      container.use<ShardManager>().send(OpCode.requestGuildMember, {
+        'guild_id': websocketPayload['id'],
+        'query': '',
+        'limit': 0,
+      });
+    }
+
     for(dynamic payload in websocketPayload['channels']) {
       payload['guild_id'] = websocketPayload['id'];
       final GuildChannel? channel = ChannelWrapper.create(payload);

lib/src/internal/websockets/packets/guild_member_chunk_packet.dart

@@ -0,0 +1,37 @@
+import 'package:mineral/core/api.dart';
+import 'package:mineral/framework.dart';
+import 'package:mineral/src/internal/mixins/container.dart';
+import 'package:mineral/src/internal/websockets/websocket_packet.dart';
+import 'package:mineral/src/internal/websockets/websocket_response.dart';
+
+class GuildMemberChunkPacker with Container implements WebsocketPacket {
+  @override
+  Future<void> handle(WebsocketResponse websocketResponse) async {
+    MineralClient client = container.use<MineralClient>();
+    dynamic payload = websocketResponse.payload;
+
+    if (payload['guild_id'] == null) {
+      return;
+    }
+
+    Guild? guild = client.guilds.cache.getOrFail(payload['guild_id']);
+
+    for (dynamic member in payload['members']) {
+      if(guild.members.cache.containsKey(member['user']['id'])) {
+        continue;
+      }
+
+      User user = User.from(member['user']);
+      GuildMember guildMember = GuildMember.from(
+          roles: guild.roles,
+          user: user,
+          member: member,
+          guild: guild,
+          voice: VoiceManager.empty(member['deaf'], member['mute'], user.id, payload['guild_id'])
+      );
+
+      guild.members.cache.putIfAbsent(guildMember.user.id, () => guildMember);
+      client.users.cache.putIfAbsent(user.id, () => user);
+    }
+  }
+}

lib/src/internal/websockets/websocket_dispatcher.dart

@@ -7,6 +7,7 @@ import 'package:mineral/src/internal/websockets/packets/channel_delete_packet.da
 import 'package:mineral/src/internal/websockets/packets/channel_update_packet.dart';
 import 'package:mineral/src/internal/websockets/packets/guild_create_packet.dart';
 import 'package:mineral/src/internal/websockets/packets/guild_integrations_update.dart';
+import 'package:mineral/src/internal/websockets/packets/guild_member_chunk_packet.dart';
 import 'package:mineral/src/internal/websockets/packets/guild_remove_packet.dart';
 import 'package:mineral/src/internal/websockets/packets/guild_scheduled_event_create.dart';
 import 'package:mineral/src/internal/websockets/packets/guild_scheduled_event_delete.dart';
@@ -70,6 +71,7 @@ class WebsocketDispatcher {
     register(PacketType.voiceStateUpdate, VoiceStateUpdatePacket());
     register(PacketType.inviteCreate, InviteCreatePacket());
     register(PacketType.inviteDelete, InviteDeletePacket());
+    register(PacketType.guildMemberChunk, GuildMemberChunkPacker());
   }
 
   void register (PacketType type, WebsocketPacket packet) {