Changeset 441 in code for trunk

Timestamp:

Jan 4, 2021, 4:17:35 PM (4 years ago)

Author:

contact

Message:

Make chat history operations optional in messageStore

Some stores may want not to implement chat history operations.

Location:

trunk

Files:

• downstream.go (modified) (2 diffs)
• msgstore.go (modified) (1 diff)

trunk/downstream.go

@@ -1736 +1736 @@
                 }
 
-                if dc.user.msgStore == nil {
+                store, ok := dc.user.msgStore.(chatHistoryMessageStore)
+                if !ok {
                         return ircError{&irc.Message{
                                 Command: irc.ERR_UNKNOWNCOMMAND,
@@ -1776 +1777 @@
                 switch subcommand {
                 case "BEFORE":
-                        history, err = dc.user.msgStore.LoadBeforeTime(uc.network, entity, timestamp, limit)
+                        history, err = store.LoadBeforeTime(uc.network, entity, timestamp, limit)
                 case "AFTER":
-                        history, err = dc.user.msgStore.LoadAfterTime(uc.network, entity, timestamp, limit)
+                        history, err = store.LoadAfterTime(uc.network, entity, timestamp, limit)
                 default:
                         // TODO: support LATEST, BETWEEN

trunk/msgstore.go

@@ -17 +17 @@
         // used in history queries.
         LastMsgID(network *network, entity string, t time.Time) (string, error)
+        LoadLatestID(network *network, entity, id string, limit int) ([]*irc.Message, error)
+        Append(network *network, entity string, msg *irc.Message) (id string, err error)
+}
+
+// chatHistoryMessageStore is a message store that supports chat history
+// operations.
+type chatHistoryMessageStore interface {
+        messageStore
+
         LoadBeforeTime(network *network, entity string, t time.Time, limit int) ([]*irc.Message, error)
         LoadAfterTime(network *network, entity string, t time.Time, limit int) ([]*irc.Message, error)
-        LoadLatestID(network *network, entity, id string, limit int) ([]*irc.Message, error)
-        Append(network *network, entity string, msg *irc.Message) (id string, err error)
 }