Changeset 549 in code for trunk/downstream.go

Timestamp:

Jun 2, 2021, 6:32:11 PM (4 years ago)

Author:

contact

Message:

Implement CHATHISTORY TARGETS

References: ​https://github.com/ircv3/ircv3-specifications/pull/450

File:

• trunk/downstream.go (modified) (2 diffs)

trunk/downstream.go

@@ -2031 +2031 @@
                                 return err
                         }
+                case "TARGETS":
+                        if err := parseMessageParams(msg, nil, &boundsStr[0], &boundsStr[1], &limitStr); err != nil {
+                                return err
+                        }
                 default:
                         // TODO: support LATEST, AROUND
@@ -2093 +2097 @@
                                 history, err = store.LoadBeforeTime(uc.network, entity, bounds[0], bounds[1], limit)
                         }
+                case "TARGETS":
+                        // TODO: support TARGETS in multi-upstream mode
+                        targets, err := store.ListTargets(uc.network, bounds[0], bounds[1], limit)
+                        if err != nil {
+                                dc.logger.Printf("failed fetching targets for chathistory: %v", target, err)
+                                return ircError{&irc.Message{
+                                        Command: "FAIL",
+                                        Params:  []string{"CHATHISTORY", "MESSAGE_ERROR", subcommand, "Failed to retrieve targets"},
+                                }}
+                        }
+
+                        batchRef := "history-targets"
+                        dc.SendMessage(&irc.Message{
+                                Prefix:  dc.srv.prefix(),
+                                Command: "BATCH",
+                                Params:  []string{"+" + batchRef, "draft/chathistory-targets"},
+                        })
+
+                        for _, target := range targets {
+                                dc.SendMessage(&irc.Message{
+                                        Tags:    irc.Tags{"batch": irc.TagValue(batchRef)},
+                                        Prefix:  dc.srv.prefix(),
+                                        Command: "CHATHISTORY",
+                                        Params:  []string{"TARGETS", target.Name, target.LatestMessage.UTC().Format(serverTimeLayout)},
+                                })
+                        }
+
+                        dc.SendMessage(&irc.Message{
+                                Prefix:  dc.srv.prefix(),
+                                Command: "BATCH",
+                                Params:  []string{"-" + batchRef},
+                        })
+
+                        return nil
                 }
                 if err != nil {