{% if opts.app_label == "core" and opts.model_name == "snapshot" and not embedded_changelist %}
<script>
  (function() {
    if (window.archiveboxSnapshotSearchStreamReady) return;
    window.archiveboxSnapshotSearchStreamReady = true;
    var activeSearch = null;

    function cancelActiveSearch(event) {
      if (!event.target || (event.target.name !== "q" && event.target.name !== "search_mode")) return;
      if (activeSearch) activeSearch.abort();
    }

    function streamSnapshotSearch(eventOrForm) {
      var form = eventOrForm && eventOrForm.target ? eventOrForm.target : eventOrForm;
      if (!form || form.id !== "changelist-search") return;

      var formData = new FormData(form);
      var mode = String(formData.get("search_mode") || "meta");
      var query = String(formData.get("q") || "").trim();
      if (!query) return;

      if (eventOrForm && eventOrForm.preventDefault) eventOrForm.preventDefault();
      if (activeSearch) activeSearch.abort();

      var controller = new AbortController();
      activeSearch = controller;
      var resultVersion = 0;
      var pendingRender = null;
      var renderInFlight = false;
      var renderedVersion = -1;
      var lastRender = 0;

      function buildListUrl() {
        var url = new URL(window.location.href);
        for (var pair of formData.entries()) url.searchParams.set(pair[0], pair[1]);
        url.searchParams.delete("p");
        return url;
      }

      function renderNow() {
        clearTimeout(pendingRender);
        pendingRender = null;
        if (renderInFlight || renderedVersion === resultVersion) return;
        var url = buildListUrl();
        renderInFlight = true;
        renderedVersion = resultVersion;
        lastRender = Date.now();
        fetch(url, {headers: {"X-Requested-With": "XMLHttpRequest"}, signal: controller.signal})
          .then(function(response) { return response.text(); })
          .then(function(html) {
            var doc = new DOMParser().parseFromString(html, "text/html");
            var nextMain = doc.getElementById("content-main");
            var currentMain = document.getElementById("content-main");
            if (nextMain && currentMain) {
              currentMain.replaceWith(nextMain);
              if (window.archiveboxInitAdminChangelist) window.archiveboxInitAdminChangelist();
              if (window.archiveboxInitChangelistFilters) window.archiveboxInitChangelistFilters();
              history.replaceState(null, "", url);
            }
          })
          .catch(function(error) {
            if (error.name !== "AbortError") throw error;
          })
          .finally(function() {
            renderInFlight = false;
            if (renderedVersion !== resultVersion) renderSoon();
          });
      }

      function renderSoon(force) {
        if (force) return renderNow();
        if (!pendingRender) {
          pendingRender = setTimeout(renderNow, Math.max(0, 300 - (Date.now() - lastRender)));
        }
      }

      var listUrl = buildListUrl();
      var streamUrl = new URL("{% url 'admin:core_snapshot_search_stream' %}", window.location.href);
      streamUrl.searchParams.set("q", query);
      streamUrl.searchParams.set("search_mode", mode);
      // The backend cache key is this exact changelist URL plus the user id.
      // Stream chunks only say "new result count"; the page fetch reads IDs from cache.
      streamUrl.searchParams.set("search_url", listUrl.pathname + listUrl.search);
      fetch(streamUrl, {signal: controller.signal})
        .then(function(response) {
          var reader = response.body.getReader();
          var decoder = new TextDecoder();
          var buffer = "";
          function read() {
            return reader.read().then(function(result) {
              buffer += decoder.decode(result.value || new Uint8Array(), {stream: !result.done});
              var lines = buffer.split("\n");
              buffer = lines.pop();
              lines.forEach(function(count) {
                count = parseInt(count.trim(), 10);
                resultVersion = Number.isFinite(count) ? count : resultVersion + 1;
              });
              if (lines.length) renderSoon();
              if (!result.done) return read();
              renderSoon(true);
            });
          }
          return read();
        })
        .catch(function(error) {
          if (error.name !== "AbortError") throw error;
        })
        .finally(function() {
          if (activeSearch === controller) activeSearch = null;
        });
    }

    document.addEventListener("input", cancelActiveSearch);
    document.addEventListener("change", cancelActiveSearch);
    document.addEventListener("submit", streamSnapshotSearch);
    var initialForm = document.getElementById("changelist-search");
    if (initialForm && initialForm.tagName === "FORM" && String(new FormData(initialForm).get("q") || "").trim()) {
      streamSnapshotSearch(initialForm);
    }
  })();
</script>
{% endif %}