Improve API of clientarch

siriuspy/siriuspy/clientarch/devices.py

@@ -40,7 +40,9 @@ def __init__(self, devname, propty='', connector=None):
         self._times = None
         self._values = None
         super().__init__(pvnames, connector=connector)
-        self._parallel_query_bin_interval = 3600
+        self.query_split_interval = 3600
+        self.processing_type = self.ProcessingTypes.Mean
+        self.processing_type_param1 = 1
 
     @property
     def devnames(self):
@@ -57,12 +59,12 @@ def values(self):
         """Return retrieved orbit interpolated values."""
         return self._values
 
-    def update(self, mean_sec=None, parallel=True):
+    def update(self, query_timeout=None):
         """Update state by retrieving data."""
-        super().update(mean_sec=mean_sec, parallel=parallel)
+        super().update(query_timeout=query_timeout)
 
         # interpolate data
-        self._times, self._values = self._interpolate_data(mean_sec)
+        self._times, self._values = self._interpolate_data()
 
     # --- private methods ---
 
@@ -71,9 +73,10 @@ def _get_pvnames(self):
         pvnames = []
         return devnames, pvnames
 
-    def _interpolate_data(self, mean_sec):
+    def _interpolate_data(self):
         # calc mean_sec if not passed
         nr_pvs = len(self._pvdata)
+        mean_sec = self.processing_type_param1
         if mean_sec is None:
             mean_sec = sum(
                 map(
@@ -84,7 +87,7 @@ def _interpolate_data(self, mean_sec):
             mean_sec /= nr_pvs
 
         # times vector
-        t0_, t1_ = self.timestamp_start, self.timestamp_stop
+        t0_, t1_ = self.time_start.timestamp(), self.time_stop.timestamp()
         times = _np.arange(t0_, t1_, mean_sec)
 
         # builds orbit matrix using interpolation

siriuspy/siriuspy/clientarch/exceptions.py

@@ -2,6 +2,8 @@
 
 import asyncio as _asyncio
 
+import aiohttp.client_exceptions as _aio_excep
+
 
 class ClientArchError(Exception):
     """ClientArch Abstract Exception."""
@@ -15,6 +17,10 @@ class TimeoutError(ClientArchError, _asyncio.TimeoutError):
     """ClientArch Timeout Exception."""
 
 
+class PayloadError(ClientArchError, _aio_excep.ClientPayloadError):
+    """ClientArch Timeout Exception."""
+
+
 class RuntimeError(ClientArchError, RuntimeError):
     """ClientArch Runtime Exception."""