Tweaks on Client init to make api credentials optional

piker/brokers/deribit/api.py

@@ -119,26 +119,29 @@ def get_config() -> dict[str, Any]:
 
     section = conf.get('deribit')
 
-    if section is None:
-        log.warning(f'No config section found for deribit in {path}')
-        return {}
-
     conf['log'] = {}
     conf['log']['disabled'] = True
 
+    if section is None:
+        log.warning(f'No config section found for deribit in {path}')
+
     return conf 
 
 
 class Client:
 
     def __init__(self, n: Nursery, ws: NoBsWs) -> None:
-        self._sesh = asks.Session(connections=4)
-        self._sesh.base_location = _url
         self._pairs: dict[str, Any] = {}
 
-        config = get_config()['deribit']
-        self._key_id = config['key_id']
-        self._key_secret = config['key_secret']
+        config = get_config().get('deribit', {})
+
+        if ('key_id' in config) and ('key_secret' in config):
+            self._key_id = config['key_id']
+            self._key_secret = config['key_secret']
+
+        else:
+            self._key_id = None
+            self._key_secret = None
 
         self._ws = ws 
         self._n = n 
@@ -160,7 +163,9 @@ class Client:
 
     async def start_rpc(self):
         self._n.start_soon(self._recv_task)
-        await self._n.start(self._auth_loop)
+
+        if self._key_id is not None:
+            await self._n.start(self._auth_loop)
 
     async def _recv_task(self):
         while True:
@@ -238,18 +243,6 @@ class Client:
             else:
                 await trio.sleep(renew_time / 2)
 
-    async def _api(
-        self,
-        method: str,
-        params: dict,
-    ) -> dict[str, Any]:
-        resp = await self._sesh.get(
-            path=f'/api/v2/public/{method}',
-            params=params,
-            timeout=float('inf')
-        )
-        return resproc(resp, log)
-
     async def symbol_info(
         self,
         instrument: Optional[str] = None,

piker/brokers/deribit/broker.py

@@ -30,3 +30,4 @@ async def trades_dialogue(
     get_console_log(loglevel or tractor.current_actor().loglevel)
 
     async with get_client() as client:
+        ...