Function newHandlerFromConfig

pkg/search/handler.go:142–192

(ld blobserver.Loader, conf jsonconfig.Obj)

}

func newHandlerFromConfig(ld blobserver.Loader, conf jsonconfig.Obj) (http.Handler, error) {
	indexPrefix := conf.RequiredString("index") // TODO: add optional help tips here?
	ownerCfg := conf.RequiredObject("owner")
	ownerId := ownerCfg.RequiredString("identity")
	ownerSecring := ownerCfg.RequiredString("secringFile")

	devBlockStartupPrefix := conf.OptionalString("devBlockStartupOn", "")
	slurpToMemory := conf.OptionalBool("slurpToMemory", false)
	if err := conf.Validate(); err != nil {
		return nil, err
	}

	if devBlockStartupPrefix != "" {
		_, err := ld.GetHandler(devBlockStartupPrefix)
		if err != nil {
			return nil, fmt.Errorf("search handler references bogus devBlockStartupOn handler %s: %v", devBlockStartupPrefix, err)
		}
	}

	indexHandler, err := ld.GetHandler(indexPrefix)
	if err != nil {
		return nil, fmt.Errorf("search config references unknown handler %q", indexPrefix)
	}
	indexer, ok := indexHandler.(index.Interface)
	if !ok {
		return nil, fmt.Errorf("search config references invalid indexer %q (actually a %T)", indexPrefix, indexHandler)
	}

	owner, err := newOwner(serverconfig.Owner{
		Identity:    ownerId,
		SecringFile: ownerSecring,
	})
	if err != nil {
		return nil, fmt.Errorf("could not create Owner %v", err)
	}
	h := NewHandler(indexer, owner)

	if slurpToMemory {
		ii := indexer.(*index.Index)
		ii.Lock()
		corpus, err := ii.KeepInMemory()
		if err != nil {
			ii.Unlock()
			return nil, fmt.Errorf("error slurping index to memory: %v", err)
		}
		h.SetCorpus(corpus)
		ii.Unlock()
	}

	return h, nil
}

func newOwner(ownerCfg serverconfig.Owner) (*index.Owner, error) {
	entity, err := jsonsign.EntityFromSecring(ownerCfg.Identity, ownerCfg.SecringFile)