search

libs/search/src/wagoe/search/
├── schema.clj         — Malli schemas: SearchDocument, SearchResult, SearchResponse
├── ports.clj          — ISearchStore (persistence), ISearchEngine (orchestration),
│                        ISearchDefinitions
├── core/
│   ├── index.clj      — defsearch, build-document*
│   ├── query.clj      — SQL builders (PostgreSQL FTS + H2/SQLite LIKE fallback)
│   ├── ranking.clj, highlighting.clj
│   └── ui.clj         — Hiccup: search results, admin index page
└── shell/
    ├── persistence.clj    — SearchStore (next.jdbc, HoneySQL ON CONFLICT upsert)
    ├── service.clj        — SearchService (orchestration, pagination, reindex)
    ├── http.clj           — Routes: API + admin web UI
    └── module_wiring.clj  — the :wagoe/search component

(require '[wagoe.search.core.index :as search])

(search/defsearch product-search
  {:entity-type :product
   :language    :english
   :fields      [{:name :title  :weight :a}
                 {:name :body   :weight :b}
                 {:name :tags   :weight :c}]
   :filters     [:tenant-id :category-id]})  ; optional: filterable dimensions

(defn ig-config [_settings _ctx]
  {:search {:product-search search/product-search}})

:wagoe/search
{:indexes {:product-search {:entity-type :product
                            :fields      [{:name :title :weight :a}]}}}

(require '[wagoe.search.ports :as ports])

(ports/index-document! search-engine :product-search product-id
  {:title "Wagoe Framework"
   :body  "A Clojure web framework..."
   :tags  "clojure framework"}
  {:filter-values {:tenant-id tenant-id}})

;; Bulk reindex: a seq of [entity-id field-values] pairs
(ports/reindex! search-engine :product-search documents)
;=> {:indexed 120}

(ports/search search-engine :product-search "clojure framework"
  {:filters {:tenant-id tenant-id}
   :limit   25
   :offset  0})
;=> {:results [{:entity-type :product :entity-id #uuid "..." :rank 0.9 :snippet "..."}]
;    :total 42
;    :query "clojure framework"
;    :took-ms 3}

clojure -M:test :search