Method Create

activitypub/inbox.go:30–54

(env *Env, w http.ResponseWriter, r *http.Request)

type InboxController struct {
	db *gorm.DB
}

func (i *InboxController) Create(env *Env, w http.ResponseWriter, r *http.Request) error {
	instance, err := i.findInstance(r.Host)
	if err != nil {
		return err
	}

	var act Activity
	if err := json.UnmarshalFull(r.Body, &act); err != nil {
		return httpx.Error(http.StatusBadRequest, err)
	}

	// if we need to make an activity pub request, we need to sign it with the
	// instance's admin account.
	processor := &inboxProcessor{
		logger: env.Logger.With("instance", instance.Domain),
		req:    r,
		db:     i.db,
		signAs: instance.Admin,
	}

	if err := processor.processActivity(&act); err != nil {
		return fmt.Errorf("processActivity failed: %s: %w ", act.ID, err)
	}
	w.WriteHeader(http.StatusAccepted)
	return nil