make things work

Author: siku2

Diff for: .gitignore

@@ -1,3 +1,4 @@
 .idea/
+*.build/
 
 config.toml

Diff for: Pipfile

@@ -11,7 +11,8 @@ aioredis = "*"
 autobahn = "*"
 konfi = "*"
 click = "*"
-uvloop = {markers="sys_platform != 'win32'"}
+uvloop = {markers = "sys_platform != 'win32'"}
+cbor = "*"
 
 [requires]
 python_version = "3.7"

Diff for: Pipfile.lock

@@ -1,3 +1,9 @@
 # Ari Player
 
 Giesela's player service
+
+
+## Required Components
+
+- [Wampus](https://github.com/gieseladev/wampus) `io.giesela.wampus`
+- [Elakshi](https://github.com/gieseladev/elakshi) `io.giesela.elakshi`

Diff for: README.md

@@ -171,7 +171,7 @@ async def create_ari_server(config: ari.Config, *, loop: asyncio.AbstractEventLo
                                                 user_id=config.andesite.user_id,
                                                 loop=loop)
     server = AriServer(redis, config.redis.namespace, andesite_ws)
-    andesite_ws.state = andesite.AndesiteState[Any](state_factory=server.get_player)
+    andesite_ws.state = andesite.AndesiteState(state_factory=server.get_player)
 
     return server
 
@@ -180,15 +180,15 @@ def create_component(server: AriServer, config: ari.Config) -> Component:
     """Create the WAMP component."""
     component = Component(
         realm=config.realm,
-        transports=config.get_transports(),
+        transports=config.transports,
     )
 
     @component.on_join
     async def joined(session: ISession, details: SessionDetails) -> None:
-        log.info("joined session %s: %s", session, details)
+        log.info("joined session (realm: %s)", details.realm)
         server._session = session
 
-        await session.register(server, preifx=f"io.giesela.ari.")
+        await session.register(server, prefix=f"io.giesela.ari.")
         await session.subscribe(server)
 
     return component

Diff for: ari/component.py

@@ -1,4 +1,4 @@
-from typing import Dict, Iterable, List, Optional, Tuple, Union
+from typing import Iterable, List, Optional, Tuple, Union
 
 import konfi
 
@@ -35,35 +35,14 @@ def get_node_tuples(self) -> Iterable[Tuple[str, str]]:
         return (node.as_tuple() for node in self.nodes)
 
 
-@konfi.template()
-class Transport:
-    """Transport configuration."""
-    type: str = "websocket"
-    url: str
-
-    def as_dict(self) -> Dict[str, str]:
-        return {
-            "type": self.type,
-            "url": self.url,
-        }
-
-
 @konfi.template()
 class Config:
     """Ari configuration"""
     redis: Redis
     andesite: Andesite
 
     realm: str
-    transports: Union[List[Transport], str]
-
-    def get_transports(self) -> Union[List[Dict[str, str]], str]:
-        """Get the transports configuration in the format required by
-        the component constructor."""
-        if isinstance(self.transports, str):
-            return self.transports
-        else:
-            return [transport.as_dict() for transport in self.transports]
+    transports: Union[List[dict], str]
 
 
 def load_config(config_file: str) -> Config: