Changeset 440 in code for trunk/msgstore_fs.go

Timestamp:

Jan 4, 2021, 3:26:30 PM (4 years ago)

Author:

contact

Message:

Add store-agnostic message ID format

Allow to query the network ID and entity from the message ID regardless
of the underlying store used.

File:

• trunk/msgstore_fs.go (modified) (4 diffs)

trunk/msgstore_fs.go

@@ -37 +37 @@
 }
 
-func parseMsgID(s string) (network, entity string, t time.Time, offset int64, err error) {
+func parseFSMsgID(s string) (netID int64, entity string, t time.Time, offset int64, err error) {
+        netID, entity, extra, err := parseMsgID(s)
+        if err != nil {
+                return 0, "", time.Time{}, 0, err
+        }
+
         var year, month, day int
-        _, err = fmt.Sscanf(s, "%s %s %04d-%02d-%02d %d", &network, &entity, &year, &month, &day, &offset)
-        if err != nil {
-                return "", "", time.Time{}, 0, fmt.Errorf("invalid message ID: %v", err)
+        _, err = fmt.Sscanf(extra, "%04d-%02d-%02d %d", &year, &month, &day, &offset)
+        if err != nil {
+                return 0, "", time.Time{}, 0, fmt.Errorf("invalid message ID %q: %v", s, err)
         }
         t = time.Date(year, time.Month(month), day, 0, 0, 0, 0, time.Local)
-        return network, entity, t, offset, nil
-}
-
-func formatMsgID(network, entity string, t time.Time, offset int64) string {
+        return netID, entity, t, offset, nil
+}
+
+func formatFSMsgID(netID int64, entity string, t time.Time, offset int64) string {
         year, month, day := t.Date()
-        return fmt.Sprintf("%s %s %04d-%02d-%02d %d", network, entity, year, month, day, offset)
+        extra := fmt.Sprintf("%04d-%02d-%02d %d", year, month, day, offset)
+        return formatMsgID(netID, entity, extra)
 }
 
 // nextMsgID queries the message ID for the next message to be written to f.
-func nextMsgID(network *network, entity string, t time.Time, f *os.File) (string, error) {
+func nextFSMsgID(network *network, entity string, t time.Time, f *os.File) (string, error) {
         offset, err := f.Seek(0, io.SeekEnd)
         if err != nil {
                 return "", err
         }
-        return formatMsgID(network.GetName(), entity, t, offset), nil
+        return formatFSMsgID(network.ID, entity, t, offset), nil
 }
 
@@ -65 +71 @@
         fi, err := os.Stat(p)
         if os.IsNotExist(err) {
-                return formatMsgID(network.GetName(), entity, t, -1), nil
+                return formatFSMsgID(network.ID, entity, t, -1), nil
         } else if err != nil {
                 return "", err
         }
-        return formatMsgID(network.GetName(), entity, t, fi.Size()-1), nil
+        return formatFSMsgID(network.ID, entity, t, fi.Size()-1), nil
 }
 
@@ -114 +120 @@
         }
 
-        msgID, err := nextMsgID(network, entity, t, f)
+        msgID, err := nextFSMsgID(network, entity, t, f)
         if err != nil {
                 return "", fmt.Errorf("failed to generate message ID: %v", err)
@@ -374 +380 @@
         var afterOffset int64
         if id != "" {
-                var idNet, idEntity string
+                var idNet int64
+                var idEntity string
                 var err error
-                idNet, idEntity, afterTime, afterOffset, err = parseMsgID(id)
-                if err != nil {
-                        return nil, err
-                }
-                if idNet != network.GetName() || idEntity != entity {
+                idNet, idEntity, afterTime, afterOffset, err = parseFSMsgID(id)
+                if err != nil {
+                        return nil, err
+                }
+                if idNet != network.ID || idEntity != entity {
                         return nil, fmt.Errorf("cannot find message ID: message ID doesn't match network/entity")
                 }