github/Discord.Net
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feature: Remove DM cache and fix references (#1851)

Browse Source 
* Remove DM cache and fix references

* Move line back to where it was
This commit is contained in:
Paulo
2021-05-26 17:35:49 -03:00
committed by GitHub
parent 95bae786b8
commit 7a201e9ff1
10 changed files with 68 additions and 73 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/Discord.Net.Core/Entities/Users/IUser.cs
View File

@@ -87,7 +87,7 @@ namespace Discord
UserProperties? PublicFlags { get; } UserProperties? PublicFlags { get; }
/// <summary> /// <summary>
/// Gets the direct message channel of this user, or create one if it does not already exist. /// Creates the direct message channel of this user.
/// </summary> /// </summary>
/// <remarks> /// <remarks>
/// This method is used to obtain or create a channel used to send a direct message. /// This method is used to obtain or create a channel used to send a direct message.
@@ -102,7 +102,7 @@ namespace Discord
/// <example> /// <example>
/// <para>The following example attempts to send a direct message to the target user and logs the incident should /// <para>The following example attempts to send a direct message to the target user and logs the incident should
/// it fail.</para> /// it fail.</para>
/// <code region="GetOrCreateDMChannelAsync" language="cs" /// <code region="CreateDMChannelAsync" language="cs"
/// source="../../../Discord.Net.Examples/Core/Entities/Users/IUser.Examples.cs"/> /// source="../../../Discord.Net.Examples/Core/Entities/Users/IUser.Examples.cs"/>
/// </example> /// </example>
/// <param name="options">The options to be used when sending the request.</param> /// <param name="options">The options to be used when sending the request.</param>
@@ -110,6 +110,6 @@ namespace Discord
/// A task that represents the asynchronous operation for getting or creating a DM channel. The task result /// A task that represents the asynchronous operation for getting or creating a DM channel. The task result
/// contains the DM channel associated with this user. /// contains the DM channel associated with this user.
/// </returns> /// </returns>
Task<IDMChannel> GetOrCreateDMChannelAsync(RequestOptions options = null); Task<IDMChannel> CreateDMChannelAsync(RequestOptions options = null);
} }
} }

6
src/Discord.Net.Core/Extensions/UserExtensions.cs
View File

@@ -42,7 +42,7 @@ namespace Discord
RequestOptions options = null, RequestOptions options = null,
AllowedMentions allowedMentions = null) AllowedMentions allowedMentions = null)
{ {
return await (await user.GetOrCreateDMChannelAsync().ConfigureAwait(false)).SendMessageAsync(text, isTTS, embed, options, allowedMentions).ConfigureAwait(false); return await (await user.CreateDMChannelAsync().ConfigureAwait(false)).SendMessageAsync(text, isTTS, embed, options, allowedMentions).ConfigureAwait(false);
} }
/// <summary> /// <summary>
@@ -94,7 +94,7 @@ namespace Discord
RequestOptions options = null RequestOptions options = null
) )
{ {
return await (await user.GetOrCreateDMChannelAsync().ConfigureAwait(false)).SendFileAsync(stream, filename, text, isTTS, embed, options).ConfigureAwait(false); return await (await user.CreateDMChannelAsync().ConfigureAwait(false)).SendFileAsync(stream, filename, text, isTTS, embed, options).ConfigureAwait(false);
} }
/// <summary> /// <summary>
@@ -149,7 +149,7 @@ namespace Discord
Embed embed = null, Embed embed = null,
RequestOptions options = null) RequestOptions options = null)
{ {
return await (await user.GetOrCreateDMChannelAsync().ConfigureAwait(false)).SendFileAsync(filePath, text, isTTS, embed, options).ConfigureAwait(false); return await (await user.CreateDMChannelAsync().ConfigureAwait(false)).SendFileAsync(filePath, text, isTTS, embed, options).ConfigureAwait(false);
} }
/// <summary> /// <summary>

4
src/Discord.Net.Examples/Core/Entities/Users/IUser.Examples.cs
View File

@@ -18,11 +18,11 @@ namespace Discord.Net.Examples.Core.Entities.Users
#endregion #endregion
#region GetOrCreateDMChannelAsync #region CreateDMChannelAsync
public async Task MessageUserAsync(IUser user) public async Task MessageUserAsync(IUser user)
{ {
var channel = await user.GetOrCreateDMChannelAsync(); var channel = await user.CreateDMChannelAsync();
try try
{ {
await channel.SendMessageAsync("Awesome stuff!"); await channel.SendMessageAsync("Awesome stuff!");

8
src/Discord.Net.Rest/Entities/Users/RestUser.cs
View File

@@ -79,13 +79,13 @@ namespace Discord.Rest
} }
/// <summary> /// <summary>
/// Returns a direct message channel to this user, or create one if it does not already exist. /// Creates a direct message channel to this user.
/// </summary> /// </summary>
/// <param name="options">The options to be used when sending the request.</param> /// <param name="options">The options to be used when sending the request.</param>
/// <returns> /// <returns>
/// A task that represents the asynchronous get operation. The task result contains a rest DM channel where the user is the recipient. /// A task that represents the asynchronous get operation. The task result contains a rest DM channel where the user is the recipient.
/// </returns> /// </returns>
public Task<RestDMChannel> GetOrCreateDMChannelAsync(RequestOptions options = null) public Task<RestDMChannel> CreateDMChannelAsync(RequestOptions options = null)
=> UserHelper.CreateDMChannelAsync(this, Discord, options); => UserHelper.CreateDMChannelAsync(this, Discord, options);
/// <inheritdoc /> /// <inheritdoc />
@@ -107,7 +107,7 @@ namespace Discord.Rest
//IUser //IUser
/// <inheritdoc /> /// <inheritdoc />
async Task<IDMChannel> IUser.GetOrCreateDMChannelAsync(RequestOptions options) async Task<IDMChannel> IUser.CreateDMChannelAsync(RequestOptions options)
=> await GetOrCreateDMChannelAsync(options).ConfigureAwait(false); => await CreateDMChannelAsync(options).ConfigureAwait(false);
} }
} }

60
src/Discord.Net.WebSocket/DiscordSocketClient.cs
View File

@@ -305,7 +305,7 @@ namespace Discord.WebSocket
/// <summary> /// <summary>
/// Clears cached DM channels from the client. /// Clears cached DM channels from the client.
/// </summary> /// </summary>
public void PurgeDMChannelCache() => State.PurgeDMChannels(); public void PurgeDMChannelCache() => RemoveDMChannels();
/// <inheritdoc /> /// <inheritdoc />
public override SocketUser GetUser(ulong id) public override SocketUser GetUser(ulong id)
@@ -317,14 +317,11 @@ namespace Discord.WebSocket
/// Clears cached users from the client. /// Clears cached users from the client.
/// </summary> /// </summary>
public void PurgeUserCache() => State.PurgeUsers(); public void PurgeUserCache() => State.PurgeUsers();
internal SocketGlobalUser GetOrCreateUser(ClientState state, Discord.API.User model) internal SocketGlobalUser GetOrCreateUser(ClientState state, Discord.API.User model, bool cache)
{ {
return state.GetOrAddUser(model.Id, x => if (cache)
{ return state.GetOrAddUser(model.Id, x => SocketGlobalUser.Create(this, state, model));
var user = SocketGlobalUser.Create(this, state, model); return state.GetUser(model.Id) ?? SocketGlobalUser.Create(this, state, model);
user.GlobalUser.AddRef();
return user;
});
} }
internal SocketGlobalUser GetOrCreateSelfUser(ClientState state, Discord.API.User model) internal SocketGlobalUser GetOrCreateSelfUser(ClientState state, Discord.API.User model)
{ {
@@ -1245,6 +1242,19 @@ namespace Discord.WebSocket
return; return;
} }
if (channel == null)
{
if (!data.GuildId.IsSpecified) // assume it is a DM
{
channel = CreateDMChannel(data.ChannelId, data.Author.Value, State);
}
else
{
await UnknownChannelAsync(type, data.ChannelId).ConfigureAwait(false);
return;
}
}
SocketUser author; SocketUser author;
if (guild != null) if (guild != null)
{ {
@@ -1254,7 +1264,7 @@ namespace Discord.WebSocket
author = guild.GetUser(data.Author.Value.Id); author = guild.GetUser(data.Author.Value.Id);
} }
else else
author = (channel as SocketChannel)?.GetUser(data.Author.Value.Id); author = (channel as SocketChannel).GetUser(data.Author.Value.Id);
if (author == null) if (author == null)
{ {
@@ -1271,21 +1281,8 @@ namespace Discord.WebSocket
else if (channel is SocketGroupChannel groupChannel) else if (channel is SocketGroupChannel groupChannel)
author = groupChannel.GetOrAddUser(data.Author.Value); author = groupChannel.GetOrAddUser(data.Author.Value);
else else
author = State.GetOrAddUser(data.Author.Value.Id, x => SocketGlobalUser.Create(this, State, data.Author.Value));
}
if (channel == null)
{ {
if (!data.GuildId.IsSpecified) // assume it is a DM await UnknownChannelUserAsync(type, data.Author.Value.Id, channel.Id).ConfigureAwait(false);
{
var dm = SocketDMChannel.Create(this, State, data.ChannelId, data.Author.Value);
channel = dm;
State.AddChannel(dm);
dm.Recipient.GlobalUser.DMChannel = dm;
}
else
{
await UnknownChannelAsync(type, data.ChannelId).ConfigureAwait(false);
return; return;
} }
} }
@@ -1944,24 +1941,29 @@ namespace Discord.WebSocket
{ {
var channel = SocketChannel.CreatePrivate(this, state, model); var channel = SocketChannel.CreatePrivate(this, state, model);
state.AddChannel(channel as SocketChannel); state.AddChannel(channel as SocketChannel);
if (channel is SocketDMChannel dm)
dm.Recipient.GlobalUser.DMChannel = dm;
return channel; return channel;
} }
internal SocketDMChannel CreateDMChannel(ulong channelId, API.User model, ClientState state)
{
return SocketDMChannel.Create(this, state, channelId, model);
}
internal ISocketPrivateChannel RemovePrivateChannel(ulong id) internal ISocketPrivateChannel RemovePrivateChannel(ulong id)
{ {
var channel = State.RemoveChannel(id) as ISocketPrivateChannel; var channel = State.RemoveChannel(id) as ISocketPrivateChannel;
if (channel != null) if (channel != null)
{ {
if (channel is SocketDMChannel dmChannel)
dmChannel.Recipient.GlobalUser.DMChannel = null;
foreach (var recipient in channel.Recipients) foreach (var recipient in channel.Recipients)
recipient.GlobalUser.RemoveRef(this); recipient.GlobalUser.RemoveRef(this);
} }
return channel; return channel;
} }
internal void RemoveDMChannels()
{
var channels = State.DMChannels;
State.PurgeDMChannels();
foreach (var channel in channels)
channel.Recipient.GlobalUser.RemoveRef(this);
}
private async Task GuildAvailableAsync(SocketGuild guild) private async Task GuildAvailableAsync(SocketGuild guild)
{ {

43
src/Discord.Net.WebSocket/Entities/Channels/SocketDMChannel.cs
View File

@@ -16,15 +16,13 @@ namespace Discord.WebSocket
[DebuggerDisplay(@"{DebuggerDisplay,nq}")] [DebuggerDisplay(@"{DebuggerDisplay,nq}")]
public class SocketDMChannel : SocketChannel, IDMChannel, ISocketPrivateChannel, ISocketMessageChannel public class SocketDMChannel : SocketChannel, IDMChannel, ISocketPrivateChannel, ISocketMessageChannel
{ {
private readonly MessageCache _messages;
/// <summary> /// <summary>
/// Gets the recipient of the channel. /// Gets the recipient of the channel.
/// </summary> /// </summary>
public SocketUser Recipient { get; } public SocketUser Recipient { get; }
/// <inheritdoc /> /// <inheritdoc />
public IReadOnlyCollection<SocketMessage> CachedMessages => _messages?.Messages ?? ImmutableArray.Create<SocketMessage>(); public IReadOnlyCollection<SocketMessage> CachedMessages => ImmutableArray.Create<SocketMessage>();
/// <summary> /// <summary>
/// Gets a collection that is the current logged-in user and the recipient. /// Gets a collection that is the current logged-in user and the recipient.
@@ -35,13 +33,10 @@ namespace Discord.WebSocket
: base(discord, id) : base(discord, id)
{ {
Recipient = recipient; Recipient = recipient;
recipient.GlobalUser.AddRef();
if (Discord.MessageCacheSize > 0)
_messages = new MessageCache(Discord);
} }
internal static SocketDMChannel Create(DiscordSocketClient discord, ClientState state, Model model) internal static SocketDMChannel Create(DiscordSocketClient discord, ClientState state, Model model)
{ {
var entity = new SocketDMChannel(discord, model.Id, discord.GetOrCreateUser(state, model.Recipients.Value[0])); var entity = new SocketDMChannel(discord, model.Id, discord.GetOrCreateUser(state, model.Recipients.Value[0], false));
entity.Update(state, model); entity.Update(state, model);
return entity; return entity;
} }
@@ -51,7 +46,7 @@ namespace Discord.WebSocket
} }
internal static SocketDMChannel Create(DiscordSocketClient discord, ClientState state, ulong channelId, API.User recipient) internal static SocketDMChannel Create(DiscordSocketClient discord, ClientState state, ulong channelId, API.User recipient)
{ {
var entity = new SocketDMChannel(discord, channelId, discord.GetOrCreateUser(state, recipient)); var entity = new SocketDMChannel(discord, channelId, discord.GetOrCreateUser(state, recipient, false));
entity.Update(state, recipient); entity.Update(state, recipient);
return entity; return entity;
} }
@@ -67,7 +62,7 @@ namespace Discord.WebSocket
//Messages //Messages
/// <inheritdoc /> /// <inheritdoc />
public SocketMessage GetCachedMessage(ulong id) public SocketMessage GetCachedMessage(ulong id)
=> _messages?.Get(id); => null;
/// <summary> /// <summary>
/// Gets the message associated with the given <paramref name="id"/>. /// Gets the message associated with the given <paramref name="id"/>.
/// </summary> /// </summary>
@@ -78,10 +73,7 @@ namespace Discord.WebSocket
/// </returns> /// </returns>
public async Task<IMessage> GetMessageAsync(ulong id, RequestOptions options = null) public async Task<IMessage> GetMessageAsync(ulong id, RequestOptions options = null)
{ {
IMessage msg = _messages?.Get(id); return await ChannelHelper.GetMessageAsync(this, Discord, id, options).ConfigureAwait(false);
if (msg == null)
msg = await ChannelHelper.GetMessageAsync(this, Discord, id, options).ConfigureAwait(false);
return msg;
} }
/// <summary> /// <summary>
@@ -97,7 +89,7 @@ namespace Discord.WebSocket
/// Paged collection of messages. /// Paged collection of messages.
/// </returns> /// </returns>
public IAsyncEnumerable<IReadOnlyCollection<IMessage>> GetMessagesAsync(int limit = DiscordConfig.MaxMessagesPerBatch, RequestOptions options = null) public IAsyncEnumerable<IReadOnlyCollection<IMessage>> GetMessagesAsync(int limit = DiscordConfig.MaxMessagesPerBatch, RequestOptions options = null)
=> SocketChannelHelper.GetMessagesAsync(this, Discord, _messages, null, Direction.Before, limit, CacheMode.AllowDownload, options); => ChannelHelper.GetMessagesAsync(this, Discord, null, Direction.Before, limit, options);
/// <summary> /// <summary>
/// Gets a collection of messages in this channel. /// Gets a collection of messages in this channel.
/// </summary> /// </summary>
@@ -113,7 +105,7 @@ namespace Discord.WebSocket
/// Paged collection of messages. /// Paged collection of messages.
/// </returns> /// </returns>
public IAsyncEnumerable<IReadOnlyCollection<IMessage>> GetMessagesAsync(ulong fromMessageId, Direction dir, int limit = DiscordConfig.MaxMessagesPerBatch, RequestOptions options = null) public IAsyncEnumerable<IReadOnlyCollection<IMessage>> GetMessagesAsync(ulong fromMessageId, Direction dir, int limit = DiscordConfig.MaxMessagesPerBatch, RequestOptions options = null)
=> SocketChannelHelper.GetMessagesAsync(this, Discord, _messages, fromMessageId, dir, limit, CacheMode.AllowDownload, options); => ChannelHelper.GetMessagesAsync(this, Discord, fromMessageId, dir, limit, options);
/// <summary> /// <summary>
/// Gets a collection of messages in this channel. /// Gets a collection of messages in this channel.
/// </summary> /// </summary>
@@ -129,16 +121,16 @@ namespace Discord.WebSocket
/// Paged collection of messages. /// Paged collection of messages.
/// </returns> /// </returns>
public IAsyncEnumerable<IReadOnlyCollection<IMessage>> GetMessagesAsync(IMessage fromMessage, Direction dir, int limit = DiscordConfig.MaxMessagesPerBatch, RequestOptions options = null) public IAsyncEnumerable<IReadOnlyCollection<IMessage>> GetMessagesAsync(IMessage fromMessage, Direction dir, int limit = DiscordConfig.MaxMessagesPerBatch, RequestOptions options = null)
=> SocketChannelHelper.GetMessagesAsync(this, Discord, _messages, fromMessage.Id, dir, limit, CacheMode.AllowDownload, options); => ChannelHelper.GetMessagesAsync(this, Discord, fromMessage.Id, dir, limit, options);
/// <inheritdoc /> /// <inheritdoc />
public IReadOnlyCollection<SocketMessage> GetCachedMessages(int limit = DiscordConfig.MaxMessagesPerBatch) public IReadOnlyCollection<SocketMessage> GetCachedMessages(int limit = DiscordConfig.MaxMessagesPerBatch)
=> SocketChannelHelper.GetCachedMessages(this, Discord, _messages, null, Direction.Before, limit); => ImmutableArray.Create<SocketMessage>();
/// <inheritdoc /> /// <inheritdoc />
public IReadOnlyCollection<SocketMessage> GetCachedMessages(ulong fromMessageId, Direction dir, int limit = DiscordConfig.MaxMessagesPerBatch) public IReadOnlyCollection<SocketMessage> GetCachedMessages(ulong fromMessageId, Direction dir, int limit = DiscordConfig.MaxMessagesPerBatch)
=> SocketChannelHelper.GetCachedMessages(this, Discord, _messages, fromMessageId, dir, limit); => ImmutableArray.Create<SocketMessage>();
/// <inheritdoc /> /// <inheritdoc />
public IReadOnlyCollection<SocketMessage> GetCachedMessages(IMessage fromMessage, Direction dir, int limit = DiscordConfig.MaxMessagesPerBatch) public IReadOnlyCollection<SocketMessage> GetCachedMessages(IMessage fromMessage, Direction dir, int limit = DiscordConfig.MaxMessagesPerBatch)
=> SocketChannelHelper.GetCachedMessages(this, Discord, _messages, fromMessage.Id, dir, limit); => ImmutableArray.Create<SocketMessage>();
/// <inheritdoc /> /// <inheritdoc />
public Task<IReadOnlyCollection<RestMessage>> GetPinnedMessagesAsync(RequestOptions options = null) public Task<IReadOnlyCollection<RestMessage>> GetPinnedMessagesAsync(RequestOptions options = null)
=> ChannelHelper.GetPinnedMessagesAsync(this, Discord, options); => ChannelHelper.GetPinnedMessagesAsync(this, Discord, options);
@@ -174,9 +166,12 @@ namespace Discord.WebSocket
=> ChannelHelper.EnterTypingState(this, Discord, options); => ChannelHelper.EnterTypingState(this, Discord, options);
internal void AddMessage(SocketMessage msg) internal void AddMessage(SocketMessage msg)
=> _messages?.Add(msg); {
}
internal SocketMessage RemoveMessage(ulong id) internal SocketMessage RemoveMessage(ulong id)
=> _messages?.Remove(id); {
return null;
}
//Users //Users
/// <summary> /// <summary>
@@ -232,13 +227,13 @@ namespace Discord.WebSocket
} }
/// <inheritdoc /> /// <inheritdoc />
IAsyncEnumerable<IReadOnlyCollection<IMessage>> IMessageChannel.GetMessagesAsync(int limit, CacheMode mode, RequestOptions options) IAsyncEnumerable<IReadOnlyCollection<IMessage>> IMessageChannel.GetMessagesAsync(int limit, CacheMode mode, RequestOptions options)
=> SocketChannelHelper.GetMessagesAsync(this, Discord, _messages, null, Direction.Before, limit, mode, options); => mode == CacheMode.CacheOnly ? null : GetMessagesAsync(limit, options);
/// <inheritdoc /> /// <inheritdoc />
IAsyncEnumerable<IReadOnlyCollection<IMessage>> IMessageChannel.GetMessagesAsync(ulong fromMessageId, Direction dir, int limit, CacheMode mode, RequestOptions options) IAsyncEnumerable<IReadOnlyCollection<IMessage>> IMessageChannel.GetMessagesAsync(ulong fromMessageId, Direction dir, int limit, CacheMode mode, RequestOptions options)
=> SocketChannelHelper.GetMessagesAsync(this, Discord, _messages, fromMessageId, dir, limit, mode, options); => mode == CacheMode.CacheOnly ? null : GetMessagesAsync(fromMessageId, dir, limit, options);
/// <inheritdoc /> /// <inheritdoc />
IAsyncEnumerable<IReadOnlyCollection<IMessage>> IMessageChannel.GetMessagesAsync(IMessage fromMessage, Direction dir, int limit, CacheMode mode, RequestOptions options) IAsyncEnumerable<IReadOnlyCollection<IMessage>> IMessageChannel.GetMessagesAsync(IMessage fromMessage, Direction dir, int limit, CacheMode mode, RequestOptions options)
=> SocketChannelHelper.GetMessagesAsync(this, Discord, _messages, fromMessage.Id, dir, limit, mode, options); => mode == CacheMode.CacheOnly ? null : GetMessagesAsync(fromMessage.Id, dir, limit, options);
/// <inheritdoc /> /// <inheritdoc />
async Task<IReadOnlyCollection<IMessage>> IMessageChannel.GetPinnedMessagesAsync(RequestOptions options) async Task<IReadOnlyCollection<IMessage>> IMessageChannel.GetPinnedMessagesAsync(RequestOptions options)
=> await GetPinnedMessagesAsync(options).ConfigureAwait(false); => await GetPinnedMessagesAsync(options).ConfigureAwait(false);

2
src/Discord.Net.WebSocket/Entities/Users/SocketGlobalUser.cs
View File

@@ -12,7 +12,6 @@ namespace Discord.WebSocket
public override string Username { get; internal set; } public override string Username { get; internal set; }
public override ushort DiscriminatorValue { get; internal set; } public override ushort DiscriminatorValue { get; internal set; }
public override string AvatarId { get; internal set; } public override string AvatarId { get; internal set; }
public SocketDMChannel DMChannel { get; internal set; }
internal override SocketPresence Presence { get; set; } internal override SocketPresence Presence { get; set; }
public override bool IsWebhook => false; public override bool IsWebhook => false;
@@ -52,7 +51,6 @@ namespace Discord.WebSocket
internal void Update(ClientState state, PresenceModel model) internal void Update(ClientState state, PresenceModel model)
{ {
Presence = SocketPresence.Create(model); Presence = SocketPresence.Create(model);
DMChannel = state.DMChannels.FirstOrDefault(x => x.Recipient.Id == Id);
} }
private string DebuggerDisplay => $"{Username}#{Discriminator} ({Id}{(IsBot ? ", Bot" : "")}, Global)"; private string DebuggerDisplay => $"{Username}#{Discriminator} ({Id}{(IsBot ? ", Bot" : "")}, Global)";

2
src/Discord.Net.WebSocket/Entities/Users/SocketGroupUser.cs
View File

@@ -38,7 +38,7 @@ namespace Discord.WebSocket
} }
internal static SocketGroupUser Create(SocketGroupChannel channel, ClientState state, Model model) internal static SocketGroupUser Create(SocketGroupChannel channel, ClientState state, Model model)
{ {
var entity = new SocketGroupUser(channel, channel.Discord.GetOrCreateUser(state, model)); var entity = new SocketGroupUser(channel, channel.Discord.GetOrCreateUser(state, model, true));
entity.Update(state, model); entity.Update(state, model);
return entity; return entity;
} }

6
src/Discord.Net.WebSocket/Entities/Users/SocketGuildUser.cs
View File

@@ -116,20 +116,20 @@ namespace Discord.WebSocket
} }
internal static SocketGuildUser Create(SocketGuild guild, ClientState state, UserModel model) internal static SocketGuildUser Create(SocketGuild guild, ClientState state, UserModel model)
{ {
var entity = new SocketGuildUser(guild, guild.Discord.GetOrCreateUser(state, model)); var entity = new SocketGuildUser(guild, guild.Discord.GetOrCreateUser(state, model, true));
entity.Update(state, model); entity.Update(state, model);
entity.UpdateRoles(new ulong[0]); entity.UpdateRoles(new ulong[0]);
return entity; return entity;
} }
internal static SocketGuildUser Create(SocketGuild guild, ClientState state, MemberModel model) internal static SocketGuildUser Create(SocketGuild guild, ClientState state, MemberModel model)
{ {
var entity = new SocketGuildUser(guild, guild.Discord.GetOrCreateUser(state, model.User)); var entity = new SocketGuildUser(guild, guild.Discord.GetOrCreateUser(state, model.User, true));
entity.Update(state, model); entity.Update(state, model);
return entity; return entity;
} }
internal static SocketGuildUser Create(SocketGuild guild, ClientState state, PresenceModel model) internal static SocketGuildUser Create(SocketGuild guild, ClientState state, PresenceModel model)
{ {
var entity = new SocketGuildUser(guild, guild.Discord.GetOrCreateUser(state, model.User)); var entity = new SocketGuildUser(guild, guild.Discord.GetOrCreateUser(state, model.User, true));
entity.Update(state, model, false); entity.Update(state, model, false);
return entity; return entity;
} }

4
src/Discord.Net.WebSocket/Entities/Users/SocketUser.cs
View File

@@ -92,8 +92,8 @@ namespace Discord.WebSocket
} }
/// <inheritdoc /> /// <inheritdoc />
public async Task<IDMChannel> GetOrCreateDMChannelAsync(RequestOptions options = null) public async Task<IDMChannel> CreateDMChannelAsync(RequestOptions options = null)
=> GlobalUser.DMChannel ?? await UserHelper.CreateDMChannelAsync(this, Discord, options).ConfigureAwait(false) as IDMChannel; => await UserHelper.CreateDMChannelAsync(this, Discord, options).ConfigureAwait(false);
/// <inheritdoc /> /// <inheritdoc />
public string GetAvatarUrl(ImageFormat format = ImageFormat.Auto, ushort size = 128) public string GetAvatarUrl(ImageFormat format = ImageFormat.Auto, ushort size = 128)