readme

.hgtags

@@ -1,18 +1,19 @@
-945ab4b16d05aa084f71bf5da9a3f687e0ec8bbd libnmdc-r1
+945ab4b16d05aa084f71bf5da9a3f687e0ec8bbd v0.1.0
 02a360e95480b97ddad83add5db48b2766339a99 nmdc-log-service-1.0.0
-137c1b65039e03c80379826a6efdfd808f6fbc8f libnmdc-r2
-d8b64d5527c2a5e4d76872e5bc3d69f7646135c6 libnmdc-r3
+137c1b65039e03c80379826a6efdfd808f6fbc8f v0.2.0
+d8b64d5527c2a5e4d76872e5bc3d69f7646135c6 v0.3.0
 fca41372e400853775b02e951f9db91d87f41adb nmdc-log-service-1.0.1
-050b424a7c5d5a27c9323c8810f3afbead1f5b96 libnmdc-r4
+050b424a7c5d5a27c9323c8810f3afbead1f5b96 v0.4.0
 da9f123633f9c28be6435ed7898139665d4c39d9 nmdc-log-service-1.0.2
-75a78f6a78f249a2cd8aa3d29f7e5e6319b4e03b libnmdc-r5
+75a78f6a78f249a2cd8aa3d29f7e5e6319b4e03b v0.5.0
 4116422bb10229d887f9296970a166fa1ef8c5fd nmdc-log-service-1.0.3
 cb86f3a40115cc46f450c0c83fd9b9d3b740e820 nmdc-log-service-1.0.4
-cb86f3a40115cc46f450c0c83fd9b9d3b740e820 libnmdc-r6
-71343a2c641a438206d30ea7e75dc89a11dbef00 libnmdc-r7
-b0e57a5fcffdf4102d669db51a3648ddf66a0792 libnmdc-r8
-e7c2c71ef24b386add728fad35fff4a996fccbac libnmdc-r9
-3ecc037cf2d7080572fe87c2e39ecd153fb0e947 libnmdc-r10
-5149ffe70ea8475e480b682345b31aa45a3352db release-0.11
-22b156a6fc2f6161765317f4ec9ab3731a26e0e2 release-0.12
-3ee0f4ea5142d66079a9500bdcd48a53bdcf362f release-0.13
+cb86f3a40115cc46f450c0c83fd9b9d3b740e820 v0.6.0
+71343a2c641a438206d30ea7e75dc89a11dbef00 v0.7.0
+b0e57a5fcffdf4102d669db51a3648ddf66a0792 v0.8.0
+e7c2c71ef24b386add728fad35fff4a996fccbac v0.9.0
+3ecc037cf2d7080572fe87c2e39ecd153fb0e947 v0.10.0
+5149ffe70ea8475e480b682345b31aa45a3352db v0.11.0
+22b156a6fc2f6161765317f4ec9ab3731a26e0e2 v0.12.0
+3ee0f4ea5142d66079a9500bdcd48a53bdcf362f v0.13.0
+6422ed687cd308c339b6dc188bbe1034ed93f893 v0.14.0

Example_test.go

@@ -15,7 +15,7 @@ func ExampleHubConnectionOptions_Connect() {
 		event := <-hub.OnEvent
 		switch event.EventType {
 		case EVENT_CONNECTION_STATE_CHANGED:
-			fmt.Printf("Connection -- %s (%s)\n", event.StateChange.Format(), event.Message)
+			fmt.Printf("Connection -- %s (%s)\n", event.StateChange, event.Message)
 
 		case EVENT_PUBLIC:
 			fmt.Printf("Message from '%s': '%s'\n", event.Nick, event.Message)
@@ -34,7 +34,7 @@ func ExampleHubConnectionOptions_ConnectSync() {
 	cb := func(hub *HubConnection, event HubEvent) {
 		switch event.EventType {
 		case EVENT_CONNECTION_STATE_CHANGED:
-			fmt.Printf("Connection -- %s (%s)\n", event.StateChange.Format(), event.Message)
+			fmt.Printf("Connection -- %s (%s)\n", event.StateChange, event.Message)
 
 		case EVENT_PUBLIC:
 			fmt.Printf("Message from '%s': '%s'\n", event.Nick, event.Message)

HubConnection.go

@@ -2,6 +2,7 @@ package libnmdc
 
 import (
 	"crypto/tls"
+	"fmt"
 	"net"
 	"strconv"
 	"strings"
@@ -24,10 +25,11 @@ type HubConnection struct {
 	OnEvent      chan HubEvent
 
 	// Private state
-	conn          net.Conn // this is an interface
-	connValid     bool
-	sentOurHello  bool
-	autoReconnect bool
+	conn             net.Conn // this is an interface
+	connValid        bool
+	sentOurHello     bool
+	autoReconnect    bool
+	lastDataRecieved time.Time
 
 	supports map[string]struct{}
 }
@@ -398,6 +400,7 @@ func (this *HubConnection) worker() {
 			}
 
 			if nbytes > 0 {
+				this.lastDataRecieved = time.Now()
 				fullBuffer += string(readBuff[0:nbytes])
 			}
 		}
@@ -416,6 +419,10 @@ func (this *HubConnection) worker() {
 			}
 		}
 
+		if err == nil && time.Now().Sub(this.lastDataRecieved) > RECONNECT_IF_NO_DATA_RECIEVED_IN {
+			err = fmt.Errorf("No packets recieved since %s, connection presumed lost", this.lastDataRecieved.Format(time.RFC3339))
+		}
+
 		// Maybe we disconnected
 		// Perform this check *last*, to ensure we've had a final shot at
 		//  clearing out any queued messages

__dist/README.txt

@@ -1,14 +1,22 @@
 An NMDC client protocol library for Golang.
 
-- Offers both channel-based and synchronous APIs.
-- Includes a sample logging client using the channel-based API.
-- This code hosting site isn't (yet) compatible with `go get`.
+This package offers both channel-based and synchronous APIs. Example is included.
 
 Written in golang
 Tags: nmdc
 
+=GO GET=
+
+This package can be installed via go get: `go get code.ivysaur.me/libnmdc`
+[go-get]code.ivysaur.me/libnmdc git https://git.ivysaur.me/code.ivysaur.me/libnmdc.git[/go-get]
+
 =CHANGELOG=
 
+2017-11-14 0.15
+- Feature: Fallback reconnection if no data (not even keepalives) are recieved from the hub in 24 hours
+- Fix an issue with detecting protocol messages inside multi-line chat messages
+- Update examples and the default client version number
+
 2017-02-09 0.14
 - Fix an issue with crashing on malformed IP addresses supplied by the hub
 

libnmdc.go

@@ -9,11 +9,12 @@ import (
 )
 
 const (
-	DEFAULT_CLIENT_TAG     string        = "libnmdc.go"
-	DEFAULT_CLIENT_VERSION string        = "0.11"
-	DEFAULT_HUB_NAME       string        = "(unknown)"
-	SEND_KEEPALIVE_EVERY   time.Duration = 29 * time.Second
-	AUTO_RECONNECT_AFTER   time.Duration = 30 * time.Second
+	DEFAULT_CLIENT_TAG               string        = "libnmdc.go"
+	DEFAULT_CLIENT_VERSION           string        = "0.15"
+	DEFAULT_HUB_NAME                 string        = "(unknown)"
+	SEND_KEEPALIVE_EVERY             time.Duration = 29 * time.Second
+	AUTO_RECONNECT_AFTER             time.Duration = 30 * time.Second
+	RECONNECT_IF_NO_DATA_RECIEVED_IN time.Duration = 24 * time.Hour // we expect keepalives wayyyy more frequently than this
 )
 
 var rx_protocolMessage *regexp.Regexp
@@ -23,10 +24,13 @@ var rx_userCommand *regexp.Regexp
 var ErrNotConnected error = errors.New("Not connected")
 
 func init() {
-	rx_protocolMessage = regexp.MustCompile("(?ms)^[^|]*\\|")
-	rx_publicChat = regexp.MustCompile("(?ms)^<([^>]*)> (.*)$")
-	rx_incomingTo = regexp.MustCompile("(?ms)^([^ ]+) From: ([^ ]+) \\$<([^>]*)> (.*)")
-	rx_userCommand = regexp.MustCompile(`(?ms)^(\d+) (\d+)\s?([^\$]*)\$?(.*)`)
+	// With the `m` flag, use \A instead of ^ to anchor to start
+	// This fixes accidentally finding a better match in the middle of a multi-line message
+
+	rx_protocolMessage = regexp.MustCompile(`(?ms)\A[^|]*\|`)
+	rx_publicChat = regexp.MustCompile(`(?ms)\A<([^>]*)> (.*)$`)
+	rx_incomingTo = regexp.MustCompile(`(?ms)\A([^ ]+) From: ([^ ]+) \$<([^>]*)> (.*)`)
+	rx_userCommand = regexp.MustCompile(`(?ms)\A(\d+) (\d+)\s?([^\$]*)\$?(.*)`)
 }
 
 func Unescape(encoded string) string {