summaryrefslogtreecommitdiff
path: root/internal/processing/federation
diff options
context:
space:
mode:
Diffstat (limited to 'internal/processing/federation')
-rw-r--r--internal/processing/federation/getstatus.go13
1 files changed, 6 insertions, 7 deletions
diff --git a/internal/processing/federation/getstatus.go b/internal/processing/federation/getstatus.go
index 820f1a19b..2cc37071e 100644
--- a/internal/processing/federation/getstatus.go
+++ b/internal/processing/federation/getstatus.go
@@ -24,9 +24,7 @@ import (
"net/url"
"github.com/superseriousbusiness/activity/streams"
- "github.com/superseriousbusiness/gotosocial/internal/db"
"github.com/superseriousbusiness/gotosocial/internal/gtserror"
- "github.com/superseriousbusiness/gotosocial/internal/gtsmodel"
)
func (p *processor) GetStatus(ctx context.Context, requestedUsername string, requestedStatusID string, requestURL *url.URL) (interface{}, gtserror.WithCode) {
@@ -59,14 +57,15 @@ func (p *processor) GetStatus(ctx context.Context, requestedUsername string, req
}
// get the status out of the database here
- s := &gtsmodel.Status{}
- if err := p.db.GetWhere(ctx, []db.Where{
- {Key: "id", Value: requestedStatusID, CaseInsensitive: true},
- {Key: "account_id", Value: requestedAccount.ID, CaseInsensitive: true},
- }, s); err != nil {
+ s, err := p.db.GetStatusByID(ctx, requestedStatusID)
+ if err != nil {
return nil, gtserror.NewErrorNotFound(fmt.Errorf("database error getting status with id %s and account id %s: %s", requestedStatusID, requestedAccount.ID, err))
}
+ if s.AccountID != requestedAccount.ID {
+ return nil, gtserror.NewErrorNotFound(fmt.Errorf("status with id %s does not belong to account with id %s", s.ID, requestedAccount.ID))
+ }
+
visible, err := p.filter.StatusVisible(ctx, s, requestingAccount)
if err != nil {
return nil, gtserror.NewErrorInternalError(err)