fix up status inreplyto visibility, + small format improvements (#199)

Signed-off-by: kim (grufwub) <grufwub@gmail.com>
This commit is contained in:
kim 2021-09-10 07:37:28 +01:00 committed by GitHub
parent 555ea8edfb
commit 41ace19e0c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 41 additions and 51 deletions

View File

@ -20,8 +20,6 @@ package visibility
import ( import (
"context" "context"
"errors"
"fmt" "fmt"
"github.com/sirupsen/logrus" "github.com/sirupsen/logrus"
@ -30,31 +28,33 @@ import (
) )
func (f *filter) StatusVisible(ctx context.Context, targetStatus *gtsmodel.Status, requestingAccount *gtsmodel.Account) (bool, error) { func (f *filter) StatusVisible(ctx context.Context, targetStatus *gtsmodel.Status, requestingAccount *gtsmodel.Account) (bool, error) {
const getBoosted = true
l := f.log.WithFields(logrus.Fields{ l := f.log.WithFields(logrus.Fields{
"func": "StatusVisible", "func": "StatusVisible",
"statusID": targetStatus.ID, "statusID": targetStatus.ID,
}) })
getBoosted := true // Fetch any relevant accounts for the target status
relevantAccounts, err := f.relevantAccounts(ctx, targetStatus, getBoosted) relevantAccounts, err := f.relevantAccounts(ctx, targetStatus, getBoosted)
if err != nil { if err != nil {
l.Debugf("error pulling relevant accounts for status %s: %s", targetStatus.ID, err) l.Debugf("error pulling relevant accounts for status %s: %s", targetStatus.ID, err)
return false, fmt.Errorf("StatusVisible: error pulling relevant accounts for status %s: %s", targetStatus.ID, err) return false, fmt.Errorf("StatusVisible: error pulling relevant accounts for status %s: %s", targetStatus.ID, err)
} }
// Check we have determined a target account
targetAccount := relevantAccounts.Account
if targetAccount == nil {
l.Trace("target account is not set")
return false, nil
}
// Check for domain blocks among relevant accounts
domainBlocked, err := f.domainBlockedRelevant(ctx, relevantAccounts) domainBlocked, err := f.domainBlockedRelevant(ctx, relevantAccounts)
if err != nil { if err != nil {
l.Debugf("error checking domain block: %s", err) l.Debugf("error checking domain block: %s", err)
return false, fmt.Errorf("error checking domain block: %s", err) return false, fmt.Errorf("error checking domain block: %s", err)
} } else if domainBlocked {
if domainBlocked {
return false, nil
}
targetAccount := relevantAccounts.Account
if targetAccount == nil {
l.Trace("target account is not set")
return false, nil return false, nil
} }
@ -136,7 +136,7 @@ func (f *filter) StatusVisible(ctx context.Context, targetStatus *gtsmodel.Statu
return false, nil return false, nil
} }
// status replies to account id // If not in reply to the requesting account, check if inReplyToAccount is blocked
if relevantAccounts.InReplyToAccount != nil && relevantAccounts.InReplyToAccount.ID != requestingAccount.ID { if relevantAccounts.InReplyToAccount != nil && relevantAccounts.InReplyToAccount.ID != requestingAccount.ID {
if blocked, err := f.db.IsBlocked(ctx, relevantAccounts.InReplyToAccount.ID, requestingAccount.ID, true); err != nil { if blocked, err := f.db.IsBlocked(ctx, relevantAccounts.InReplyToAccount.ID, requestingAccount.ID, true); err != nil {
return false, err return false, err
@ -144,18 +144,6 @@ func (f *filter) StatusVisible(ctx context.Context, targetStatus *gtsmodel.Statu
l.Trace("a block exists between requesting account and reply to account") l.Trace("a block exists between requesting account and reply to account")
return false, nil return false, nil
} }
// check reply to ID
if targetStatus.InReplyToID != "" && (targetStatus.Visibility == gtsmodel.VisibilityFollowersOnly || targetStatus.Visibility == gtsmodel.VisibilityDirect) {
followsRepliedAccount, err := f.db.IsFollowing(ctx, requestingAccount, relevantAccounts.InReplyToAccount)
if err != nil {
return false, err
}
if !followsRepliedAccount {
l.Trace("target status is a followers-only reply to an account that is not followed by the requesting account")
return false, nil
}
}
} }
// status boosts accounts id // status boosts accounts id
@ -178,19 +166,6 @@ func (f *filter) StatusVisible(ctx context.Context, targetStatus *gtsmodel.Statu
} }
} }
// status mentions accounts
for _, a := range relevantAccounts.MentionedAccounts {
if a == nil {
continue
}
if blocked, err := f.db.IsBlocked(ctx, a.ID, requestingAccount.ID, true); err != nil {
return false, err
} else if blocked {
l.Trace("a block exists between requesting account and a mentioned account")
return false, nil
}
}
// boost mentions accounts // boost mentions accounts
for _, a := range relevantAccounts.BoostedMentionedAccounts { for _, a := range relevantAccounts.BoostedMentionedAccounts {
if a == nil { if a == nil {
@ -204,24 +179,40 @@ func (f *filter) StatusVisible(ctx context.Context, targetStatus *gtsmodel.Statu
} }
} }
// if the requesting account is mentioned in the status it should always be visible // Iterate mentions to check for blocks or requester mentions
for _, acct := range relevantAccounts.MentionedAccounts { isMentioned, blockAmongMentions := false, false
if acct == nil { for _, a := range relevantAccounts.MentionedAccounts {
if a == nil {
continue continue
} }
if acct.ID == requestingAccount.ID {
return true, nil // yep it's mentioned! if blocked, err := f.db.IsBlocked(ctx, a.ID, requestingAccount.ID, true); err != nil {
return false, err
} else if blocked {
blockAmongMentions = true
break
} }
if a.ID == requestingAccount.ID {
isMentioned = true
}
}
if blockAmongMentions {
l.Trace("a block exists between requesting account and a mentioned account")
return false, nil
} else if isMentioned {
// Requester mentioned, should always be visible
return true, nil
} }
// at this point we know neither account blocks the other, or another account mentioned or otherwise referred to in the status // at this point we know neither account blocks the other, or another account mentioned or otherwise referred to in the status
// that means it's now just a matter of checking the visibility settings of the status itself // that means it's now just a matter of checking the visibility settings of the status itself
switch targetStatus.Visibility { switch targetStatus.Visibility {
case gtsmodel.VisibilityPublic, gtsmodel.VisibilityUnlocked: case gtsmodel.VisibilityPublic, gtsmodel.VisibilityUnlocked:
// no problem here, just return OK // no problem here
return true, nil
case gtsmodel.VisibilityFollowersOnly: case gtsmodel.VisibilityFollowersOnly:
// check one-way follow // Followers-only post, check for a one-way follow to target
follows, err := f.db.IsFollowing(ctx, requestingAccount, targetAccount) follows, err := f.db.IsFollowing(ctx, requestingAccount, targetAccount)
if err != nil { if err != nil {
return false, err return false, err
@ -230,9 +221,8 @@ func (f *filter) StatusVisible(ctx context.Context, targetStatus *gtsmodel.Statu
l.Trace("requested status is followers only but requesting account is not a follower") l.Trace("requested status is followers only but requesting account is not a follower")
return false, nil return false, nil
} }
return true, nil
case gtsmodel.VisibilityMutualsOnly: case gtsmodel.VisibilityMutualsOnly:
// check mutual follow // Mutuals-only post, check for a mutual follow
mutuals, err := f.db.IsMutualFollowing(ctx, requestingAccount, targetAccount) mutuals, err := f.db.IsMutualFollowing(ctx, requestingAccount, targetAccount)
if err != nil { if err != nil {
return false, err return false, err
@ -241,11 +231,11 @@ func (f *filter) StatusVisible(ctx context.Context, targetStatus *gtsmodel.Statu
l.Trace("requested status is mutuals only but accounts aren't mufos") l.Trace("requested status is mutuals only but accounts aren't mufos")
return false, nil return false, nil
} }
return true, nil
case gtsmodel.VisibilityDirect: case gtsmodel.VisibilityDirect:
l.Trace("requesting account requests a status it's not mentioned in") l.Trace("requesting account requests a direct status it's not mentioned in")
return false, nil // it's not mentioned -_- return false, nil // it's not mentioned -_-
} }
return false, errors.New("reached the end of StatusVisible with no result") // If we reached here, all is okay
return true, nil
} }