diff options
author | Kegsay <kegan@matrix.org> | 2020-03-30 15:02:20 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-03-30 15:02:20 +0100 |
commit | 11a8059bba9dbdc855f10e3b380c4a2f245635a2 (patch) | |
tree | 61b2ffaa53eecb6d4eef8e275f432734cbb9e606 /federationsender/consumers | |
parent | f72b759426c1895b76c16ace526cc788713c2fea (diff) |
Rename the typing server to EDU server (#948)
* Blunt move and sed rename
* Rename common/ refs to typing
* Rename internal stuff in eduserver
* Rename docs and scripts
* Rename constants/filenames, goimports everything to re-order imports
Diffstat (limited to 'federationsender/consumers')
-rw-r--r-- | federationsender/consumers/eduserver.go (renamed from federationsender/consumers/typingserver.go) | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/federationsender/consumers/typingserver.go b/federationsender/consumers/eduserver.go index 590fcb25..ba45db7f 100644 --- a/federationsender/consumers/typingserver.go +++ b/federationsender/consumers/eduserver.go @@ -18,15 +18,15 @@ import ( "github.com/matrix-org/dendrite/common" "github.com/matrix-org/dendrite/common/config" + "github.com/matrix-org/dendrite/eduserver/api" "github.com/matrix-org/dendrite/federationsender/queue" "github.com/matrix-org/dendrite/federationsender/storage" - "github.com/matrix-org/dendrite/typingserver/api" "github.com/matrix-org/gomatrixserverlib" log "github.com/sirupsen/logrus" "gopkg.in/Shopify/sarama.v1" ) -// OutputTypingEventConsumer consumes events that originate in typing server. +// OutputTypingEventConsumer consumes events that originate in EDU server. type OutputTypingEventConsumer struct { consumer *common.ContinualConsumer db storage.Database @@ -34,7 +34,7 @@ type OutputTypingEventConsumer struct { ServerName gomatrixserverlib.ServerName } -// NewOutputTypingEventConsumer creates a new OutputTypingEventConsumer. Call Start() to begin consuming from typing servers. +// NewOutputTypingEventConsumer creates a new OutputTypingEventConsumer. Call Start() to begin consuming from EDU servers. func NewOutputTypingEventConsumer( cfg *config.Dendrite, kafkaConsumer sarama.Consumer, @@ -57,19 +57,19 @@ func NewOutputTypingEventConsumer( return c } -// Start consuming from typing servers +// Start consuming from EDU servers func (t *OutputTypingEventConsumer) Start() error { return t.consumer.Start() } -// onMessage is called for OutputTypingEvent received from the typing servers. +// onMessage is called for OutputTypingEvent received from the EDU servers. // Parses the msg, creates a matrix federation EDU and sends it to joined hosts. func (t *OutputTypingEventConsumer) onMessage(msg *sarama.ConsumerMessage) error { // Extract the typing event from msg. var ote api.OutputTypingEvent if err := json.Unmarshal(msg.Value, &ote); err != nil { // Skip this msg but continue processing messages. - log.WithError(err).Errorf("typingserver output log: message parse failed") + log.WithError(err).Errorf("eduserver output log: message parse failed") return nil } |