From aa8a0d08501cbb22400a67ece85c45fdfbdc6131 Mon Sep 17 00:00:00 2001 From: Tobi Smethurst <31960611+tsmethurst@users.noreply.github.com> Date: Sat, 19 Jun 2021 11:18:55 +0200 Subject: Streaming (#49) Add new status and notification websocket streaming capabilities --- internal/processing/streaming.go | 14 ++++++++++++++ 1 file changed, 14 insertions(+) create mode 100644 internal/processing/streaming.go (limited to 'internal/processing/streaming.go') diff --git a/internal/processing/streaming.go b/internal/processing/streaming.go new file mode 100644 index 000000000..1e566da81 --- /dev/null +++ b/internal/processing/streaming.go @@ -0,0 +1,14 @@ +package processing + +import ( + "github.com/superseriousbusiness/gotosocial/internal/gtserror" + "github.com/superseriousbusiness/gotosocial/internal/gtsmodel" +) + +func (p *processor) AuthorizeStreamingRequest(accessToken string) (*gtsmodel.Account, error) { + return p.streamingProcessor.AuthorizeStreamingRequest(accessToken) +} + +func (p *processor) OpenStreamForAccount(account *gtsmodel.Account, streamType string) (*gtsmodel.Stream, gtserror.WithCode) { + return p.streamingProcessor.OpenStreamForAccount(account, streamType) +} -- cgit v1.2.3