State tracking refactor completer.

This commit is contained in:
Alex Bramley 2011-10-06 23:54:34 +01:00
parent e36caa3a3d
commit 7a17ee9eb5
1 changed files with 72 additions and 36 deletions

View File

@ -14,8 +14,11 @@ import (
type StateTracker interface { type StateTracker interface {
NewNick(nick string) *Nick NewNick(nick string) *Nick
GetNick(nick string) *Nick GetNick(nick string) *Nick
ReNick(old, neu string)
DelNick(nick string)
NewChannel(channel string) *Channel NewChannel(channel string) *Channel
GetChannel(channel string) *Channel GetChannel(channel string) *Channel
DelChannel(channel string)
IsOn(channel, nick string) bool IsOn(channel, nick string) bool
} }
@ -25,6 +28,8 @@ type stateTracker struct {
chans map[string]*Channel chans map[string]*Channel
// Map of nicks we know about // Map of nicks we know about
nicks map[string]*Nick nicks map[string]*Nick
// When tracking state, it helps to know who we are.
Me *Nick
} }
@ -32,7 +37,7 @@ type stateTracker struct {
type Channel struct { type Channel struct {
Name, Topic string Name, Topic string
Modes *ChanMode Modes *ChanMode
Nicks map[*Nick]*ChanPrivs nicks map[*Nick]*ChanPrivs
st StateTracker st StateTracker
} }
@ -40,7 +45,7 @@ type Channel struct {
type Nick struct { type Nick struct {
Nick, Ident, Host, Name string Nick, Ident, Host, Name string
Modes *NickMode Modes *NickMode
Channels map[*Channel]*ChanPrivs chans map[*Channel]*ChanPrivs
st StateTracker st StateTracker
} }
@ -99,6 +104,23 @@ func (st *stateTracker) GetNick(n string) *Nick {
return nil return nil
} }
// Signals to the tracking code that the *irc.Nick object should be tracked
// under a "neu" nick rather than the old one.
func (st *stateTracker) ReNick(old, neu string) {
if n, ok := st.nicks[old]; ok {
st.nicks[old] = nil, false
n.Nick = neu
st.nicks[neu] = n
}
}
// Removes a nick from being tracked.
func (st *stateTracker) DelNick(n string) {
if _, ok := st.nicks[n]; ok {
st.nicks[n] = nil, false
}
}
// Creates a new *irc.Channel, initialises it, and stores it so it // Creates a new *irc.Channel, initialises it, and stores it so it
// can be properly tracked for state management purposes. // can be properly tracked for state management purposes.
func (st *stateTracker) NewChannel(c string) *Channel { func (st *stateTracker) NewChannel(c string) *Channel {
@ -116,50 +138,72 @@ func (st *stateTracker) GetChannel(c string) *Channel {
return nil return nil
} }
// Removes a channel from being tracked.
func (st *stateTracker) DelChannel(c string) {
if _, ok := st.chans[c]; ok {
st.chans[c] = nil, false
}
}
func (st *stateTracker) IsOn(c, n string) bool {
nk := st.GetNick(n)
ch := st.GetChannel(c)
if nk != nil && ch != nil {
return nk.IsOn(ch)
}
return false
}
/******************************************************************************\ /******************************************************************************\
* Channel methods for state management * Channel methods for state management
\******************************************************************************/ \******************************************************************************/
func (ch *Channel) initialise() { func (ch *Channel) initialise() {
ch.Modes = new(ChanMode) ch.Modes = new(ChanMode)
ch.Nicks = make(map[*Nick]*ChanPrivs) ch.nicks = make(map[*Nick]*ChanPrivs)
} }
// Associates an *irc.Nick with an *irc.Channel using a shared *irc.ChanPrivs // Associates an *irc.Nick with an *irc.Channel using a shared *irc.ChanPrivs
func (ch *Channel) AddNick(n *Nick) { func (ch *Channel) AddNick(n *Nick) {
if _, ok := ch.Nicks[n]; !ok { if _, ok := ch.nicks[n]; !ok {
ch.Nicks[n] = new(ChanPrivs) ch.nicks[n] = new(ChanPrivs)
n.Channels[ch] = ch.Nicks[n] n.chans[ch] = ch.nicks[n]
} else { } else {
logging.Warn("irc.Channel.AddNick(): trying to add already-present "+ logging.Warn("Channel.AddNick(): trying to add already-present "+
"nick %s to channel %s", n.Nick, ch.Name) "nick %s to channel %s", n.Nick, ch.Name)
} }
} }
// Returns true if the *irc.Nick n is associated with the *irc.Channel
func (ch *Channel) IsOn(n *Nick) bool {
_, ok := ch.nicks[nk]
return ok
}
// Disassociates an *irc.Nick from an *irc.Channel. Will call ch.Delete() if // Disassociates an *irc.Nick from an *irc.Channel. Will call ch.Delete() if
// the *irc.Nick being removed is the connection's nick. Will also call // the *irc.Nick being removed is the connection's nick. Will also call
// n.DelChannel(ch) to remove the association from the perspective of *irc.Nick. // n.DelChannel(ch) to remove the association from the perspective of *irc.Nick.
func (ch *Channel) DelNick(n *Nick) { func (ch *Channel) DelNick(n *Nick) {
if _, ok := ch.Nicks[n]; ok { if _, ok := ch.nicks[n]; ok {
if n == n.conn.Me { if n == n.st.Me {
// we're leaving the channel, so remove all state we have about it // we're leaving the channel, so remove all state we have about it
ch.Delete() ch.Delete()
} else { } else {
ch.Nicks[n] = nil, false ch.nicks[n] = nil, false
n.DelChannel(ch) n.DelChannel(ch)
} }
} // no else here ... } // no else here ...
// we call Channel.DelNick() and Nick.DelChan() from each other to ensure // we call Channel.DelNick() and Nick.DelChannel() from each other to ensure
// consistency, and this would mean spewing an error message every delete // consistency, and this would mean spewing an error message every delete
} }
// Stops the channel from being tracked by state tracking handlers. Also calls // Stops the channel from being tracked by state tracking handlers. Also calls
// n.DelChannel(ch) for all nicks that are associated with the channel. // n.DelChannel(ch) for all nicks that are associated with the channel.
func (ch *Channel) Delete() { func (ch *Channel) Delete() {
for n, _ := range ch.Nicks { for n, _ := range ch.nicks {
n.DelChannel(ch) n.DelChannel(ch)
} }
ch.conn.chans[ch.Name] = nil, false ch.st.DelChannel(ch.Name)
} }
// Parses mode strings for a channel // Parses mode strings for a channel
@ -212,7 +256,7 @@ func (ch *Channel) ParseModes(modes string, modeargs []string) {
case 'q', 'a', 'o', 'h', 'v': case 'q', 'a', 'o', 'h', 'v':
if len(modeargs) != 0 { if len(modeargs) != 0 {
n := ch.st.GetNick(modeargs[0]) n := ch.st.GetNick(modeargs[0])
if p, ok := ch.Nicks[n]; ok && n != nil { if p, ok := ch.nicks[n]; ok {
switch m { switch m {
case 'q': case 'q':
p.Owner = modeop p.Owner = modeop
@ -244,7 +288,7 @@ func (ch *Channel) ParseModes(modes string, modeargs []string) {
\******************************************************************************/ \******************************************************************************/
func (n *Nick) initialise() { func (n *Nick) initialise() {
n.Modes = new(NickMode) n.Modes = new(NickMode)
n.Channels = make(map[*Channel]*ChanPrivs) n.chans = make(map[*Channel]*ChanPrivs)
} }
// Associates an *irc.Channel with an *irc.Nick using a shared *irc.ChanPrivs // Associates an *irc.Channel with an *irc.Nick using a shared *irc.ChanPrivs
@ -253,11 +297,11 @@ func (n *Nick) initialise() {
// pre-existing association within the *irc.Nick object rather than the // pre-existing association within the *irc.Nick object rather than the
// *irc.Channel object before associating the two. // *irc.Channel object before associating the two.
func (n *Nick) AddChannel(ch *Channel) { func (n *Nick) AddChannel(ch *Channel) {
if _, ok := n.Channels[ch]; !ok { if _, ok := n.chans[ch]; !ok {
ch.Nicks[n] = new(ChanPrivs) ch.nicks[n] = new(ChanPrivs)
n.Channels[ch] = ch.Nicks[n] n.chans[ch] = ch.nicks[n]
} else { } else {
logging.Warn("irc.Nick.AddChannel(): trying to add already-present "+ logging.Warn("Nick.AddChannel(): trying to add already-present "+
"channel %s to nick %s", ch.Name, n.Nick) "channel %s to nick %s", ch.Name, n.Nick)
} }
} }
@ -266,33 +310,25 @@ func (n *Nick) AddChannel(ch *Channel) {
// the *irc.Nick is no longer on any channels we are tracking. Will also call // the *irc.Nick is no longer on any channels we are tracking. Will also call
// ch.DelNick(n) to remove the association from the perspective of *irc.Channel. // ch.DelNick(n) to remove the association from the perspective of *irc.Channel.
func (n *Nick) DelChannel(ch *Channel) { func (n *Nick) DelChannel(ch *Channel) {
if _, ok := n.Channels[ch]; ok { if _, ok := n.chans[ch]; ok {
n.Channels[ch] = nil, false n.chans[ch] = nil, false
ch.DelNick(n) ch.DelNick(n)
if len(n.Channels) == 0 { if len(n.chans) == 0 {
// nick is no longer in any channels we inhabit, stop tracking it // nick is no longer in any channels we inhabit, stop tracking it
n.Delete() n.Delete()
} }
} }
} }
// Signals to the tracking code that the *irc.Nick object should be tracked
// under a "neu" nick rather than the old one.
func (n *Nick) ReNick(neu string) {
n.conn.nicks[n.Nick] = nil, false
n.Nick = neu
n.conn.nicks[n.Nick] = n
}
// Stops the nick from being tracked by state tracking handlers. Also calls // Stops the nick from being tracked by state tracking handlers. Also calls
// ch.DelNick(n) for all nicks that are associated with the channel. // ch.DelNick(n) for all nicks that are associated with the channel.
func (n *Nick) Delete() { func (n *Nick) Delete() {
// we don't ever want to remove *our* nick from conn.nicks... // we don't ever want to remove *our* nick from st.nicks...
if n != n.conn.Me { if n != n.st.Me {
for ch, _ := range n.Channels { for ch, _ := range n.chans {
ch.DelNick(n) ch.DelNick(n)
} }
n.conn.nicks[n.Nick] = nil, false n.st.DelNick(n.Nick)
} }
} }
@ -401,7 +437,7 @@ func (ch *Channel) String() string {
str += "Topic: " + ch.Topic + "\n\t" str += "Topic: " + ch.Topic + "\n\t"
str += "Modes: " + ch.Modes.String() + "\n\t" str += "Modes: " + ch.Modes.String() + "\n\t"
str += "Nicks: \n" str += "Nicks: \n"
for n, p := range ch.Nicks { for n, p := range ch.nicks {
str += "\t\t" + n.Nick + ": " + p.String() + "\n" str += "\t\t" + n.Nick + ": " + p.String() + "\n"
} }
return str return str
@ -421,7 +457,7 @@ func (n *Nick) String() string {
str += "Real Name: " + n.Name + "\n\t" str += "Real Name: " + n.Name + "\n\t"
str += "Modes: " + n.Modes.String() + "\n\t" str += "Modes: " + n.Modes.String() + "\n\t"
str += "Channels: \n" str += "Channels: \n"
for ch, p := range n.Channels { for ch, p := range n.chans {
str += "\t\t" + ch.Name + ": " + p.String() + "\n" str += "\t\t" + ch.Name + ": " + p.String() + "\n"
} }
return str return str