Inkuire JS support

Author: KacperFKorban

scaladoc-js/src/searchbar/Searchbar.scala

@@ -4,5 +4,7 @@ class Searchbar {
   val pages = SearchbarGlobals.pages.toList.map(PageEntry.apply)
   val engine = SearchbarEngine(pages)
   val parser = QueryParser()
-  val component = SearchbarComponent(q => engine.query(parser.parse(q)))
-}
+  // val component = SearchbarComponent(q => engine.query(parser.parse(q)))
+  val inkuireEngine = InkuireJSSearchEngine()
+  val component = SearchbarComponent(inkuireEngine.query)
+}

scaladoc-js/src/searchbar/SearchbarComponent.scala

@@ -3,7 +3,7 @@ package dotty.tools.scaladoc
 import org.scalajs.dom._
 import org.scalajs.dom.html.Input
 
-class SearchbarComponent(val callback: (String) => List[PageEntry]):
+class SearchbarComponent(val callback: (String) => (PageEntry => Node) => Unit):
   val resultsChunkSize = 100
   extension (p: PageEntry)
     def toHTML =
@@ -28,24 +28,12 @@ class SearchbarComponent(val callback: (String) => List[PageEntry]):
       wrapper
 
   def handleNewQuery(query: String) =
-    val result = callback(query).map(_.toHTML)
     resultsDiv.scrollTop = 0
     while (resultsDiv.hasChildNodes()) resultsDiv.removeChild(resultsDiv.lastChild)
     val fragment = document.createDocumentFragment()
-    result.take(resultsChunkSize).foreach(fragment.appendChild)
-    resultsDiv.appendChild(fragment)
-    def loadMoreResults(result: List[raw.HTMLElement]): Unit = {
-      resultsDiv.onscroll = (event: Event) => {
-          if (resultsDiv.scrollHeight - resultsDiv.scrollTop == resultsDiv.clientHeight)
-          {
-              val fragment = document.createDocumentFragment()
-              result.take(resultsChunkSize).foreach(fragment.appendChild)
-              resultsDiv.appendChild(fragment)
-              loadMoreResults(result.drop(resultsChunkSize))
-          }
-      }
+    callback(query) { (p: PageEntry) =>
+      resultsDiv.appendChild(p.toHTML)
     }
-    loadMoreResults(result.drop(resultsChunkSize))
 
   private val searchIcon: html.Div =
     val span = document.createElement("span").asInstanceOf[html.Span]

scaladoc-js/src/searchbar/engine/InkuireDelegateSearchEngine.scala

@@ -0,0 +1,90 @@
+package dotty.tools.scaladoc
+
+import scala.io.Source
+import dotty.tools.scaladoc.PageEntry
+import org.scalajs.dom.webworkers.Worker
+import org.scalajs.dom._
+import scala.scalajs.js.{ JSON, Dynamic }
+import scala.collection.mutable.ListBuffer
+import scala.scalajs.js
+import scala.scalajs.js.timers._
+import org.scalajs.dom.ext.Ajax
+import scala.scalajs.js.URIUtils
+
+import scala.concurrent.ExecutionContext.global
+import scala.concurrent.ExecutionContext
+import scala.concurrent.Future
+
+case class Match(
+  prettifiedSignature: String,
+  functionName:        String,
+  packageLocation:     String,
+  pageLocation:        String
+)
+
+case class OutputFormat(
+  query:   String,
+  matches: List[Match]
+)
+
+//TODO CORS problems
+class InkuireDelegateSearchEngine {
+
+  given ec: ExecutionContext = global
+
+  val ec2 = "http://ec2-52-59-255-148.eu-central-1.compute.amazonaws.com:8080" //TODO configure
+
+  private def getURLContent(url: String): Future[String] = Ajax.get(url).map(_.responseText).fallbackTo(Future("[]"))
+  
+  def dynamicToPageEntry(d: Dynamic): PageEntry =
+    PageEntry(
+      d.functionName.asInstanceOf[String],
+      d.prettifiedSignature.asInstanceOf[String],
+      d.pageLocation.asInstanceOf[String],
+      d.functionName.asInstanceOf[String],
+      List.empty
+    )
+
+  def query(s: String)(callback: PageEntry => Node): Unit = {
+    val signature = URIUtils.encodeURIComponent(s)
+    getURLContent(ec2 + "/forSignature?signature=" + signature).map(JSON.parse(_)).foreach { (d: Dynamic) =>
+      d.matches.asInstanceOf[js.Array[Dynamic]].map(dynamicToPageEntry).foreach(callback)
+    }
+  }
+
+}
+
+class InkuireJSSearchEngine {
+
+  val scriptPath = Globals.pathToRoot + "scripts/"
+  val worker     = new Worker(s"${scriptPath}inkuire-worker.js")
+
+  def dynamicToPageEntry(d: Dynamic): PageEntry = {
+    PageEntry(
+      d.functionName.asInstanceOf[String],
+      d.prettifiedSignature.asInstanceOf[String],
+      d.pageLocation.asInstanceOf[String],
+      d.functionName.asInstanceOf[String],
+      List.empty
+    )
+  }
+
+  def query(s: String)(callback: PageEntry => Node): List[PageEntry] = {
+    worker.onmessage = _ => ()
+    val res = ListBuffer[PageEntry]()
+    val func = (msg: MessageEvent) => {
+      msg.data.asInstanceOf[String] match {
+        case "engine_ready" =>
+        case "new_query" =>
+        case q =>
+          val matches = JSON.parse(q).matches
+          val actualMatches = matches.asInstanceOf[js.Array[Dynamic]].map(dynamicToPageEntry)
+          actualMatches.foreach(callback)
+      }
+    }
+    worker.onmessage = func
+    worker.postMessage(s)
+    res.toList
+  }
+
+}