1 files changed, 28 insertions, 0 deletions
diff --git a/srv/src/chat/util.go b/srv/src/chat/util.go
new file mode 100644
index 0000000..05f4830
--- /dev/null
+++ b/srv/src/chat/util.go
@@ -0,0 +1,28 @@
+package chat
+
+import (
+	"strconv"
+	"strings"
+
+	"github.com/mediocregopher/radix/v4"
+)
+
+func parseStreamEntryID(str string) (radix.StreamEntryID, error) {
+
+	split := strings.SplitN(str, "-", 2)
+	if len(split) != 2 {
+		return radix.StreamEntryID{}, errInvalidMessageID
+	}
+
+	time, err := strconv.ParseUint(split[0], 10, 64)
+	if err != nil {
+		return radix.StreamEntryID{}, errInvalidMessageID
+	}
+
+	seq, err := strconv.ParseUint(split[1], 10, 64)
+	if err != nil {
+		return radix.StreamEntryID{}, errInvalidMessageID
+	}
+
+	return radix.StreamEntryID{Time: time, Seq: seq}, nil
+}