59 lines
1.8 KiB
Go
59 lines
1.8 KiB
Go
package resolvers
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"github.com/go-fed/activity/streams/vocab"
|
|
"github.com/owncast/owncast/activitypub/apmodels"
|
|
"github.com/pkg/errors"
|
|
log "github.com/sirupsen/logrus"
|
|
)
|
|
|
|
func getPersonFromFollow(activity vocab.ActivityStreamsFollow) (apmodels.ActivityPubActor, error) {
|
|
return GetResolvedActorFromActorProperty(activity.GetActivityStreamsActor())
|
|
}
|
|
|
|
// MakeFollowRequest will convert an inbound Follow request to our internal actor model.
|
|
func MakeFollowRequest(c context.Context, activity vocab.ActivityStreamsFollow) (*apmodels.ActivityPubActor, error) {
|
|
person, err := getPersonFromFollow(activity)
|
|
if err != nil {
|
|
return nil, errors.New("unable to resolve person from follow request: " + err.Error())
|
|
}
|
|
|
|
hostname := person.ActorIri.Hostname()
|
|
username := person.Username
|
|
fullUsername := fmt.Sprintf("%s@%s", username, hostname)
|
|
|
|
followRequest := apmodels.ActivityPubActor{
|
|
ActorIri: person.ActorIri,
|
|
FollowRequestIri: activity.GetJSONLDId().Get(),
|
|
Inbox: person.Inbox,
|
|
Name: person.Name,
|
|
Username: fullUsername,
|
|
Image: person.Image,
|
|
RequestObject: activity,
|
|
}
|
|
|
|
return &followRequest, nil
|
|
}
|
|
|
|
// MakeUnFollowRequest will convert an inbound Unfollow request to our internal actor model.
|
|
func MakeUnFollowRequest(c context.Context, activity vocab.ActivityStreamsUndo) *apmodels.ActivityPubActor {
|
|
person, err := GetResolvedActorFromActorProperty(activity.GetActivityStreamsActor())
|
|
if err != nil {
|
|
log.Errorln("unable to resolve person from actor iri", person.ActorIri, err)
|
|
return nil
|
|
}
|
|
|
|
unfollowRequest := apmodels.ActivityPubActor{
|
|
ActorIri: person.ActorIri,
|
|
FollowRequestIri: activity.GetJSONLDId().Get(),
|
|
Inbox: person.Inbox,
|
|
Name: person.Name,
|
|
Image: person.Image,
|
|
}
|
|
|
|
return &unfollowRequest
|
|
}
|