summaryrefslogtreecommitdiff
path: root/internal/processing/streaming/streamnotification.go
diff options
context:
space:
mode:
Diffstat (limited to 'internal/processing/streaming/streamnotification.go')
-rw-r--r--internal/processing/streaming/streamnotification.go51
1 files changed, 0 insertions, 51 deletions
diff --git a/internal/processing/streaming/streamnotification.go b/internal/processing/streaming/streamnotification.go
deleted file mode 100644
index d8460874f..000000000
--- a/internal/processing/streaming/streamnotification.go
+++ /dev/null
@@ -1,51 +0,0 @@
-package streaming
-
-import (
- "encoding/json"
- "errors"
- "fmt"
-
- "github.com/sirupsen/logrus"
- apimodel "github.com/superseriousbusiness/gotosocial/internal/api/model"
- "github.com/superseriousbusiness/gotosocial/internal/gtsmodel"
- "github.com/superseriousbusiness/gotosocial/internal/stream"
-)
-
-func (p *processor) StreamNotificationToAccount(n *apimodel.Notification, account *gtsmodel.Account) error {
- l := p.log.WithFields(logrus.Fields{
- "func": "StreamNotificationToAccount",
- "account": account.ID,
- })
- v, ok := p.streamMap.Load(account.ID)
- if !ok {
- // no open connections so nothing to stream
- return nil
- }
-
- streamsForAccount, ok := v.(*stream.StreamsForAccount)
- if !ok {
- return errors.New("stream map error")
- }
-
- notificationBytes, err := json.Marshal(n)
- if err != nil {
- return fmt.Errorf("error marshalling notification to json: %s", err)
- }
-
- streamsForAccount.Lock()
- defer streamsForAccount.Unlock()
- for _, s := range streamsForAccount.Streams {
- s.Lock()
- defer s.Unlock()
- if s.Connected {
- l.Debugf("streaming notification to stream id %s", s.ID)
- s.Messages <- &stream.Message{
- Stream: []string{s.Type},
- Event: "notification",
- Payload: string(notificationBytes),
- }
- }
- }
-
- return nil
-}