Added entities.

Pipfile

@@ -9,7 +9,7 @@ pylint = "*"
 [packages]
 flask = "*"
 flask-restful = "*"
-py4j = "*"
+rpyc = "*"
 
 [requires]
 python_version = "3.8"

file_indexer_api/common/connection_handler.py

@@ -0,0 +1,8 @@
+from rpyc import connect
+
+class ConnectionHandler(object):
+    connection = connect('localhost', 18861)
+    root = None
+
+    def get_handler(self):
+        return self.root

file_indexer_api/common/connection_handler_factory.py

@@ -0,0 +1,11 @@
+from file_indexer_api.common.connection_handler import ConnectionHandler
+from file_indexer_api.common.indexer_handler import IndexerHandler
+from file_indexer_api.common.searcher_handler import SearcherHandler
+
+class ConnectionHandlerFactory():
+    @staticmethod
+    def create_connection_handler(type):
+        if type == 'indexer':
+            return IndexerHandler
+        if type == 'searcher':
+            return SearcherHandler

file_indexer_api/common/indexer_handler.py

@@ -0,0 +1,4 @@
+from file_indexer_api.common.connection_handler import ConnectionHandler
+
+class IndexerHandler(ConnectionHandler):
+    root = ConnectionHandler.root.index()

file_indexer_api/common/searcher_handler.py

@@ -0,0 +1,4 @@
+from file_indexer_api.common.connection_handler import ConnectionHandler
+
+class SearcherHandler(ConnectionHandler):
+    root = ConnectionHandler.root.searcher()

file_indexer_api/entities/indexer.py

@@ -0,0 +1,8 @@
+from file_indexer_api.common.connection_handler_factory import ConnectionHandlerFactory
+
+class Indexer():
+    def __init__(self):
+        self.indexer = ConnectionHandlerFactory.create_connection_handler('indexer')
+
+    def index(self, path): 
+        self.indexer.get_handler(path)

file_indexer_api/entities/searcher.py

@@ -0,0 +1,8 @@
+from file_indexer_api.common.connection_handler_factory import ConnectionHandlerFactory
+
+class Searcher():
+    def __init__(self):
+        self.searcher = ConnectionHandlerFactory.create_connection_handler('indexer')
+
+    def search(self, query): 
+        self.searcher.get_handler(query)