* Partial fix of #810, addresses critical connection issues. * Implement fix for REST. * Implement fix on RestChannel.
162 lines
8.0 KiB
C#
162 lines
8.0 KiB
C#
using Discord.Rest;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Collections.Immutable;
|
|
using System.Diagnostics;
|
|
using System.Linq;
|
|
using System.Threading.Tasks;
|
|
using Model = Discord.API.Channel;
|
|
|
|
namespace Discord.WebSocket
|
|
{
|
|
[DebuggerDisplay(@"{DebuggerDisplay,nq}")]
|
|
public class SocketGuildChannel : SocketChannel, IGuildChannel
|
|
{
|
|
private ImmutableArray<Overwrite> _overwrites;
|
|
|
|
public SocketGuild Guild { get; }
|
|
public string Name { get; private set; }
|
|
public int Position { get; private set; }
|
|
|
|
public IReadOnlyCollection<Overwrite> PermissionOverwrites => _overwrites;
|
|
public new virtual IReadOnlyCollection<SocketGuildUser> Users => ImmutableArray.Create<SocketGuildUser>();
|
|
|
|
internal SocketGuildChannel(DiscordSocketClient discord, ulong id, SocketGuild guild)
|
|
: base(discord, id)
|
|
{
|
|
Guild = guild;
|
|
}
|
|
internal static SocketGuildChannel Create(SocketGuild guild, ClientState state, Model model)
|
|
{
|
|
switch (model.Type)
|
|
{
|
|
case ChannelType.Text:
|
|
return SocketTextChannel.Create(guild, state, model);
|
|
case ChannelType.Voice:
|
|
return SocketVoiceChannel.Create(guild, state, model);
|
|
default:
|
|
// TODO: Proper implementation for channel categories
|
|
return new SocketGuildChannel(guild.Discord, model.Id, guild);
|
|
}
|
|
}
|
|
internal override void Update(ClientState state, Model model)
|
|
{
|
|
Name = model.Name.Value;
|
|
Position = model.Position.Value;
|
|
|
|
var overwrites = model.PermissionOverwrites.Value;
|
|
var newOverwrites = ImmutableArray.CreateBuilder<Overwrite>(overwrites.Length);
|
|
for (int i = 0; i < overwrites.Length; i++)
|
|
newOverwrites.Add(overwrites[i].ToEntity());
|
|
_overwrites = newOverwrites.ToImmutable();
|
|
}
|
|
|
|
public Task ModifyAsync(Action<GuildChannelProperties> func, RequestOptions options = null)
|
|
=> ChannelHelper.ModifyAsync(this, Discord, func, options);
|
|
public Task DeleteAsync(RequestOptions options = null)
|
|
=> ChannelHelper.DeleteAsync(this, Discord, options);
|
|
|
|
public OverwritePermissions? GetPermissionOverwrite(IUser user)
|
|
{
|
|
for (int i = 0; i < _overwrites.Length; i++)
|
|
{
|
|
if (_overwrites[i].TargetId == user.Id)
|
|
return _overwrites[i].Permissions;
|
|
}
|
|
return null;
|
|
}
|
|
public OverwritePermissions? GetPermissionOverwrite(IRole role)
|
|
{
|
|
for (int i = 0; i < _overwrites.Length; i++)
|
|
{
|
|
if (_overwrites[i].TargetId == role.Id)
|
|
return _overwrites[i].Permissions;
|
|
}
|
|
return null;
|
|
}
|
|
public async Task AddPermissionOverwriteAsync(IUser user, OverwritePermissions perms, RequestOptions options = null)
|
|
{
|
|
await ChannelHelper.AddPermissionOverwriteAsync(this, Discord, user, perms, options).ConfigureAwait(false);
|
|
_overwrites = _overwrites.Add(new Overwrite(user.Id, PermissionTarget.User, new OverwritePermissions(perms.AllowValue, perms.DenyValue)));
|
|
}
|
|
public async Task AddPermissionOverwriteAsync(IRole role, OverwritePermissions perms, RequestOptions options = null)
|
|
{
|
|
await ChannelHelper.AddPermissionOverwriteAsync(this, Discord, role, perms, options).ConfigureAwait(false);
|
|
_overwrites = _overwrites.Add(new Overwrite(role.Id, PermissionTarget.Role, new OverwritePermissions(perms.AllowValue, perms.DenyValue)));
|
|
}
|
|
public async Task RemovePermissionOverwriteAsync(IUser user, RequestOptions options = null)
|
|
{
|
|
await ChannelHelper.RemovePermissionOverwriteAsync(this, Discord, user, options).ConfigureAwait(false);
|
|
|
|
for (int i = 0; i < _overwrites.Length; i++)
|
|
{
|
|
if (_overwrites[i].TargetId == user.Id)
|
|
{
|
|
_overwrites = _overwrites.RemoveAt(i);
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
public async Task RemovePermissionOverwriteAsync(IRole role, RequestOptions options = null)
|
|
{
|
|
await ChannelHelper.RemovePermissionOverwriteAsync(this, Discord, role, options).ConfigureAwait(false);
|
|
|
|
for (int i = 0; i < _overwrites.Length; i++)
|
|
{
|
|
if (_overwrites[i].TargetId == role.Id)
|
|
{
|
|
_overwrites = _overwrites.RemoveAt(i);
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
|
|
public async Task<IReadOnlyCollection<RestInviteMetadata>> GetInvitesAsync(RequestOptions options = null)
|
|
=> await ChannelHelper.GetInvitesAsync(this, Discord, options).ConfigureAwait(false);
|
|
public async Task<RestInviteMetadata> CreateInviteAsync(int? maxAge = 3600, int? maxUses = null, bool isTemporary = false, bool isUnique = false, RequestOptions options = null)
|
|
=> await ChannelHelper.CreateInviteAsync(this, Discord, maxAge, maxUses, isTemporary, isUnique, options).ConfigureAwait(false);
|
|
|
|
public new virtual SocketGuildUser GetUser(ulong id) => null;
|
|
|
|
public override string ToString() => Name;
|
|
internal new SocketGuildChannel Clone() => MemberwiseClone() as SocketGuildChannel;
|
|
|
|
//SocketChannel
|
|
internal override IReadOnlyCollection<SocketUser> GetUsersInternal() => Users;
|
|
internal override SocketUser GetUserInternal(ulong id) => GetUser(id);
|
|
|
|
//IGuildChannel
|
|
IGuild IGuildChannel.Guild => Guild;
|
|
ulong IGuildChannel.GuildId => Guild.Id;
|
|
|
|
async Task<IReadOnlyCollection<IInviteMetadata>> IGuildChannel.GetInvitesAsync(RequestOptions options)
|
|
=> await GetInvitesAsync(options).ConfigureAwait(false);
|
|
async Task<IInviteMetadata> IGuildChannel.CreateInviteAsync(int? maxAge, int? maxUses, bool isTemporary, bool isUnique, RequestOptions options)
|
|
=> await CreateInviteAsync(maxAge, maxUses, isTemporary, isUnique, options).ConfigureAwait(false);
|
|
|
|
OverwritePermissions? IGuildChannel.GetPermissionOverwrite(IRole role)
|
|
=> GetPermissionOverwrite(role);
|
|
OverwritePermissions? IGuildChannel.GetPermissionOverwrite(IUser user)
|
|
=> GetPermissionOverwrite(user);
|
|
async Task IGuildChannel.AddPermissionOverwriteAsync(IRole role, OverwritePermissions permissions, RequestOptions options)
|
|
=> await AddPermissionOverwriteAsync(role, permissions, options).ConfigureAwait(false);
|
|
async Task IGuildChannel.AddPermissionOverwriteAsync(IUser user, OverwritePermissions permissions, RequestOptions options)
|
|
=> await AddPermissionOverwriteAsync(user, permissions, options).ConfigureAwait(false);
|
|
async Task IGuildChannel.RemovePermissionOverwriteAsync(IRole role, RequestOptions options)
|
|
=> await RemovePermissionOverwriteAsync(role, options).ConfigureAwait(false);
|
|
async Task IGuildChannel.RemovePermissionOverwriteAsync(IUser user, RequestOptions options)
|
|
=> await RemovePermissionOverwriteAsync(user, options).ConfigureAwait(false);
|
|
|
|
IAsyncEnumerable<IReadOnlyCollection<IGuildUser>> IGuildChannel.GetUsersAsync(CacheMode mode, RequestOptions options)
|
|
=> ImmutableArray.Create<IReadOnlyCollection<IGuildUser>>(Users).ToAsyncEnumerable();
|
|
Task<IGuildUser> IGuildChannel.GetUserAsync(ulong id, CacheMode mode, RequestOptions options)
|
|
=> Task.FromResult<IGuildUser>(GetUser(id));
|
|
|
|
//IChannel
|
|
IAsyncEnumerable<IReadOnlyCollection<IUser>> IChannel.GetUsersAsync(CacheMode mode, RequestOptions options)
|
|
=> ImmutableArray.Create<IReadOnlyCollection<IUser>>(Users).ToAsyncEnumerable(); //Overriden in Text/Voice
|
|
Task<IUser> IChannel.GetUserAsync(ulong id, CacheMode mode, RequestOptions options)
|
|
=> Task.FromResult<IUser>(GetUser(id)); //Overriden in Text/Voice
|
|
}
|
|
}
|