Method createObject

activitypub/inbox.go:264–281

(props map[string]any)

	typ := stringFromAny(create["type"])
	switch typ {
	case "Note", "Question":
		return i.processCreateNote(create)
	default:
		return fmt.Errorf("unknown create object type: %q", typ)
	}
}

func (i *inboxProcessor) processCreateNote(create map[string]any) error {
	uri := stringFromAny(create["atomUri"])
	_, err := models.NewStatuses(i.db).FindByURI(uri)
	switch err {
	case nil:
		// we already have this status
		return nil
	case gorm.ErrRecordNotFound:
		// we don't have this status
		actors := NewRemoteActorFetcher(i.signAs)
		actor, err := models.NewActors(i.db).FindOrCreate(stringFromAny(create["attributedTo"]), actors.Fetch)
		if err != nil {
			return err
		}