Merge pull request #2 from SantiagoSotoC/add-path-property-to-stream

Add path property to stream

.gitignore

@@ -3,6 +3,8 @@ snapcast.egg-info*
 .cache
 .coverage
 .tox
+.venv
+dist
 MANIFEST
 .venv
 dist

snapcast/control/server.py

@@ -44,6 +44,8 @@
 STREAM_SETMETA = 'Stream.SetMeta'  # deprecated
 STREAM_ONUPDATE = 'Stream.OnUpdate'
 STREAM_ONMETA = 'Stream.OnMetadata'  # deprecated
+STREAM_ADDSTREAM = 'Stream.AddStream' 
+STREAM_REMOVESTREAM = 'Stream.RemoveStream' 
 
 SERVER_RECONNECT_DELAY = 5
 
@@ -55,12 +57,15 @@
             SERVER_DELETECLIENT, CLIENT_GETSTATUS, CLIENT_SETNAME,
             CLIENT_SETLATENCY, CLIENT_SETVOLUME,
             GROUP_GETSTATUS, GROUP_SETMUTE, GROUP_SETSTREAM, GROUP_SETCLIENTS,
-            GROUP_SETNAME, STREAM_SETMETA, STREAM_SETPROPERTY, STREAM_CONTROL]
+            GROUP_SETNAME, STREAM_SETMETA, STREAM_SETPROPERTY, STREAM_CONTROL, 
+            STREAM_ADDSTREAM, STREAM_REMOVESTREAM ]
 
 # server versions in which new methods were added
 _VERSIONS = {
     GROUP_SETNAME: '0.16.0',
     STREAM_SETPROPERTY: '0.26.0',
+    STREAM_ADDSTREAM: '0.26.0',
+    STREAM_REMOVESTREAM: '0.26.0',
 }
 
 
@@ -238,6 +243,19 @@ def stream_setproperty(self, identifier, stream_property, value):
             'value': value
             })
 
+    async def stream_add_stream(self, stream_uri):
+        """Add a stream."""
+        params = {"streamUri" : stream_uri}
+        result = await self._transact(STREAM_ADDSTREAM, params)
+        status = await self.status()
+        self._on_server_update(status)
+        return result
+
+    async def stream_remove_stream(self, identifier):
+        """Remove a Stream."""
+        result = await self._request(STREAM_REMOVESTREAM, identifier)
+        return result
+
     def group(self, group_identifier):
         """Get a group."""
         return self._groups[group_identifier]

snapcast/control/stream.py

@@ -45,7 +45,13 @@ def meta(self):
     def properties(self):
         """Get properties."""
         return self._stream.get('properties')
-
+
+    @property
+    def path(self):
+        """Get stream path."""
+        return self._stream.get('uri').get('path')
+
+    @property
     def update(self, data):
         """Update stream."""
         self._stream = data