from bridge import AsyncBridge as Bridge
from browser import aio, console as log, window
from cache import cache
import json

log.warning = log.warn
profile = window.profile or ""
bridge = Bridge()


class JidSearch:

    def __init__(self, search_elt, callback, empty_cb=None):
        self.search_elt = search_elt
        self.search_elt.bind("input", self.on_search_input)
        self.last_query = None
        self.current_query = None
        self.callback = callback
        self.empty_cb = empty_cb
        current_search = search_elt.value.strip() or None
        if current_search is not None:
            aio.run(self.perform_search(current_search))

    def on_search_input(self, evt):
        search_text = evt.target.value.strip()
        if not search_text and self.empty_cb is not None:
            self.empty_cb()
        elif len(search_text) > 2:
            aio.run(self.perform_search(search_text))

    async def perform_search(self, query):
        if self.current_query is None:
            log.debug(f"performing search: {query=}")
            self.current_query = query
            jid_items = json.loads(await bridge.jid_search(query, ""))
            await cache.fill_identities(i["entity"] for i in jid_items)

            self.last_query = query
            self.current_query = None
            current_query = self.search_elt.value.strip()
            if current_query != query:
                await self.perform_search(current_query)
                return
            self.callback(jid_items)