80850b15d0
* feat: Adds a webhook for when a user follow the stream Frontend: Adds a checkbox which renders only when social features are enabled. Backend: - Defines a new type for the event - Implements the webhook including unit testing - Fires the webhook inside the ApproveFollower handler * Removes unnecessary Type fiels from Events struct * refactor: renames SendUserFollowedEvent func to FediverseEngagementFollow and fixes linting errors * fix: fixes unit test to reflect removed Type field from FediverseEngagementFollowEvent * feat: fires webhook also when manual approvals are not required * chore: slight cleanup --------- Co-authored-by: Gabe Kangas <gabek@real-ity.com>
91 lines
2.9 KiB
Go
91 lines
2.9 KiB
Go
package inbox
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/go-fed/activity/streams/vocab"
|
|
"github.com/owncast/owncast/activitypub/persistence"
|
|
"github.com/owncast/owncast/activitypub/requests"
|
|
"github.com/owncast/owncast/activitypub/resolvers"
|
|
"github.com/owncast/owncast/core/chat/events"
|
|
"github.com/owncast/owncast/core/webhooks"
|
|
"github.com/owncast/owncast/persistence/configrepository"
|
|
"github.com/pkg/errors"
|
|
|
|
log "github.com/sirupsen/logrus"
|
|
)
|
|
|
|
func handleFollowInboxRequest(c context.Context, activity vocab.ActivityStreamsFollow) error {
|
|
configRepository := configrepository.Get()
|
|
|
|
follow, err := resolvers.MakeFollowRequest(c, activity)
|
|
if err != nil {
|
|
log.Errorln("unable to create follow inbox request", err)
|
|
return err
|
|
}
|
|
|
|
if follow == nil {
|
|
return fmt.Errorf("unable to handle request")
|
|
}
|
|
|
|
approved := !configRepository.GetFederationIsPrivate()
|
|
|
|
followRequest := *follow
|
|
|
|
if err := persistence.AddFollow(followRequest, approved); err != nil {
|
|
log.Errorln("unable to save follow request", err)
|
|
return err
|
|
}
|
|
|
|
localAccountName := configRepository.GetDefaultFederationUsername()
|
|
actorReference := activity.GetActivityStreamsActor()
|
|
object := activity.GetActivityStreamsObject()
|
|
objectIRI := object.At(0).GetIRI().String()
|
|
actorIRI := actorReference.At(0).GetIRI().String()
|
|
|
|
if approved {
|
|
if err := requests.SendFollowAccept(follow.Inbox, activity, localAccountName); err != nil {
|
|
log.Errorln("unable to send follow accept", err)
|
|
return err
|
|
}
|
|
go webhooks.SendFediverseEngagementFollowEvent(actorIRI)
|
|
}
|
|
|
|
// If this request is approved and we have not previously sent an action to
|
|
// chat due to a previous follow request, then do so.
|
|
hasPreviouslyhandled := true // Default so we don't send anything if it fails.
|
|
if approved {
|
|
hasPreviouslyhandled, err = persistence.HasPreviouslyHandledInboundActivity(objectIRI, actorIRI, events.FediverseEngagementFollow)
|
|
if err != nil {
|
|
log.Errorln("error checking for previously handled follow activity", err)
|
|
}
|
|
}
|
|
|
|
// Save this follow action to our activities table.
|
|
if err := persistence.SaveInboundFediverseActivity(objectIRI, actorIRI, events.FediverseEngagementFollow, time.Now()); err != nil {
|
|
return errors.Wrap(err, "unable to save inbound share/re-post activity")
|
|
}
|
|
|
|
// Send action to chat if it has not been previously handled.
|
|
if !hasPreviouslyhandled {
|
|
return handleEngagementActivity(events.FediverseEngagementFollow, false, actorReference, events.FediverseEngagementFollow)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func handleUnfollowRequest(c context.Context, activity vocab.ActivityStreamsUndo) error {
|
|
request := resolvers.MakeUnFollowRequest(c, activity)
|
|
if request == nil {
|
|
log.Errorf("unable to handle unfollow request")
|
|
return errors.New("unable to handle unfollow request")
|
|
}
|
|
|
|
unfollowRequest := *request
|
|
log.Traceln("unfollow request:", unfollowRequest)
|
|
|
|
return persistence.RemoveFollow(unfollowRequest)
|
|
}
|