From eaccf41563a5696996c0c75ceff1f270e88fc207 Mon Sep 17 00:00:00 2001 From: Brian Picciano Date: Mon, 16 Aug 2021 21:53:02 -0600 Subject: MVP of chat package --- srv/chat/util.go | 28 ++++++++++++++++++++++++++++ 1 file changed, 28 insertions(+) create mode 100644 srv/chat/util.go (limited to 'srv/chat/util.go') diff --git a/srv/chat/util.go b/srv/chat/util.go new file mode 100644 index 0000000..05f4830 --- /dev/null +++ b/srv/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 +} -- cgit v1.2.3