fix: only send non-direct messages over websockets

internal/database/token.go

@@ -58,12 +58,16 @@ const (
 	TokenScopePostsRead     TokenScope = "posts.read"
 	TokenScopePostsWrite    TokenScope = "posts.write"
 	TokenScopeTimeline      TokenScope = "timeline"
-	TokenScopeStreaming TokenScope = "streaming"
+	TokenScopeStreaming     TokenScope = "streaming"
 )
 
 func (s TokenScope) IsValid() bool {
 	switch s {
-	case TokenScopeAccountsRead, TokenScopeAccountsMe, TokenScopeAccountsWrite:
+	case TokenScopeAccountsRead, TokenScopeAccountsMe,
+	TokenScopeAccountsWrite, TokenScopeBlogsRead,
+	TokenScopeBlogsWrite, TokenScopePostsRead,
+	TokenScopePostsWrite, TokenScopeTimeline,
+	TokenScopeStreaming:
 		return true
 	default:
 		return false

internal/processor/processor.go

@@ -71,11 +71,16 @@ func (p *Processor) handlePostLocal(
 	apiPost := api.DBPostToPost(post, blog, acct)
 	p.SocketHolder.Send(acct.ID, streaming.EventTypePost, apiPost)
 
-	for _, follower := range followers {
-		if !follower.IsLocal {
-			continue
-		}
+	// send to followers
+	if post.Visibility != database.DirectVisibility {
+		for _, follower := range followers {
+			if !follower.IsLocal {
+				continue
+			}
 
-		p.SocketHolder.Send(follower.AccountID, streaming.EventTypePost, apiPost)
+			p.SocketHolder.Send(follower.AccountID, streaming.EventTypePost, apiPost)
+		}
 	}
+
+	// TODO: send to mentions
 }