sharp-chat/SharpChat.Protocol.SockChat/Commands/CreateChannelCommand.cs

72 lines
2.7 KiB
C#
Raw Permalink Normal View History

2022-08-30 15:05:29 +00:00
using SharpChat.Channels;
using SharpChat.Protocol.SockChat.Packets;
using SharpChat.Users;
using System;
using System.Collections.Generic;
using System.Linq;
namespace SharpChat.Protocol.SockChat.Commands {
public class CreateChannelCommand : ICommand {
private const string NAME = @"create";
private ChannelManager Channels { get; }
private ChannelUserRelations ChannelUsers { get; }
private IUser Sender { get; }
public CreateChannelCommand(ChannelManager channels, ChannelUserRelations channelUsers, IUser sender) {
Channels = channels ?? throw new ArgumentNullException(nameof(channels));
ChannelUsers = channelUsers ?? throw new ArgumentNullException(nameof(channelUsers));
Sender = sender ?? throw new ArgumentNullException(nameof(sender));
}
public bool IsCommandMatch(string name, IEnumerable<string> args)
=> name == NAME;
public bool DispatchCommand(CommandContext ctx) {
if(!ctx.User.Can(UserPermissions.CreateChannel)) {
ctx.Connection.SendPacket(new CommandNotAllowedErrorPacket(Sender, ctx.Args));
return true;
}
bool hasRank;
if(ctx.Args.Count() < 2 || (hasRank = ctx.Args.ElementAtOrDefault(1)?.All(char.IsDigit) == true && ctx.Args.Count() < 3)) {
ctx.Connection.SendPacket(new CommandFormatErrorPacket(Sender));
return true;
}
int rank = 0;
if(hasRank && !int.TryParse(ctx.Args.ElementAtOrDefault(1), out rank) && rank < 0)
rank = 0;
if(rank > ctx.User.Rank) {
ctx.Connection.SendPacket(new InsufficientRankErrorPacket(Sender));
return true;
}
string createChanName = string.Join('_', ctx.Args.Skip(hasRank ? 2 : 1));
IChannel createChan;
try {
createChan = Channels.Create(
ctx.User,
createChanName,
null,
!ctx.User.Can(UserPermissions.SetChannelPermanent),
rank
);
} catch(ChannelExistException) {
ctx.Connection.SendPacket(new ChannelExistsErrorPacket(Sender, createChanName));
return true;
} catch(ChannelInvalidNameException) {
ctx.Connection.SendPacket(new ChannelNameFormatErrorPacket(Sender));
return true;
}
ChannelUsers.JoinChannel(createChan, ctx.Session);
ctx.Connection.SendPacket(new ChannelCreateResponsePacket(Sender, createChan));
return true;
}
}
}