(ns snapkitty.lisp.knowledge.qdrant
  "Qdrant vector database client — ENFORCED auth"
  (:require [promesa.core :as p]
            ["node-fetch" :default fetch]))

(defn http-request [cfg method path {:keys [body]}]
  "Make authenticated HTTP request to Qdrant — REQUIRES API KEY"
  (let [url (str (:qdrant-url cfg) path)
        headers {"Content-Type" "application/json"
                 "api-key" (:qdrant-key cfg)}
        options (clj->js (merge {:method method
                                 :headers headers}
                                (when body {:body (js/JSON.stringify body)})))]
    (p/let [response (fetch url options)]
      (if (.-ok response)
        (.json response)
        (throw (ex-info (str "Qdrant error: " (.-status response))
                        {:status (.-status response)}))))))

(defn ensure-collection! [cfg]
  "Create collection if it doesn't exist"
  (let [coll-name (:collection-name cfg)]
    (p/let [_ (http-request cfg "PUT"
                            (str "/collections/" coll-name)
                            {:body {:vectors {:size 384
                                             :distance "Cosine"}}})]
      (js/console.log (str "[qdrant] Collection '" coll-name "' ready")))))

(defn upsert-point! [cfg coll-id vector {:keys [id payload]}]
  "Insert/update vector with metadata"
  (http-request cfg "PUT"
                (str "/collections/" coll-id "/points")
                {:body {:points [{:id id
                                 :vector vector
                                 :payload payload}]}}))

(defn search-points [cfg coll-id query-vector {:keys [limit filter]}]
  "Search for nearest vectors"
  (http-request cfg "POST"
                (str "/collections/" coll-id "/points/search")
                {:body {:vector query-vector
                       :limit (or limit 10)
                       :filter filter}}))

(defn delete-point! [cfg coll-id point-id]
  "Delete a point by ID"
  (http-request cfg "POST"
                (str "/collections/" coll-id "/points/delete")
                {:body {:points_selector {:ids [point-id]}}}))