|
|
|
@ -417,19 +417,9 @@ func (ap *ActivityPub) InboxHandler(w http.ResponseWriter, r *http.Request) {
|
|
|
|
|
actor = ap.actor
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
switch obj.(type) {
|
|
|
|
|
case *Follow:
|
|
|
|
|
ap.inbox <- activity{actor: actor, inbox: actor.Inbox, object: obj.(*Follow)}
|
|
|
|
|
case *Undo:
|
|
|
|
|
ap.inbox <- activity{actor: actor, inbox: actor.Inbox, object: obj.(*Undo)}
|
|
|
|
|
case *Create:
|
|
|
|
|
ap.inbox <- activity{actor: actor, inbox: actor.Inbox, object: obj.(*Create)}
|
|
|
|
|
case *Delete:
|
|
|
|
|
ap.inbox <- activity{actor: actor, inbox: actor.Inbox, object: obj.(*Delete)}
|
|
|
|
|
case *Accept:
|
|
|
|
|
ap.inbox <- activity{actor: actor, inbox: actor.Inbox, object: obj.(*Accept)}
|
|
|
|
|
case *Reject:
|
|
|
|
|
ap.inbox <- activity{actor: actor, inbox: actor.Inbox, object: obj.(*Reject)}
|
|
|
|
|
switch obj := obj.(type) {
|
|
|
|
|
case *Create, *Delete, *Follow, *Undo, *Accept, *Reject:
|
|
|
|
|
ap.inbox <- activity{actor: actor, inbox: actor.Inbox, object: obj}
|
|
|
|
|
default:
|
|
|
|
|
log.Debugf("unsupported object type %T", obj)
|
|
|
|
|
http.Error(w, "Unsupported", http.StatusUnprocessableEntity)
|
|
|
|
|