summaryrefslogtreecommitdiff
path: root/internal/processing/followrequest.go
diff options
context:
space:
mode:
authorLibravatar kim <89579420+NyaaaWhatsUpDoc@users.noreply.github.com>2023-09-12 14:00:35 +0100
committerLibravatar GitHub <noreply@github.com>2023-09-12 14:00:35 +0100
commit7293d6029b43db693fd170c0c087394339da0677 (patch)
tree09063243faf1b178fde35973486e311f66b1ca33 /internal/processing/followrequest.go
parent[feature] Allow admins to expire remote public keys; refetch expired keys on ... (diff)
downloadgotosocial-7293d6029b43db693fd170c0c087394339da0677.tar.xz
[feature] add paging to account follows, followers and follow requests endpoints (#2186)
Diffstat (limited to 'internal/processing/followrequest.go')
-rw-r--r--internal/processing/followrequest.go123
1 files changed, 0 insertions, 123 deletions
diff --git a/internal/processing/followrequest.go b/internal/processing/followrequest.go
deleted file mode 100644
index 6587b73bb..000000000
--- a/internal/processing/followrequest.go
+++ /dev/null
@@ -1,123 +0,0 @@
-// GoToSocial
-// Copyright (C) GoToSocial Authors admin@gotosocial.org
-// SPDX-License-Identifier: AGPL-3.0-or-later
-//
-// This program is free software: you can redistribute it and/or modify
-// it under the terms of the GNU Affero General Public License as published by
-// the Free Software Foundation, either version 3 of the License, or
-// (at your option) any later version.
-//
-// This program is distributed in the hope that it will be useful,
-// but WITHOUT ANY WARRANTY; without even the implied warranty of
-// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-// GNU Affero General Public License for more details.
-//
-// You should have received a copy of the GNU Affero General Public License
-// along with this program. If not, see <http://www.gnu.org/licenses/>.
-
-package processing
-
-import (
- "context"
- "errors"
-
- "github.com/superseriousbusiness/gotosocial/internal/ap"
- apimodel "github.com/superseriousbusiness/gotosocial/internal/api/model"
- "github.com/superseriousbusiness/gotosocial/internal/db"
- "github.com/superseriousbusiness/gotosocial/internal/gtserror"
- "github.com/superseriousbusiness/gotosocial/internal/log"
- "github.com/superseriousbusiness/gotosocial/internal/messages"
- "github.com/superseriousbusiness/gotosocial/internal/oauth"
-)
-
-func (p *Processor) FollowRequestsGet(ctx context.Context, auth *oauth.Auth) ([]apimodel.Account, gtserror.WithCode) {
- followRequests, err := p.state.DB.GetAccountFollowRequests(ctx, auth.Account.ID)
- if err != nil && !errors.Is(err, db.ErrNoEntries) {
- return nil, gtserror.NewErrorInternalError(err)
- }
-
- accts := make([]apimodel.Account, 0, len(followRequests))
- for _, followRequest := range followRequests {
- if followRequest.Account == nil {
- // The creator of the follow doesn't exist,
- // just skip this one.
- log.WithContext(ctx).WithField("followRequest", followRequest).Warn("follow request had no associated account")
- continue
- }
-
- apiAcct, err := p.tc.AccountToAPIAccountPublic(ctx, followRequest.Account)
- if err != nil {
- return nil, gtserror.NewErrorInternalError(err)
- }
-
- accts = append(accts, *apiAcct)
- }
-
- return accts, nil
-}
-
-func (p *Processor) FollowRequestAccept(ctx context.Context, auth *oauth.Auth, accountID string) (*apimodel.Relationship, gtserror.WithCode) {
- follow, err := p.state.DB.AcceptFollowRequest(ctx, accountID, auth.Account.ID)
- if err != nil {
- return nil, gtserror.NewErrorNotFound(err)
- }
-
- if follow.Account == nil {
- // The creator of the follow doesn't exist,
- // so we can't do further processing.
- log.WithContext(ctx).WithField("follow", follow).Warn("follow had no associated account")
- return p.relationship(ctx, auth.Account.ID, accountID)
- }
-
- p.state.Workers.EnqueueClientAPI(ctx, messages.FromClientAPI{
- APObjectType: ap.ActivityFollow,
- APActivityType: ap.ActivityAccept,
- GTSModel: follow,
- OriginAccount: follow.Account,
- TargetAccount: follow.TargetAccount,
- })
-
- return p.relationship(ctx, auth.Account.ID, accountID)
-}
-
-func (p *Processor) FollowRequestReject(ctx context.Context, auth *oauth.Auth, accountID string) (*apimodel.Relationship, gtserror.WithCode) {
- followRequest, err := p.state.DB.GetFollowRequest(ctx, accountID, auth.Account.ID)
- if err != nil {
- return nil, gtserror.NewErrorNotFound(err)
- }
-
- err = p.state.DB.RejectFollowRequest(ctx, accountID, auth.Account.ID)
- if err != nil {
- return nil, gtserror.NewErrorNotFound(err)
- }
-
- if followRequest.Account == nil {
- // The creator of the request doesn't exist,
- // so we can't do further processing.
- return p.relationship(ctx, auth.Account.ID, accountID)
- }
-
- p.state.Workers.EnqueueClientAPI(ctx, messages.FromClientAPI{
- APObjectType: ap.ActivityFollow,
- APActivityType: ap.ActivityReject,
- GTSModel: followRequest,
- OriginAccount: followRequest.Account,
- TargetAccount: followRequest.TargetAccount,
- })
-
- return p.relationship(ctx, auth.Account.ID, accountID)
-}
-
-func (p *Processor) relationship(ctx context.Context, accountID string, targetAccountID string) (*apimodel.Relationship, gtserror.WithCode) {
- relationship, err := p.state.DB.GetRelationship(ctx, accountID, targetAccountID)
- if err != nil {
- return nil, gtserror.NewErrorInternalError(err)
- }
-
- apiRelationship, err := p.tc.RelationshipToAPIRelationship(ctx, relationship)
- if err != nil {
- return nil, gtserror.NewErrorInternalError(err)
- }
-
- return apiRelationship, nil
-}