receive_undo_follow.go

package activitypub_user

import (
	"github.com/EmissarySocial/emissary/model"
	"github.com/benpate/derp"
	"github.com/benpate/hannibal/streams"
	"github.com/benpate/hannibal/vocab"
)

func init() {
	inboxRouter.Add(vocab.ActivityTypeUndo, vocab.ActivityTypeFollow, undoFollow)
	inboxRouter.Add(vocab.ActivityTypeDelete, vocab.ActivityTypeFollow, undoFollow)
}

// undoFollow handles "Undo/Follow" and "Delete/Follow" activitites, which means
// that this code is called when a remote user unfollows an actor on this server.
func undoFollow(context Context, activity streams.Document) error {

	const location = "handler.activitypub.activityPub_HandleRequest_Undo_Follow"

	// Try to load the existing follower record
	followerService := context.factory.Follower()
	follower := model.NewFollower()

	// Load the original follow
	originalFollow, err := activity.Object().Load()

	if err != nil {
		if derp.NotFound(err) {
			return nil // If there is no follower record, then there's nothing to delete.
		}

		// All other errors are bad, tho.
		return derp.Wrap(err, location, "Error retrieving original follow request", activity.Value())
	}

	// Collect data from the original follow
	actorURL := originalFollow.Actor().ID() // The "actor" of the original follow is our follower.actor.ProfileURL
	userURL := originalFollow.Object().ID() // The "object" of the original follow is our local UserURL
	userService := context.factory.User()
	userID, err := userService.ParseProfileURL(userURL)

	if err != nil {
		return derp.Wrap(err, location, "Invalid User URL", userURL)
	}

	if err := followerService.LoadByActivityPubFollower(userID, actorURL, &follower); err != nil {

		if derp.NotFound(err) {
			return nil
		}

		return derp.Wrap(err, location, "Error locating follower", activity.Value(), userID, actorURL)
	}

	// Try to delete the existing follower record
	if err := followerService.Delete(&follower, "Removed by remote client"); err != nil {
		return derp.Wrap(err, location, "Error deleting follower", follower)
	}

	// Voila!
	return nil
}