* Move reaction methods of IUserMessage to IReactionMessage Moves the reaction-related methods contained in IUserMessage to the IReactionMessage type. Updates the type of ISystemMessage so that it implements IReactionMessage. * Move rest reaction implementation to RestReactionMessage Copies the reaction implementation from RestUserMessage to RestReactionMessage. Updates RestUserMessage and RestSystemMessage to be derived from RestReactionMessage instead of RestMessage. * Move WS reaction implementation to SocketReactionMessage Copies the reaction implementation from SocketUserMessage into SocketReactionMessage. Updates SocketSystemMessage and SocketUserMessage to use SocketReactionMessage as the base class. * docs: update summary for ReactionMessage classes * Remove ReactionMessage types, move reaction impl to IMessage Removes the IReactionMessage and derived types, which was unnecessary since all classes derived from IReactionMessage were IMessage. Moves the reaction implementation to IMessage and derived types.pull/1376/head
@@ -1,5 +1,6 @@ | |||
using System; | |||
using System.Collections.Generic; | |||
using System.Threading.Tasks; | |||
namespace Discord | |||
{ | |||
@@ -138,5 +139,89 @@ namespace Discord | |||
/// A message's application, if any is associated. | |||
/// </returns> | |||
MessageApplication Application { get; } | |||
/// <summary> | |||
/// Gets all reactions included in this message. | |||
/// </summary> | |||
IReadOnlyDictionary<IEmote, ReactionMetadata> Reactions { get; } | |||
/// <summary> | |||
/// Adds a reaction to this message. | |||
/// </summary> | |||
/// <example> | |||
/// The following example adds the reaction, <c>💕</c>, to the message. | |||
/// <code language="cs"> | |||
/// await msg.AddReactionAsync(new Emoji("\U0001f495")); | |||
/// </code> | |||
/// </example> | |||
/// <param name="emote">The emoji used to react to this message.</param> | |||
/// <param name="options">The options to be used when sending the request.</param> | |||
/// <returns> | |||
/// A task that represents the asynchronous operation for adding a reaction to this message. | |||
/// </returns> | |||
/// <seealso cref="IEmote"/> | |||
Task AddReactionAsync(IEmote emote, RequestOptions options = null); | |||
/// <summary> | |||
/// Removes a reaction from message. | |||
/// </summary> | |||
/// <example> | |||
/// The following example removes the reaction, <c>💕</c>, added by the message author from the message. | |||
/// <code language="cs"> | |||
/// await msg.RemoveReactionAsync(new Emoji("\U0001f495"), msg.Author); | |||
/// </code> | |||
/// </example> | |||
/// <param name="emote">The emoji used to react to this message.</param> | |||
/// <param name="user">The user that added the emoji.</param> | |||
/// <param name="options">The options to be used when sending the request.</param> | |||
/// <returns> | |||
/// A task that represents the asynchronous operation for removing a reaction to this message. | |||
/// </returns> | |||
/// <seealso cref="IEmote"/> | |||
Task RemoveReactionAsync(IEmote emote, IUser user, RequestOptions options = null); | |||
/// <summary> | |||
/// Removes a reaction from message. | |||
/// </summary> | |||
/// <example> | |||
/// The following example removes the reaction, <c>💕</c>, added by the user with ID 84291986575613952 from the message. | |||
/// <code language="cs"> | |||
/// await msg.RemoveReactionAsync(new Emoji("\U0001f495"), 84291986575613952); | |||
/// </code> | |||
/// </example> | |||
/// <param name="emote">The emoji used to react to this message.</param> | |||
/// <param name="userId">The ID of the user that added the emoji.</param> | |||
/// <param name="options">The options to be used when sending the request.</param> | |||
/// <returns> | |||
/// A task that represents the asynchronous operation for removing a reaction to this message. | |||
/// </returns> | |||
/// <seealso cref="IEmote"/> | |||
Task RemoveReactionAsync(IEmote emote, ulong userId, RequestOptions options = null); | |||
/// <summary> | |||
/// Removes all reactions from this message. | |||
/// </summary> | |||
/// <param name="options">The options to be used when sending the request.</param> | |||
/// <returns> | |||
/// A task that represents the asynchronous removal operation. | |||
/// </returns> | |||
Task RemoveAllReactionsAsync(RequestOptions options = null); | |||
/// <summary> | |||
/// Gets all users that reacted to a message with a given emote. | |||
/// </summary> | |||
/// <example> | |||
/// The following example gets the users that have reacted with the emoji <c>💕</c> to the message. | |||
/// <code language="cs"> | |||
/// var emoji = new Emoji("\U0001f495"); | |||
/// var reactedUsers = await message.GetReactionUsersAsync(emoji, 100).FlattenAsync(); | |||
/// </code> | |||
/// </example> | |||
/// <param name="emoji">The emoji that represents the reaction that you wish to get.</param> | |||
/// <param name="limit">The number of users to request.</param> | |||
/// <param name="options">The options to be used when sending the request.</param> | |||
/// <returns> | |||
/// A paged collection containing a read-only collection of users that has reacted to this message. | |||
/// Flattening the paginated response into a collection of users with | |||
/// <see cref="AsyncEnumerableExtensions.FlattenAsync{T}"/> is required if you wish to access the users. | |||
/// </returns> | |||
IAsyncEnumerable<IReadOnlyCollection<IUser>> GetReactionUsersAsync(IEmote emoji, int limit, RequestOptions options = null); | |||
} | |||
} |
@@ -58,90 +58,6 @@ namespace Discord | |||
Task UnpinAsync(RequestOptions options = null); | |||
/// <summary> | |||
/// Gets all reactions included in this message. | |||
/// </summary> | |||
IReadOnlyDictionary<IEmote, ReactionMetadata> Reactions { get; } | |||
/// <summary> | |||
/// Adds a reaction to this message. | |||
/// </summary> | |||
/// <example> | |||
/// The following example adds the reaction, <c>💕</c>, to the message. | |||
/// <code language="cs"> | |||
/// await msg.AddReactionAsync(new Emoji("\U0001f495")); | |||
/// </code> | |||
/// </example> | |||
/// <param name="emote">The emoji used to react to this message.</param> | |||
/// <param name="options">The options to be used when sending the request.</param> | |||
/// <returns> | |||
/// A task that represents the asynchronous operation for adding a reaction to this message. | |||
/// </returns> | |||
/// <seealso cref="IEmote"/> | |||
Task AddReactionAsync(IEmote emote, RequestOptions options = null); | |||
/// <summary> | |||
/// Removes a reaction from message. | |||
/// </summary> | |||
/// <example> | |||
/// The following example removes the reaction, <c>💕</c>, added by the message author from the message. | |||
/// <code language="cs"> | |||
/// await msg.RemoveReactionAsync(new Emoji("\U0001f495"), msg.Author); | |||
/// </code> | |||
/// </example> | |||
/// <param name="emote">The emoji used to react to this message.</param> | |||
/// <param name="user">The user that added the emoji.</param> | |||
/// <param name="options">The options to be used when sending the request.</param> | |||
/// <returns> | |||
/// A task that represents the asynchronous operation for removing a reaction to this message. | |||
/// </returns> | |||
/// <seealso cref="IEmote"/> | |||
Task RemoveReactionAsync(IEmote emote, IUser user, RequestOptions options = null); | |||
/// <summary> | |||
/// Removes a reaction from message. | |||
/// </summary> | |||
/// <example> | |||
/// The following example removes the reaction, <c>💕</c>, added by the user with ID 84291986575613952 from the message. | |||
/// <code language="cs"> | |||
/// await msg.RemoveReactionAsync(new Emoji("\U0001f495"), 84291986575613952); | |||
/// </code> | |||
/// </example> | |||
/// <param name="emote">The emoji used to react to this message.</param> | |||
/// <param name="userId">The ID of the user that added the emoji.</param> | |||
/// <param name="options">The options to be used when sending the request.</param> | |||
/// <returns> | |||
/// A task that represents the asynchronous operation for removing a reaction to this message. | |||
/// </returns> | |||
/// <seealso cref="IEmote"/> | |||
Task RemoveReactionAsync(IEmote emote, ulong userId, RequestOptions options = null); | |||
/// <summary> | |||
/// Removes all reactions from this message. | |||
/// </summary> | |||
/// <param name="options">The options to be used when sending the request.</param> | |||
/// <returns> | |||
/// A task that represents the asynchronous removal operation. | |||
/// </returns> | |||
Task RemoveAllReactionsAsync(RequestOptions options = null); | |||
/// <summary> | |||
/// Gets all users that reacted to a message with a given emote. | |||
/// </summary> | |||
/// <example> | |||
/// The following example gets the users that have reacted with the emoji <c>💕</c> to the message. | |||
/// <code language="cs"> | |||
/// var emoji = new Emoji("\U0001f495"); | |||
/// var reactedUsers = await message.GetReactionUsersAsync(emoji, 100).FlattenAsync(); | |||
/// </code> | |||
/// </example> | |||
/// <param name="emoji">The emoji that represents the reaction that you wish to get.</param> | |||
/// <param name="limit">The number of users to request.</param> | |||
/// <param name="options">The options to be used when sending the request.</param> | |||
/// <returns> | |||
/// A paged collection containing a read-only collection of users that has reacted to this message. | |||
/// Flattening the paginated response into a collection of users with | |||
/// <see cref="AsyncEnumerableExtensions.FlattenAsync{T}"/> is required if you wish to access the users. | |||
/// </returns> | |||
IAsyncEnumerable<IReadOnlyCollection<IUser>> GetReactionUsersAsync(IEmote emoji, int limit, RequestOptions options = null); | |||
/// <summary> | |||
/// Transforms this message's text into a human-readable form by resolving its tags. | |||
/// </summary> | |||
/// <param name="userHandling">Determines how the user tag should be handled.</param> | |||
@@ -13,6 +13,7 @@ namespace Discord.Rest | |||
public abstract class RestMessage : RestEntity<ulong>, IMessage, IUpdateable | |||
{ | |||
private long _timestampTicks; | |||
private ImmutableArray<RestReaction> _reactions = ImmutableArray.Create<RestReaction>(); | |||
/// <inheritdoc /> | |||
public IMessageChannel Channel { get; } | |||
@@ -106,6 +107,22 @@ namespace Discord.Rest | |||
PartyId = model.Activity.Value.PartyId.GetValueOrDefault() | |||
}; | |||
} | |||
if (model.Reactions.IsSpecified) | |||
{ | |||
var value = model.Reactions.Value; | |||
if (value.Length > 0) | |||
{ | |||
var reactions = ImmutableArray.CreateBuilder<RestReaction>(value.Length); | |||
for (int i = 0; i < value.Length; i++) | |||
reactions.Add(RestReaction.Create(value[i])); | |||
_reactions = reactions.ToImmutable(); | |||
} | |||
else | |||
_reactions = ImmutableArray.Create<RestReaction>(); | |||
} | |||
else | |||
_reactions = ImmutableArray.Create<RestReaction>(); | |||
} | |||
/// <inheritdoc /> | |||
@@ -135,5 +152,24 @@ namespace Discord.Rest | |||
IReadOnlyCollection<IEmbed> IMessage.Embeds => Embeds; | |||
/// <inheritdoc /> | |||
IReadOnlyCollection<ulong> IMessage.MentionedUserIds => MentionedUsers.Select(x => x.Id).ToImmutableArray(); | |||
/// <inheritdoc /> | |||
public IReadOnlyDictionary<IEmote, ReactionMetadata> Reactions => _reactions.ToDictionary(x => x.Emote, x => new ReactionMetadata { ReactionCount = x.Count, IsMe = x.Me }); | |||
/// <inheritdoc /> | |||
public Task AddReactionAsync(IEmote emote, RequestOptions options = null) | |||
=> MessageHelper.AddReactionAsync(this, emote, Discord, options); | |||
/// <inheritdoc /> | |||
public Task RemoveReactionAsync(IEmote emote, IUser user, RequestOptions options = null) | |||
=> MessageHelper.RemoveReactionAsync(this, user.Id, emote, Discord, options); | |||
/// <inheritdoc /> | |||
public Task RemoveReactionAsync(IEmote emote, ulong userId, RequestOptions options = null) | |||
=> MessageHelper.RemoveReactionAsync(this, userId, emote, Discord, options); | |||
/// <inheritdoc /> | |||
public Task RemoveAllReactionsAsync(RequestOptions options = null) | |||
=> MessageHelper.RemoveAllReactionsAsync(this, Discord, options); | |||
/// <inheritdoc /> | |||
public IAsyncEnumerable<IReadOnlyCollection<IUser>> GetReactionUsersAsync(IEmote emote, int limit, RequestOptions options = null) | |||
=> MessageHelper.GetReactionUsersAsync(this, emote, limit, Discord, options); | |||
} | |||
} |
@@ -2,7 +2,6 @@ using System; | |||
using System.Collections.Generic; | |||
using System.Collections.Immutable; | |||
using System.Diagnostics; | |||
using System.Linq; | |||
using System.Threading.Tasks; | |||
using Model = Discord.API.Message; | |||
@@ -19,7 +18,6 @@ namespace Discord.Rest | |||
private ImmutableArray<Attachment> _attachments = ImmutableArray.Create<Attachment>(); | |||
private ImmutableArray<Embed> _embeds = ImmutableArray.Create<Embed>(); | |||
private ImmutableArray<ITag> _tags = ImmutableArray.Create<ITag>(); | |||
private ImmutableArray<RestReaction> _reactions = ImmutableArray.Create<RestReaction>(); | |||
/// <inheritdoc /> | |||
public override bool IsTTS => _isTTS; | |||
@@ -41,8 +39,6 @@ namespace Discord.Rest | |||
public override IReadOnlyCollection<RestUser> MentionedUsers => MessageHelper.FilterTagsByValue<RestUser>(TagType.UserMention, _tags); | |||
/// <inheritdoc /> | |||
public override IReadOnlyCollection<ITag> Tags => _tags; | |||
/// <inheritdoc /> | |||
public IReadOnlyDictionary<IEmote, ReactionMetadata> Reactions => _reactions.ToDictionary(x => x.Emote, x => new ReactionMetadata { ReactionCount = x.Count, IsMe = x.Me }); | |||
internal RestUserMessage(BaseDiscordClient discord, ulong id, IMessageChannel channel, IUser author, MessageSource source) | |||
: base(discord, id, channel, author, source) | |||
@@ -117,22 +113,6 @@ namespace Discord.Rest | |||
} | |||
} | |||
if (model.Reactions.IsSpecified) | |||
{ | |||
var value = model.Reactions.Value; | |||
if (value.Length > 0) | |||
{ | |||
var reactions = ImmutableArray.CreateBuilder<RestReaction>(value.Length); | |||
for (int i = 0; i < value.Length; i++) | |||
reactions.Add(RestReaction.Create(value[i])); | |||
_reactions = reactions.ToImmutable(); | |||
} | |||
else | |||
_reactions = ImmutableArray.Create<RestReaction>(); | |||
} | |||
else | |||
_reactions = ImmutableArray.Create<RestReaction>(); | |||
if (model.Content.IsSpecified) | |||
{ | |||
var text = model.Content.Value; | |||
@@ -151,22 +131,6 @@ namespace Discord.Rest | |||
} | |||
/// <inheritdoc /> | |||
public Task AddReactionAsync(IEmote emote, RequestOptions options = null) | |||
=> MessageHelper.AddReactionAsync(this, emote, Discord, options); | |||
/// <inheritdoc /> | |||
public Task RemoveReactionAsync(IEmote emote, IUser user, RequestOptions options = null) | |||
=> MessageHelper.RemoveReactionAsync(this, user.Id, emote, Discord, options); | |||
/// <inheritdoc /> | |||
public Task RemoveReactionAsync(IEmote emote, ulong userId, RequestOptions options = null) | |||
=> MessageHelper.RemoveReactionAsync(this, userId, emote, Discord, options); | |||
/// <inheritdoc /> | |||
public Task RemoveAllReactionsAsync(RequestOptions options = null) | |||
=> MessageHelper.RemoveAllReactionsAsync(this, Discord, options); | |||
/// <inheritdoc /> | |||
public IAsyncEnumerable<IReadOnlyCollection<IUser>> GetReactionUsersAsync(IEmote emote, int limit, RequestOptions options = null) | |||
=> MessageHelper.GetReactionUsersAsync(this, emote, limit, Discord, options); | |||
/// <inheritdoc /> | |||
public Task PinAsync(RequestOptions options = null) | |||
=> MessageHelper.PinAsync(this, Discord, options); | |||
/// <inheritdoc /> | |||
@@ -14,6 +14,7 @@ namespace Discord.WebSocket | |||
public abstract class SocketMessage : SocketEntity<ulong>, IMessage | |||
{ | |||
private long _timestampTicks; | |||
private readonly List<SocketReaction> _reactions = new List<SocketReaction>(); | |||
/// <summary> | |||
/// Gets the author of this message. | |||
@@ -89,6 +90,8 @@ namespace Discord.WebSocket | |||
public virtual IReadOnlyCollection<SocketUser> MentionedUsers => ImmutableArray.Create<SocketUser>(); | |||
/// <inheritdoc /> | |||
public virtual IReadOnlyCollection<ITag> Tags => ImmutableArray.Create<ITag>(); | |||
/// <inheritdoc /> | |||
public IReadOnlyDictionary<IEmote, ReactionMetadata> Reactions => _reactions.GroupBy(r => r.Emote).ToDictionary(x => x.Key, x => new ReactionMetadata { ReactionCount = x.Count(), IsMe = x.Any(y => y.UserId == Discord.CurrentUser.Id) }); | |||
/// <inheritdoc /> | |||
public DateTimeOffset Timestamp => DateTimeUtils.FromTicks(_timestampTicks); | |||
@@ -169,5 +172,35 @@ namespace Discord.WebSocket | |||
IReadOnlyCollection<ulong> IMessage.MentionedRoleIds => MentionedRoles.Select(x => x.Id).ToImmutableArray(); | |||
/// <inheritdoc /> | |||
IReadOnlyCollection<ulong> IMessage.MentionedUserIds => MentionedUsers.Select(x => x.Id).ToImmutableArray(); | |||
internal void AddReaction(SocketReaction reaction) | |||
{ | |||
_reactions.Add(reaction); | |||
} | |||
internal void RemoveReaction(SocketReaction reaction) | |||
{ | |||
if (_reactions.Contains(reaction)) | |||
_reactions.Remove(reaction); | |||
} | |||
internal void ClearReactions() | |||
{ | |||
_reactions.Clear(); | |||
} | |||
/// <inheritdoc /> | |||
public Task AddReactionAsync(IEmote emote, RequestOptions options = null) | |||
=> MessageHelper.AddReactionAsync(this, emote, Discord, options); | |||
/// <inheritdoc /> | |||
public Task RemoveReactionAsync(IEmote emote, IUser user, RequestOptions options = null) | |||
=> MessageHelper.RemoveReactionAsync(this, user.Id, emote, Discord, options); | |||
/// <inheritdoc /> | |||
public Task RemoveReactionAsync(IEmote emote, ulong userId, RequestOptions options = null) | |||
=> MessageHelper.RemoveReactionAsync(this, userId, emote, Discord, options); | |||
/// <inheritdoc /> | |||
public Task RemoveAllReactionsAsync(RequestOptions options = null) | |||
=> MessageHelper.RemoveAllReactionsAsync(this, Discord, options); | |||
/// <inheritdoc /> | |||
public IAsyncEnumerable<IReadOnlyCollection<IUser>> GetReactionUsersAsync(IEmote emote, int limit, RequestOptions options = null) | |||
=> MessageHelper.GetReactionUsersAsync(this, emote, limit, Discord, options); | |||
} | |||
} |
@@ -15,7 +15,6 @@ namespace Discord.WebSocket | |||
[DebuggerDisplay(@"{DebuggerDisplay,nq}")] | |||
public class SocketUserMessage : SocketMessage, IUserMessage | |||
{ | |||
private readonly List<SocketReaction> _reactions = new List<SocketReaction>(); | |||
private bool _isMentioningEveryone, _isTTS, _isPinned, _isSuppressed; | |||
private long? _editedTimestampTicks; | |||
private ImmutableArray<Attachment> _attachments = ImmutableArray.Create<Attachment>(); | |||
@@ -42,8 +41,6 @@ namespace Discord.WebSocket | |||
public override IReadOnlyCollection<SocketRole> MentionedRoles => MessageHelper.FilterTagsByValue<SocketRole>(TagType.RoleMention, _tags); | |||
/// <inheritdoc /> | |||
public override IReadOnlyCollection<SocketUser> MentionedUsers => MessageHelper.FilterTagsByValue<SocketUser>(TagType.UserMention, _tags); | |||
/// <inheritdoc /> | |||
public IReadOnlyDictionary<IEmote, ReactionMetadata> Reactions => _reactions.GroupBy(r => r.Emote).ToDictionary(x => x.Key, x => new ReactionMetadata { ReactionCount = x.Count(), IsMe = x.Any(y => y.UserId == Discord.CurrentUser.Id) }); | |||
internal SocketUserMessage(DiscordSocketClient discord, ulong id, ISocketMessageChannel channel, SocketUser author, MessageSource source) | |||
: base(discord, id, channel, author, source) | |||
@@ -126,20 +123,7 @@ namespace Discord.WebSocket | |||
model.Content = text; | |||
} | |||
} | |||
internal void AddReaction(SocketReaction reaction) | |||
{ | |||
_reactions.Add(reaction); | |||
} | |||
internal void RemoveReaction(SocketReaction reaction) | |||
{ | |||
if (_reactions.Contains(reaction)) | |||
_reactions.Remove(reaction); | |||
} | |||
internal void ClearReactions() | |||
{ | |||
_reactions.Clear(); | |||
} | |||
/// <inheritdoc /> | |||
/// <exception cref="InvalidOperationException">Only the author of a message may modify the message.</exception> | |||
/// <exception cref="ArgumentOutOfRangeException">Message content is too long, length must be less or equal to <see cref="DiscordConfig.MaxMessageSize"/>.</exception> | |||
@@ -147,22 +131,6 @@ namespace Discord.WebSocket | |||
=> MessageHelper.ModifyAsync(this, Discord, func, options); | |||
/// <inheritdoc /> | |||
public Task AddReactionAsync(IEmote emote, RequestOptions options = null) | |||
=> MessageHelper.AddReactionAsync(this, emote, Discord, options); | |||
/// <inheritdoc /> | |||
public Task RemoveReactionAsync(IEmote emote, IUser user, RequestOptions options = null) | |||
=> MessageHelper.RemoveReactionAsync(this, user.Id, emote, Discord, options); | |||
/// <inheritdoc /> | |||
public Task RemoveReactionAsync(IEmote emote, ulong userId, RequestOptions options = null) | |||
=> MessageHelper.RemoveReactionAsync(this, userId, emote, Discord, options); | |||
/// <inheritdoc /> | |||
public Task RemoveAllReactionsAsync(RequestOptions options = null) | |||
=> MessageHelper.RemoveAllReactionsAsync(this, Discord, options); | |||
/// <inheritdoc /> | |||
public IAsyncEnumerable<IReadOnlyCollection<IUser>> GetReactionUsersAsync(IEmote emote, int limit, RequestOptions options = null) | |||
=> MessageHelper.GetReactionUsersAsync(this, emote, limit, Discord, options); | |||
/// <inheritdoc /> | |||
public Task PinAsync(RequestOptions options = null) | |||
=> MessageHelper.PinAsync(this, Discord, options); | |||
/// <inheritdoc /> | |||