Merge branch 'master' into receive_buffer_upstream

Author: dannytrigo

CHANGES

@@ -1,3 +1,9 @@
+1.2.10 (2024-03-09)
+    - Retrieve zone from decoded commands
+
+1.2.9 (2024-03-07)
+    - Fix disconnected socket in async API
+
 1.2.8 (2019-11-09)
     - Added HDMI-CEC TV control support via CTV command. See 'onkyo --help-commands main ctv' for possible values.
 

eiscp/core.py

@@ -244,27 +244,27 @@ def command_to_iscp(command, arguments=None, zone=None):
     return '{}{}'.format(prefix, value)
 
 
-def iscp_to_command(iscp_message):
-    for zone, zone_cmds in commands.COMMANDS.items():
-        # For now, ISCP commands are always three characters, which
-        # makes this easy.
-        command, args = iscp_message[:3], iscp_message[3:]
-        if command in zone_cmds:
-            if args in zone_cmds[command]['values']:
-                return zone_cmds[command]['name'], \
-                       zone_cmds[command]['values'][args]['name']
-            else:
-                match = re.match('[+-]?[0-9a-f]+$', args, re.IGNORECASE)
-                if match:
-                    return zone_cmds[command]['name'], \
-                             int(args, 16)
+def iscp_to_command(iscp_message, with_zone=False):
+    def __iscp_to_command(iscp_message):
+        for zone, zone_cmds in commands.COMMANDS.items():
+            # For now, ISCP commands are always three characters, which
+            # makes this easy.
+            command, args = iscp_message[:3], iscp_message[3:]
+            if command in zone_cmds:
+                if args in zone_cmds[command]['values']:
+                    return zone, zone_cmds[command]['name'], \
+                           zone_cmds[command]['values'][args]['name']
                 else:
-                    return zone_cmds[command]['name'], args
-
-    else:
-        raise ValueError(
-            'Cannot convert ISCP message to command: {}'.format(iscp_message))
-
+                    match = re.match('[+-]?[0-9a-f]+$', args, re.IGNORECASE)
+                    if match:
+                        return zone, zone_cmds[command]['name'], int(args, 16)
+                    else:
+                        return zone, zone_cmds[command]['name'], args
+        else:
+            raise ValueError(
+                'Cannot convert ISCP message to command: {}'.format(iscp_message))
+    zone, ret_cmd, args = __iscp_to_command(iscp_message)
+    return (zone, ret_cmd, args) if with_zone else (ret_cmd, args)
 
 def filter_for_message(getter_func, msg):
     """Helper that calls ``getter_func`` until a matching message

setup.py

@@ -11,13 +11,13 @@
 f.close()
 
 setup(
-    name='onkyo-eiscp',
-    version='1.2.8',
-    url='https://github.com/miracle2k/onkyo-eiscp',
+    name='dannytrigo-onkyo-eiscp',
+    version='1.2.10',
+    url='https://github.com/dannytrigo/onkyo-eiscp',
     license='MIT',
     author='Michael Elsdörfer',
     author_email='michael@elsdoerfer.com',
-    description='Control Onkyo receivers over ethernet.',
+    description='Control Onkyo receivers over ethernet. (dannytrigo fork for bugfix)',
     long_description=long_description,
     packages = find_packages(exclude=('tests*',)),
     entry_points="""[console_scripts]\nonkyo = eiscp.script:run\n""",

tests/test_core.py

@@ -1,14 +1,19 @@
 from eiscp.core import iscp_to_command, command_to_iscp
+from unittest import TestCase
 
-
-class TestIscpToCommand:
+class TestIscpToCommand(TestCase):
     def test(self):
-        assert iscp_to_command('MVL') == ('master-volume', '')
+        self.assertEqual(('master-volume', ''), iscp_to_command('MVL'))
 
+    def test_with_zone(self):
+        self.assertEqual(('main', 'audio-muting', ''), iscp_to_command('AMT', True))
+        self.assertEqual(('zone2', 'muting', ''), iscp_to_command('ZMT', True))
+        self.assertEqual(('zone3', 'muting', ''), iscp_to_command('MT3', True))
+        self.assertEqual(('zone4', 'muting', ''), iscp_to_command('MT4', True))
 
-class TestCommandToIscp:
+class TestCommandToIscp(TestCase):
     def test(self):
-        assert command_to_iscp('main.system-power=standby') == 'PWR00'
+        self.assertEqual('PWR00', command_to_iscp('main.system-power=standby'))
 
     def test_argument_aliases(self):
-        assert command_to_iscp('main.system-power=off') == 'PWR00'
+        self.assertEqual('PWR00', command_to_iscp('main.system-power=off'))