3ae49bb6f4
- optional beachcomber.PageSearcher returns a page of candidate ids plus the engine's found count; beachcomber.SearchPage falls back to SearchIDs for engines without it, so Engine is unchanged - Query.QueryByWeights is sent to Typesense as query_by_weights; a mismatched weight list or a page above typesense.MaxPerPage (250) is refused before any request
81 lines
2.5 KiB
Go
81 lines
2.5 KiB
Go
package beachcomber
|
|
|
|
import (
|
|
"context"
|
|
"sort"
|
|
"sync"
|
|
|
|
"git.golem15.com/golem15/summercms/modules/backpack"
|
|
)
|
|
|
|
// NullEngine is the name of the built-in engine that indexes nothing.
|
|
const NullEngine = "null"
|
|
|
|
// EngineFactory builds an engine for an app.
|
|
type EngineFactory func(app *backpack.App) (Engine, error)
|
|
|
|
// engineTable is the init-time engine registry, like database/sql's: it is
|
|
// written only from package init functions and read when a Service is built.
|
|
var engineTable = struct {
|
|
mu sync.RWMutex
|
|
factories map[string]EngineFactory
|
|
}{factories: map[string]EngineFactory{}}
|
|
|
|
// RegisterEngine makes an engine available under name. Call it from the
|
|
// engine package's init function. A duplicate name, an empty name or a nil
|
|
// factory panics.
|
|
func RegisterEngine(name string, f EngineFactory) {
|
|
if name == "" {
|
|
panic("beachcomber: RegisterEngine with an empty name")
|
|
}
|
|
if f == nil {
|
|
panic("beachcomber: RegisterEngine " + name + " with a nil factory")
|
|
}
|
|
engineTable.mu.Lock()
|
|
defer engineTable.mu.Unlock()
|
|
if _, dup := engineTable.factories[name]; dup {
|
|
panic("beachcomber: RegisterEngine called twice for engine " + name)
|
|
}
|
|
engineTable.factories[name] = f
|
|
}
|
|
|
|
func engineFactory(name string) (EngineFactory, bool) {
|
|
engineTable.mu.RLock()
|
|
defer engineTable.mu.RUnlock()
|
|
f, ok := engineTable.factories[name]
|
|
return f, ok
|
|
}
|
|
|
|
func engineNames() []string {
|
|
engineTable.mu.RLock()
|
|
defer engineTable.mu.RUnlock()
|
|
names := make([]string, 0, len(engineTable.factories))
|
|
for n := range engineTable.factories {
|
|
names = append(names, n)
|
|
}
|
|
sort.Strings(names)
|
|
return names
|
|
}
|
|
|
|
func init() {
|
|
RegisterEngine(NullEngine, func(*backpack.App) (Engine, error) { return nullEngine{}, nil })
|
|
}
|
|
|
|
// nullEngine is never configured, so sync is skipped before it is called.
|
|
// Every method is a no-op; SearchIDs and SearchPage return no ids.
|
|
type nullEngine struct{}
|
|
|
|
func (nullEngine) Name() string { return NullEngine }
|
|
func (nullEngine) Configured() bool { return false }
|
|
func (nullEngine) Upsert(context.Context, string, map[string]any, []map[string]any) error {
|
|
return nil
|
|
}
|
|
func (nullEngine) Delete(context.Context, string, []string) error { return nil }
|
|
func (nullEngine) Flush(context.Context, string) error { return nil }
|
|
func (nullEngine) SearchIDs(context.Context, string, Query) ([]string, error) {
|
|
return []string{}, nil
|
|
}
|
|
func (nullEngine) SearchPage(context.Context, string, Query) (SearchResult, error) {
|
|
return SearchResult{IDs: []string{}}, nil
|
|
}
|