added excel->json recorder source generation script

backend/recorder_adapters/__init__.py

@@ -100,6 +100,10 @@ class RecorderAdapter:
     def _get_version(self):
         pass
 
+    @abstractmethod
+    def is_recording(self) -> bool:
+        pass
+
 
 def get_defined_recorder_adapters():
     models = []

backend/recorder_adapters/epiphan_base.py

@@ -0,0 +1,142 @@
+#  Copyright (c) 2019. Tobias Kurze
+import shutil
+import time
+from datetime import datetime
+from pprint import pprint
+
+import requests
+from requests.auth import HTTPBasicAuth
+
+from backend import LrcException
+from backend.recorder_adapters import RecorderAdapter
+
+# HOST = "localhost"
+BASE_URL = "http://172.23.8.102"  # Audimax SMP 351
+
+USER = "admin"
+PW = "lrgrashof+-"
+
+
+class EpiphanV1(RecorderAdapter):
+
+    def __init__(self, admin_user: str, admin_pw: str):
+        self.user = admin_user
+        self.password = admin_pw
+        self.session = requests.Session()
+        self.session.auth = HTTPBasicAuth(self.user, self.password)
+
+    def _get_name(self):
+        pass
+
+    def _get_version(self):
+        pass
+
+    def get_status(self) -> dict:
+        res = self.session.get(BASE_URL + "/admin/ajax/recorder_status.cgi")
+        if res.ok:
+            return res.json()
+        raise LrcException(res.text, res.status_code)
+
+    def get_sysinfo(self) -> dict:
+        res = self.session.get(BASE_URL + "/ajax/sysinfo.cgi")
+        if res.ok:
+            return res.json()
+        raise LrcException(res.text, res.status_code)
+
+    def is_recording(self) -> bool:
+        state = self.get_status().get('state', None)
+        return state == "up"
+
+    def get_recording_time(self):
+        """
+        Returns recording time in seconds. Also returns 0 if not recording.
+        :return:
+        """
+        return self.get_status().get('seconds', None)
+
+    def start_recording(self):
+        res = self.session.get(BASE_URL + "/admin/ajax/start_recorder.cgi")
+        if not res.ok:
+            raise LrcException(res.text, res.status_code)
+        time.sleep(2)  # just a little bit of waiting time -> it takes a bit for the Epiphan to update its state
+
+    def stop_recording(self):
+        res = self.session.get(BASE_URL + "/admin/ajax/stop_recorder.cgi")
+        if not res.ok:
+            raise LrcException(res.text, res.status_code)
+        time.sleep(4)  # just a little bit of waiting time -> it takes a bit for the Epiphan to update its state
+
+    def get_ip_address(self):
+        try:
+            return self.get_sysinfo().get("system").get("network").get("interfaces")[0].get('ipaddr', None)
+        except Exception as err:
+            raise LrcException(str(err))
+
+    def get_disk_space(self):
+        try:
+            data = self.get_sysinfo().get("system").get("data")
+            return {'available': data.get("available", None), 'free': data.get("free", None),
+                    'total': data.get("total", None), 'used': data.get("total", 0) - data.get("available", 0)}
+        except Exception as err:
+            raise LrcException(str(err))
+
+    def get_video_inputs(self) -> list:
+        ret = []
+        try:
+            video = self.get_sysinfo().get("inputs").get("video")
+            for v in video:
+                ret.append(
+                    {'id': v.get('id', None), 'name': v.get('name', None), 'resolution': v.get('resolution', None)})
+            return ret
+        except Exception as err:
+            raise LrcException(str(err))
+
+    def get_hardware_revision(self):
+        try:
+            return self.get_sysinfo().get("system").get("firmware")
+        except Exception as err:
+            raise LrcException(str(err))
+
+    def get_system_time(self):
+        try:
+            time_stamp = self.get_sysinfo().get("time")
+            return {'unix_time_stamp': time_stamp,
+                    'date_time_utc': datetime.utcfromtimestamp(time_stamp).strftime('%Y-%m-%dT%H:%M:%SZ')}
+        except Exception as err:
+            raise LrcException(str(err))
+
+    def get_screenshot(self):
+        ret = self.session.get(BASE_URL + "/admin/grab_frame.cgi?size=256x192&device=DAV93133.vga&_t=1573471990578",
+                               stream=True)
+
+        print(ret)
+        pprint(ret.headers)
+        with open('out.jpg', 'wb') as out_file:
+            shutil.copyfileobj(ret.raw, out_file)
+        del ret
+
+
+if __name__ == '__main__':
+    e = EpiphanV1(USER, PW)
+    try:
+        # print(e.is_recording())
+        """
+        if e.is_recording():
+            e.stop_recording()
+        else:
+            e.start_recording()
+        print(e.is_recording())
+        """
+
+        """
+        print(e.get_ip_address())
+        print(e.get_disk_space())
+        print(e.get_video_inputs())
+        print(e.get_hardware_revision())
+        print(e.get_system_time())
+        """
+
+        e.get_screenshot()
+
+    except LrcException as e:
+        print(e)

backend/recorder_adapters/extron_smp.py

@@ -6,13 +6,13 @@ REQUIRES_USER = False
 REQUIRES_PW = True
 
 # HOST = "localhost"
-HOST = "129.13.51.102"  # Audimax SMP 351
+# HOST = "129.13.51.102"  # Audimax SMP 351
 # HOST = "129.13.51.106"  # Tulla SMP 351
-# HOST = "172.22.246.207"  # Test SMP MZ
+HOST = "172.22.246.207"  # Test SMP MZ
 
 USER = "admin"
 PW = "123mzsmp"
-PW = "audimaxsmp"
+#PW = "audimaxsmp"
 
 
 class SMP(TelnetAdapter, RecorderAdapter):
@@ -701,6 +701,9 @@ class SMP(TelnetAdapter, RecorderAdapter):
         some advanced options skipped
     """
 
+    def is_recording(self) -> bool:
+        pass
+
     def get_input_hdcp_status(self, input_number: int):
         """
         returns: