Support common wrapper

Author: DifferentialOrange

tarantool/connection_pool.py

@@ -210,24 +210,13 @@ def connect(self):
 
         self.update_ro_info()
 
-    def call(self, func_name, *args, **kwargs):
-        mode = kwargs.get('mode', Mode.PREFER_RW)
+    def send_with_reload_on_ro_error(self, method_name, mode, *args, **kwargs):
         conn = self.strategy.getnext(mode)
-        
-        # try:
-        resp = conn.call(func_name, args)
-        # except ValueError:
-            #reload
-            # resp = conn.call(func_name, args)
-        
-        return resp
+        method = getattr(Connection, method_name)
+        print(args)
 
-    def eval(self, expr, *args, **kwargs):        
-        mode = kwargs.get('mode', Mode.PREFER_RW)
-        conn = self.strategy.getnext(mode)
-        
         try:
-            resp = conn.eval(expr, args)
+            resp = method(conn, *args, **kwargs)
         except DatabaseError as e:
             if len(e.args) > 0:
                 strerror = tnt_strerror(e.args[0])
@@ -237,12 +226,21 @@ def eval(self, expr, *args, **kwargs):
             if strerror != 'UNDEFINED' and strerror[0] == 'ER_READONLY':
                 self.update_ro_info()
                 conn = self.strategy.getnext(mode)
-                resp = conn.eval(expr, args)
+                resp = method(conn, *args, **kwargs)
             else:
                 raise
 
         return resp
 
+
+    def call(self, func_name, *args, **kwargs):
+        mode = kwargs.get('mode', Mode.PREFER_RW)
+        return self.send_with_reload_on_ro_error('call', mode, func_name, *args)
+
+    def eval(self, expr, *args, **kwargs):  
+        mode = kwargs.get('mode', Mode.PREFER_RW)
+        return self.send_with_reload_on_ro_error('eval', mode, expr, *args)
+
     def replace(self, space_name, values):
         raise NotImplementedError