mirror of
https://codeberg.org/forgejo/forgejo.git
synced 2026-07-25 19:07:59 +00:00
5f432e32c8
First round of patches to re-enable some lints from my side. This PR also refactors the general key fetching code quite a bit due to the way it currently worked with relying on some values being nil sometimes. Reviewed-on: https://codeberg.org/forgejo/forgejo/pulls/11253 Reviewed-by: elle <0xllx0@noreply.codeberg.org> Reviewed-by: Gusted <gusted@noreply.codeberg.org> Co-authored-by: famfo <famfo@famfo.xyz> Co-committed-by: famfo <famfo@famfo.xyz>
45 lines
1.5 KiB
Go
45 lines
1.5 KiB
Go
// Copyright 2024 The Forgejo Authors. All rights reserved.
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
package federation
|
|
|
|
import (
|
|
"context"
|
|
"net/http"
|
|
|
|
"forgejo.org/models/user"
|
|
"forgejo.org/modules/log"
|
|
|
|
ap "github.com/go-ap/activitypub"
|
|
)
|
|
|
|
func processPersonInboxUndo(ctx context.Context, ctxUser *user.User, activity *ap.Activity) (ServiceResult, error) {
|
|
if activity.Object.GetType() != ap.FollowType {
|
|
log.Error("Invalid object type for Undo activity: %v", activity.Object.GetType())
|
|
return ServiceResult{}, NewErrNotAcceptablef("Invalid object type for Undo activity: %v", activity.Object.GetType())
|
|
}
|
|
|
|
actorURI := activity.Actor.GetLink().String()
|
|
_, federatedUser, err := findFederatedUser(ctx, actorURI)
|
|
if err != nil {
|
|
log.Error("User not found: %v", err)
|
|
return ServiceResult{}, NewErrInternalf("User not found: %v", err)
|
|
}
|
|
|
|
following, err := user.IsFollowingAp(ctx, ctxUser, federatedUser)
|
|
if err != nil {
|
|
log.Error("forgefed.IsFollowing: %v", err)
|
|
return ServiceResult{}, NewErrInternalf("forgefed.IsFollowing: %v", err)
|
|
}
|
|
if !following {
|
|
// The local user is not following the federated one, nothing to do.
|
|
log.Trace("Local user[%d] is not following federated user[%d]", ctxUser.ID, federatedUser.ID)
|
|
return NewServiceResultStatusOnly(http.StatusNoContent), nil
|
|
}
|
|
if err := user.RemoveFollower(ctx, ctxUser, federatedUser); err != nil {
|
|
log.Error("Unable to remove follower", err)
|
|
return ServiceResult{}, NewErrInternalf("Unable to remove follower: %v", err)
|
|
}
|
|
|
|
return NewServiceResultStatusOnly(http.StatusNoContent), nil
|
|
}
|