1 files changed, 57 insertions, 0 deletions
diff --git a/src/nouveau/src/nouveau_rpc.erl b/src/nouveau/src/nouveau_rpc.erl
new file mode 100644
index 000000000..02f9ce90b
--- /dev/null
+++ b/src/nouveau/src/nouveau_rpc.erl
@@ -0,0 +1,57 @@
+%%
+%% Licensed under the Apache License, Version 2.0 (the "License");
+%% you may not use this file except in compliance with the License.
+%% You may obtain a copy of the License at
+%%
+%%     http://www.apache.org/licenses/LICENSE-2.0
+%%
+%% Unless required by applicable law or agreed to in writing, software
+%% distributed under the License is distributed on an "AS IS" BASIS,
+%% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+%% See the License for the specific language governing permissions and
+%% limitations under the License.
+
+%% -*- erlang-indent-level: 4;indent-tabs-mode: nil -*-
+
+-module(nouveau_rpc).
+
+-export([
+    search/3,
+    info/2,
+    cleanup/2
+]).
+
+-include("nouveau.hrl").
+-import(nouveau_util, [index_path/1]).
+
+search(DbName, #index{} = Index0, QueryArgs) ->
+    %% Incorporate the shard name into the record.
+    Index1 = Index0#index{dbname = DbName},
+    Update = maps:get(update, QueryArgs, true),
+
+    %% check if index is up to date
+    case Update andalso nouveau_index_updater:outdated(Index1) of
+        true ->
+            case nouveau_index_manager:update_index(Index1) of
+                ok ->
+                    ok;
+                {error, Reason} ->
+                    rexi:reply({error, Reason})
+            end;
+        false ->
+            ok;
+        {error, Reason} ->
+            rexi:reply({error, Reason})
+    end,
+
+    %% Run the search
+    rexi:reply(nouveau_api:search(Index1, QueryArgs)).
+
+info(DbName, #index{} = Index0) ->
+    %% Incorporate the shard name into the record.
+    Index1 = Index0#index{dbname = DbName},
+    rexi:reply(nouveau_api:index_info(Index1)).
+
+cleanup(DbName, Exclusions) ->
+    nouveau_api:delete_path(nouveau_util:index_name(DbName), Exclusions),
+    rexi:reply(ok).