SearchQueryIndexer.elm

module SearchQueryIndexer exposing (main)


import Stream exposing (Stream, Pipeline)


main : Pipeline
main =
    Stream.readFrom "searches"
    |> Stream.filter (\search -> search.resultCount > 0)
    |> Stream.map .query
    |> Stream.filter (\query -> String.length query > 10)
    |> Stream.filter (\query -> String.length query < 50)
    |> Stream.map normalizeQuery
    |> Stream.writeTo "search-queries"


normalizeQuery : String -> String
normalizeQuery query =
    String.toLower query