readme

.hgtags

@@ -13,3 +13,5 @@ cb86f3a40115cc46f450c0c83fd9b9d3b740e820 libnmdc-r6
 b0e57a5fcffdf4102d669db51a3648ddf66a0792 libnmdc-r8
 e7c2c71ef24b386add728fad35fff4a996fccbac libnmdc-r9
 3ecc037cf2d7080572fe87c2e39ecd153fb0e947 libnmdc-r10
+5149ffe70ea8475e480b682345b31aa45a3352db release-0.11
+22b156a6fc2f6161765317f4ec9ab3731a26e0e2 release-0.12

HubConnection.go

@@ -28,6 +28,8 @@ type HubConnection struct {
 	connValid     bool
 	sentOurHello  bool
 	autoReconnect bool
+
+	supports map[string]struct{}
 }
 
 // Thread-safe user accessor.
@@ -67,10 +69,11 @@ func (this *HubConnection) UserCount() int {
 
 func (this *HubConnection) userJoined_NameOnly(nick string) {
 	if !this.UserExists(nick) {
-		this.userLock.Lock()
-		defer this.userLock.Unlock()
 
+		this.userLock.Lock()
 		this.users[nick] = *NewUserInfo(nick)
+		this.userLock.Unlock() // Don't lock over a processEvent boundary
+
 		this.processEvent(HubEvent{EventType: EVENT_USER_JOINED, Nick: nick})
 	}
 }
@@ -78,14 +81,14 @@ func (this *HubConnection) userJoined_NameOnly(nick string) {
 func (this *HubConnection) userJoined_Full(uinf *UserInfo) {
 	// n.b. also called when we get a replacement MyINFO for someone
 	this.userLock.Lock()
-	defer this.userLock.Unlock()
-
 	_, userExisted := this.users[uinf.Nick] // don't use UserExists as it would deadlock the mutex
-
 	this.users[uinf.Nick] = *uinf
+	this.userLock.Unlock() // Don't lock over a processEvent boundary
 
 	if !userExisted {
 		this.processEvent(HubEvent{EventType: EVENT_USER_JOINED, Nick: uinf.Nick})
+	} else {
+		this.processEvent(HubEvent{EventType: EVENT_USER_UPDATED_INFO, Nick: uinf.Nick})
 	}
 }
 
@@ -132,9 +135,8 @@ func (this *HubConnection) processProtocolMessage(message string) {
 	switch commandParts[0] {
 
 	case "$Lock":
-		this.SayRaw("$Supports NoGetINFO UserCommand UserIP2|" +
+		this.SayRaw("$Supports NoHello NoGetINFO UserCommand UserIP2 QuickList ChatOnly|" +
-			"$Key " + unlock([]byte(commandParts[1])) + "|" +
+			"$Key " + unlock([]byte(commandParts[1])) + "|")
-			"$ValidateNick " + Escape(this.Hco.Self.Nick) + "|")
 		this.sentOurHello = false
 
 	case "$Hello":
@@ -167,26 +169,32 @@ func (this *HubConnection) processProtocolMessage(message string) {
 		this.processEvent(HubEvent{EventType: EVENT_SYSTEM_MESSAGE_FROM_CONN, Message: "Incorrect password."})
 
 	case "$GetPass":
-		this.SayRaw("$MyPass " + Escape(this.Hco.NickPassword) + "|")
+		if len(this.Hco.NickPassword) == 0 {
+			// We've got a problem. MyPass with no arguments is a syntax error with no message = instant close
+			// Just drop the connection
+			this.processEvent(HubEvent{EventType: EVENT_SYSTEM_MESSAGE_FROM_CONN, Message: "This account is passworded."})
+			this.Disconnect()
+		} else {
+			this.SayRaw("$MyPass " + Escape(this.Hco.NickPassword) + "|")
+		}
 
 	case "$Quit":
-		func() {
+		this.userLock.Lock()
-			this.userLock.Lock()
+		delete(this.users, commandParts[1])
-			defer this.userLock.Unlock()
+		this.userLock.Unlock() // Don't lock over a processEvent boundary
 
-			delete(this.users, commandParts[1])
-		}()
 		this.processEvent(HubEvent{EventType: EVENT_USER_PART, Nick: commandParts[1]})
 
 	case "$MyINFO":
 		u := UserInfo{}
 		err := u.fromMyINFO(commandParts[1])
-		if err == nil {
+		if err != nil {
-			this.userJoined_Full(&u)
-		} else {
 			this.processEvent(HubEvent{EventType: EVENT_DEBUG_MESSAGE, Message: err.Error()})
+			return
 		}
 
+		this.userJoined_Full(&u)
+
 	case "$NickList":
 		nicklist := strings.Split(commandParts[1], "$$")
 		for _, nick := range nicklist {
@@ -237,11 +245,34 @@ func (this *HubConnection) processProtocolMessage(message string) {
 		}
 
 	case "$UserIP":
-		// Final message in PtokaX connection handshake - trigger connection callback.
+		this.userLock.Lock()
-		// This might not be the case for other hubsofts, though
+
-		if this.State != CONNECTIONSTATE_CONNECTED {
+		pairs := strings.Split(commandParts[1], "$$")
-			this.processEvent(HubEvent{EventType: EVENT_CONNECTION_STATE_CHANGED, StateChange: CONNECTIONSTATE_CONNECTED})
+		notifyOfUpdate := make([]string, 0, len(pairs))
-			this.State = CONNECTIONSTATE_CONNECTED
+
+	nextIPPair:
+		for _, pair := range pairs {
+			parts := strings.SplitN(pair, " ", 2)
+			ip2nick := parts[0]
+			ip2addr := parts[1]
+
+			uinfo, ok := this.users[ip2nick]
+			if !ok {
+				this.processEvent(HubEvent{EventType: EVENT_DEBUG_MESSAGE, Message: "Recieved IP '" + ip2addr + "' for unknown user '" + ip2nick + "'"})
+				continue nextIPPair
+			}
+
+			if uinfo.IPAddress != ip2addr {
+				uinfo.IPAddress = ip2addr
+				notifyOfUpdate = append(notifyOfUpdate, ip2nick)
+				this.users[ip2nick] = uinfo
+			}
+		}
+
+		this.userLock.Unlock()
+
+		for _, nick := range notifyOfUpdate {
+			this.processEvent(HubEvent{EventType: EVENT_USER_UPDATED_INFO, Nick: nick})
 		}
 
 	case "$ForceMove":
@@ -269,8 +300,34 @@ func (this *HubConnection) processProtocolMessage(message string) {
 			this.processEvent(HubEvent{EventType: EVENT_DEBUG_MESSAGE, Message: "Malformed usercommand '" + commandParts[1] + "'"})
 		}
 
-	// IGNORABLE COMMANDS
 	case "$Supports":
+		this.supports = make(map[string]struct{})
+		for _, s := range strings.Split(commandParts[1], " ") {
+			this.supports[s] = struct{}{}
+		}
+
+		if !this.sentOurHello {
+
+			// Need to log in.
+			// If the hub supports QuickList, we can skip one network roundtrip
+			if _, ok := this.supports["QuickList"]; ok {
+				this.SayInfo()
+				this.SayRaw("$GetNickList|")
+			} else {
+				this.SayRaw("$ValidateNick " + Escape(this.Hco.Self.Nick) + "|")
+			}
+
+			// This also counts as the end of the handshake from our POV. Consider
+			// ourselves logged in
+			this.sentOurHello = true
+			if this.State != CONNECTIONSTATE_CONNECTED {
+				this.processEvent(HubEvent{EventType: EVENT_CONNECTION_STATE_CHANGED, StateChange: CONNECTIONSTATE_CONNECTED})
+				this.State = CONNECTIONSTATE_CONNECTED
+			}
+
+		}
+
+	// IGNORABLE COMMANDS
 	case "$HubTopic":
 	case "$Search":
 	case "$ConnectToMe":

TODO.txt

@@ -0,0 +1 @@
+- Implement ZPipe ($ZOn)

UserInfo.go

@@ -24,6 +24,7 @@ type UserInfo struct {
 	HubsRegistered   uint64
 	HubsOperator     uint64
 	IsOperator       bool
+	IPAddress        string
 }
 
 var rx_myinfo *regexp.Regexp

__dist/README.txt

@@ -9,6 +9,25 @@ Tags: nmdc
 
 =CHANGELOG=
 
+2017-02-09 0.13
+- Feature: Implement UserIP2 extension, to retrieve IP addresses of other users
+- Enhancement: Implement QuickList extension (reduce one network roundtrip during initial connection)
+- Enhancement: Implement NoHello extension (faster connection performance)
+- Enhancement: Implement ChatOnly extension
+- Fix an issue with not notifying client on all MyINFO updates
+
+2017-02-05 0.12
+- Fix an issue with mutex deadlock when accessing user information from a callback
+- Fix an issue with silent disconnection if a password was required but not present
+
+2016-11-29 0.11
+- BREAKING: Remove some exported methods
+- BREAKING: Fix an issue with missing sufficient parameters in the synchronous API
+- Enhancement: Improve output under godoc
+- Fix an issue with special characters appearing in recieved private messages
+- Fix an issue with parsing active/passive connection modes
+- Fix an issue with errors appearing on stdout
+
 2016-10-08 r10
 - Feature: Support `$UserCommand`