mirror of
https://github.com/ergochat/ergo.git
synced 2024-11-22 20:09:41 +01:00
461 lines
11 KiB
Go
461 lines
11 KiB
Go
// Copyright (c) 2012-2014 Jeremy Latt
|
|
// Copyright (c) 2014-2015 Edmund Huber
|
|
// Copyright (c) 2016- Daniel Oaks <daniel@danieloaks.net>
|
|
// released under the MIT license
|
|
|
|
package irc
|
|
|
|
import (
|
|
"fmt"
|
|
"strconv"
|
|
"strings"
|
|
|
|
"github.com/DanielOaks/girc-go/ircmsg"
|
|
)
|
|
|
|
// user mode flags
|
|
type UserMode rune
|
|
|
|
func (mode UserMode) String() string {
|
|
return string(mode)
|
|
}
|
|
|
|
type UserModes []UserMode
|
|
|
|
func (modes UserModes) String() string {
|
|
strs := make([]string, len(modes))
|
|
for index, mode := range modes {
|
|
strs[index] = mode.String()
|
|
}
|
|
return strings.Join(strs, "")
|
|
}
|
|
|
|
type ModeChange struct {
|
|
mode UserMode
|
|
op ModeOp
|
|
}
|
|
|
|
func (change *ModeChange) String() string {
|
|
return fmt.Sprintf("%s%s", change.op, change.mode)
|
|
}
|
|
|
|
type ModeChanges []*ModeChange
|
|
|
|
func (changes ModeChanges) String() string {
|
|
if len(changes) == 0 {
|
|
return ""
|
|
}
|
|
|
|
op := changes[0].op
|
|
str := changes[0].op.String()
|
|
for _, change := range changes {
|
|
if change.op != op {
|
|
op = change.op
|
|
str += change.op.String()
|
|
}
|
|
str += change.mode.String()
|
|
}
|
|
return str
|
|
}
|
|
|
|
// channel mode flags
|
|
type ChannelMode rune
|
|
|
|
func (mode ChannelMode) String() string {
|
|
return string(mode)
|
|
}
|
|
|
|
type ChannelModes []ChannelMode
|
|
|
|
func (modes ChannelModes) String() string {
|
|
strs := make([]string, len(modes))
|
|
for index, mode := range modes {
|
|
strs[index] = mode.String()
|
|
}
|
|
return strings.Join(strs, "")
|
|
}
|
|
|
|
type ChannelModeChange struct {
|
|
mode ChannelMode
|
|
op ModeOp
|
|
arg string
|
|
}
|
|
|
|
func (change *ChannelModeChange) String() (str string) {
|
|
if (change.op == Add) || (change.op == Remove) {
|
|
str = change.op.String()
|
|
}
|
|
str += change.mode.String()
|
|
if change.arg != "" {
|
|
str += " " + change.arg
|
|
}
|
|
return
|
|
}
|
|
|
|
type ChannelModeChanges []*ChannelModeChange
|
|
|
|
func (changes ChannelModeChanges) String() string {
|
|
if len(changes) == 0 {
|
|
return ""
|
|
}
|
|
|
|
op := changes[0].op
|
|
str := changes[0].op.String()
|
|
|
|
for _, change := range changes {
|
|
if change.op != op {
|
|
op = change.op
|
|
str += change.op.String()
|
|
}
|
|
str += change.mode.String()
|
|
}
|
|
|
|
for _, change := range changes {
|
|
if change.arg == "" {
|
|
continue
|
|
}
|
|
str += " " + change.arg
|
|
}
|
|
return str
|
|
}
|
|
|
|
type ChannelModeCommand struct {
|
|
channel Name
|
|
changes ChannelModeChanges
|
|
}
|
|
|
|
type ModeOp rune
|
|
|
|
func (op ModeOp) String() string {
|
|
return string(op)
|
|
}
|
|
|
|
const (
|
|
Add ModeOp = '+'
|
|
List ModeOp = '='
|
|
Remove ModeOp = '-'
|
|
)
|
|
|
|
const (
|
|
Away UserMode = 'a'
|
|
Invisible UserMode = 'i'
|
|
LocalOperator UserMode = 'O'
|
|
Operator UserMode = 'o'
|
|
Restricted UserMode = 'r'
|
|
ServerNotice UserMode = 's' // deprecated
|
|
TLS UserMode = 'Z'
|
|
WallOps UserMode = 'w'
|
|
)
|
|
|
|
var (
|
|
SupportedUserModes = UserModes{
|
|
Away, Invisible, Operator,
|
|
}
|
|
// supportedUserModesString acts as a cache for when we introduce users
|
|
supportedUserModesString = SupportedUserModes.String()
|
|
)
|
|
|
|
const (
|
|
ChannelFounder ChannelMode = 'q' // arg
|
|
ChannelAdmin ChannelMode = 'a' // arg
|
|
ChannelOperator ChannelMode = 'o' // arg
|
|
Halfop ChannelMode = 'h' // arg
|
|
Voice ChannelMode = 'v' // arg
|
|
|
|
BanMask ChannelMode = 'b' // arg
|
|
ExceptMask ChannelMode = 'e' // arg
|
|
InviteMask ChannelMode = 'I' // arg
|
|
InviteOnly ChannelMode = 'i' // flag
|
|
Key ChannelMode = 'k' // flag arg
|
|
Moderated ChannelMode = 'm' // flag
|
|
NoOutside ChannelMode = 'n' // flag
|
|
OpOnlyTopic ChannelMode = 't' // flag
|
|
Persistent ChannelMode = 'P' // flag
|
|
ReOp ChannelMode = 'r' // flag
|
|
Secret ChannelMode = 's' // flag
|
|
Theater ChannelMode = 'T' // flag, nonstandard
|
|
UserLimit ChannelMode = 'l' // flag arg
|
|
)
|
|
|
|
var (
|
|
SupportedChannelModes = ChannelModes{
|
|
BanMask, ExceptMask, InviteMask, InviteOnly, Key, NoOutside,
|
|
OpOnlyTopic, Persistent, Secret, Theater, UserLimit,
|
|
}
|
|
// supportedChannelModesString acts as a cache for when we introduce users
|
|
supportedChannelModesString = SupportedChannelModes.String()
|
|
|
|
DefaultChannelModes = ChannelModes{
|
|
NoOutside, OpOnlyTopic,
|
|
}
|
|
|
|
// ChannelPrivModes holds the list of modes that are privileged, ie founder/op/halfop, in order.
|
|
// voice is not in this list because it cannot perform channel operator actions.
|
|
ChannelPrivModes = ChannelModes{
|
|
ChannelFounder, ChannelAdmin, ChannelOperator, Halfop,
|
|
}
|
|
|
|
ChannelModePrefixes = map[ChannelMode]string{
|
|
ChannelFounder: "~",
|
|
ChannelAdmin: "&",
|
|
ChannelOperator: "@",
|
|
Halfop: "%",
|
|
Voice: "+",
|
|
}
|
|
)
|
|
|
|
//
|
|
// commands
|
|
//
|
|
|
|
// MODE <target> [<modestring> [<mode arguments>...]]
|
|
func modeHandler(server *Server, client *Client, msg ircmsg.IrcMessage) bool {
|
|
name := NewName(msg.Params[0])
|
|
if name.IsChannel() {
|
|
return cmodeHandler(server, client, msg)
|
|
} else {
|
|
return umodeHandler(server, client, msg)
|
|
}
|
|
}
|
|
|
|
// MODE <target> [<modestring> [<mode arguments>...]]
|
|
func umodeHandler(server *Server, client *Client, msg ircmsg.IrcMessage) bool {
|
|
nickname := NewName(msg.Params[0])
|
|
|
|
target := server.clients.Get(nickname)
|
|
|
|
if target == nil {
|
|
client.Send(nil, server.nameString, ERR_NOSUCHNICK, client.nickString, msg.Params[0], "No such nick")
|
|
return false
|
|
}
|
|
|
|
//TODO(dan): restricting to Operator here should be done with SAMODE only
|
|
// point SAMODE at this handler too, if they are operator and SAMODE was called then fine
|
|
if client != target && !client.flags[Operator] {
|
|
if len(msg.Params) > 1 {
|
|
client.Send(nil, server.nameString, ERR_USERSDONTMATCH, client.nickString, "Can't change modes for other users")
|
|
} else {
|
|
client.Send(nil, server.nameString, ERR_USERSDONTMATCH, client.nickString, "Can't view modes for other users")
|
|
}
|
|
return false
|
|
}
|
|
|
|
// assemble changes
|
|
changes := make(ModeChanges, 0)
|
|
applied := make(ModeChanges, 0)
|
|
|
|
if len(msg.Params) > 1 {
|
|
modeArg := msg.Params[1]
|
|
op := ModeOp(modeArg[0])
|
|
if (op == Add) || (op == Remove) {
|
|
modeArg = modeArg[1:]
|
|
} else {
|
|
client.Send(nil, server.nameString, ERR_UNKNOWNMODE, client.nickString, string(modeArg[1]), "is an unknown mode character to me")
|
|
return false
|
|
}
|
|
|
|
for _, mode := range modeArg {
|
|
if mode == '-' || mode == '+' {
|
|
op = ModeOp(mode)
|
|
continue
|
|
}
|
|
changes = append(changes, &ModeChange{
|
|
mode: UserMode(mode),
|
|
op: op,
|
|
})
|
|
}
|
|
|
|
for _, change := range changes {
|
|
switch change.mode {
|
|
case Invisible, ServerNotice, WallOps:
|
|
switch change.op {
|
|
case Add:
|
|
if target.flags[change.mode] {
|
|
continue
|
|
}
|
|
target.flags[change.mode] = true
|
|
applied = append(applied, change)
|
|
|
|
case Remove:
|
|
if !target.flags[change.mode] {
|
|
continue
|
|
}
|
|
delete(target.flags, change.mode)
|
|
applied = append(applied, change)
|
|
}
|
|
|
|
case Operator, LocalOperator:
|
|
if change.op == Remove {
|
|
if !target.flags[change.mode] {
|
|
continue
|
|
}
|
|
delete(target.flags, change.mode)
|
|
applied = append(applied, change)
|
|
}
|
|
}
|
|
|
|
// can't do anything to TLS mode
|
|
}
|
|
}
|
|
|
|
if len(applied) > 0 {
|
|
client.Send(nil, client.nickMaskString, "MODE", target.nickString, applied.String())
|
|
} else if client == target {
|
|
client.Send(nil, target.nickMaskString, RPL_UMODEIS, target.nickString, target.ModeString())
|
|
}
|
|
return false
|
|
}
|
|
|
|
// MODE <target> [<modestring> [<mode arguments>...]]
|
|
func cmodeHandler(server *Server, client *Client, msg ircmsg.IrcMessage) bool {
|
|
channelName := NewName(msg.Params[0])
|
|
channel := server.channels.Get(channelName)
|
|
|
|
if channel == nil {
|
|
client.Send(nil, server.nameString, ERR_NOSUCHCHANNEL, client.nickString, msg.Params[0], "No such channel")
|
|
return false
|
|
}
|
|
|
|
// assemble changes
|
|
//TODO(dan): split out assembling changes into func that returns changes, err
|
|
changes := make(ChannelModeChanges, 0)
|
|
applied := make(ChannelModeChanges, 0)
|
|
|
|
// TODO(dan): look at separating these into the type A/B/C/D args and using those lists here
|
|
if len(msg.Params) > 1 {
|
|
modeArg := msg.Params[1]
|
|
op := ModeOp(modeArg[0])
|
|
if (op == Add) || (op == Remove) {
|
|
modeArg = modeArg[1:]
|
|
} else {
|
|
client.Send(nil, server.nameString, ERR_UNKNOWNMODE, client.nickString, string(modeArg[1]), "is an unknown mode character to me")
|
|
return false
|
|
}
|
|
|
|
skipArgs := 2
|
|
for _, mode := range modeArg {
|
|
if mode == '-' || mode == '+' {
|
|
op = ModeOp(mode)
|
|
continue
|
|
}
|
|
change := ChannelModeChange{
|
|
mode: ChannelMode(mode),
|
|
op: op,
|
|
}
|
|
|
|
// put arg into modechange if needed
|
|
switch ChannelMode(mode) {
|
|
case BanMask, ExceptMask, InviteMask:
|
|
if len(msg.Params) > skipArgs {
|
|
change.arg = msg.Params[skipArgs]
|
|
skipArgs += 1
|
|
} else {
|
|
change.op = List
|
|
}
|
|
case Key, UserLimit, ChannelFounder, ChannelAdmin, ChannelOperator, Halfop, Voice:
|
|
if len(msg.Params) > skipArgs {
|
|
change.arg = msg.Params[skipArgs]
|
|
skipArgs += 1
|
|
} else {
|
|
continue
|
|
}
|
|
}
|
|
|
|
applied = append(applied, &change)
|
|
}
|
|
|
|
for _, change := range changes {
|
|
switch change.mode {
|
|
case BanMask, ExceptMask, InviteMask:
|
|
mask := change.arg
|
|
list := channel.lists[change.mode]
|
|
if list == nil {
|
|
// This should never happen, but better safe than panicky.
|
|
client.Send(nil, server.nameString, ERR_UNKNOWNERROR, client.nickString, "MODE", "Could not complete MODE command")
|
|
return false
|
|
}
|
|
|
|
if (change.op == List) || (mask == "") {
|
|
channel.ShowMaskList(client, change.mode)
|
|
continue
|
|
}
|
|
|
|
switch change.op {
|
|
case Add:
|
|
list.Add(Name(mask))
|
|
applied = append(applied, change)
|
|
|
|
case Remove:
|
|
list.Remove(Name(mask))
|
|
applied = append(applied, change)
|
|
}
|
|
|
|
case InviteOnly, Moderated, NoOutside, OpOnlyTopic, Persistent, Secret:
|
|
switch change.op {
|
|
case Add:
|
|
if channel.flags[change.mode] {
|
|
continue
|
|
}
|
|
channel.flags[change.mode] = true
|
|
applied = append(applied, change)
|
|
|
|
case Remove:
|
|
if !channel.flags[change.mode] {
|
|
continue
|
|
}
|
|
delete(channel.flags, change.mode)
|
|
applied = append(applied, change)
|
|
}
|
|
|
|
case ChannelFounder, ChannelAdmin, ChannelOperator, Halfop, Voice:
|
|
// make sure client has privs to edit the given prefix
|
|
var hasPrivs bool
|
|
|
|
for _, mode := range ChannelPrivModes {
|
|
if channel.members[client][mode] {
|
|
hasPrivs = true
|
|
|
|
// Admins can't give other people Admin or remove it from others,
|
|
// standard for that channel mode, we worry about this later
|
|
if mode == ChannelAdmin && change.mode == ChannelAdmin {
|
|
hasPrivs = false
|
|
}
|
|
|
|
break
|
|
} else if mode == change.mode {
|
|
break
|
|
}
|
|
}
|
|
|
|
name := NewName(change.arg)
|
|
|
|
if !hasPrivs {
|
|
if change.op == Remove && name.ToLower() == client.nick.ToLower() {
|
|
// success!
|
|
} else {
|
|
client.Send(nil, client.server.nameString, ERR_CHANOPRIVSNEEDED, channel.nameString, "You're not a channel operator")
|
|
continue
|
|
}
|
|
}
|
|
|
|
change := channel.applyModeMember(client, change.mode, change.op, change.arg)
|
|
if change != nil {
|
|
applied = append(changes, change)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if len(applied) > 0 {
|
|
//TODO(dan): we should change the name of String and make it return a slice here
|
|
args := append([]string{channel.nameString}, strings.Split(applied.String(), " ")...)
|
|
client.Send(nil, client.nickMaskString, "MODE", args...)
|
|
} else {
|
|
//TODO(dan): we should just make ModeString return a slice here
|
|
args := append([]string{client.nickString, channel.nameString}, strings.Split(channel.ModeString(client), " ")...)
|
|
client.Send(nil, client.nickMaskString, RPL_CHANNELMODEIS, args...)
|
|
client.Send(nil, client.nickMaskString, RPL_CHANNELCREATED, client.nickString, channel.nameString, strconv.FormatInt(channel.createdTime.Unix(), 10))
|
|
}
|
|
return false
|
|
}
|