Revert "Revert "Revert "make all searches (and counts) fail"""
This reverts commit 27a8be71e7
.
This commit is contained in:
parent
49296d9f42
commit
a925edf069
|
@ -1,11 +1,12 @@
|
|||
package lila.search
|
||||
|
||||
import actorApi._
|
||||
import akka.actor._
|
||||
import akka.pattern.pipe
|
||||
import play.api.libs.json._
|
||||
import scalastic.elasticsearch.{ Indexer ⇒ EsIndexer }
|
||||
|
||||
import actorApi._
|
||||
|
||||
final class TypeIndexer(
|
||||
esIndexer: Fu[EsIndexer],
|
||||
indexName: String,
|
||||
|
@ -13,19 +14,15 @@ final class TypeIndexer(
|
|||
mapping: JsObject,
|
||||
indexQuery: JsObject ⇒ Funit) extends Actor {
|
||||
|
||||
private val disabled = new RuntimeException("Search is disabled")
|
||||
|
||||
def receive = {
|
||||
|
||||
case Search(request) ⇒ sender ! Status.Failure(disabled)
|
||||
// withEs { es ⇒
|
||||
// SearchResponse(request.in(indexName, typeName)(es))
|
||||
// } pipeTo sender
|
||||
case Search(request) ⇒ withEs { es ⇒
|
||||
SearchResponse(request.in(indexName, typeName)(es))
|
||||
} pipeTo sender
|
||||
|
||||
case Count(request) ⇒ sender ! Status.Failure(disabled)
|
||||
// withEs { es ⇒
|
||||
// CountResponse(request.in(indexName, typeName)(es))
|
||||
// } pipeTo sender
|
||||
case Count(request) ⇒ withEs { es ⇒
|
||||
CountResponse(request.in(indexName, typeName)(es))
|
||||
} pipeTo sender
|
||||
|
||||
case RebuildAll ⇒ {
|
||||
self ! Clear
|
||||
|
|
Loading…
Reference in a new issue