From 91856ddda8e777bfd2244bfe101edb624365f0f9 Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Fri, 18 Feb 2022 12:13:38 -0500
Subject: [PATCH] Better handle nested erros from docker client

---
 piker/data/_ahab.py | 29 ++++++++++++++++++++++++-----
 1 file changed, 24 insertions(+), 5 deletions(-)

diff --git a/piker/data/_ahab.py b/piker/data/_ahab.py
index baa396ab..ed81fed0 100644
--- a/piker/data/_ahab.py
+++ b/piker/data/_ahab.py
@@ -32,7 +32,7 @@ import tractor
 import docker
 import json
 from docker.models.containers import Container
-from docker.errors import DockerException
+from docker.errors import DockerException, APIError
 from requests.exceptions import ConnectionError
 
 from ..log import get_logger  # , get_console_log
@@ -102,10 +102,23 @@ async def open_docker(
         # prolly no daemon started
         raise DockerNotStarted('!?!?')
 
-    except DockerException as err:
+    except (
+        DockerException,
+        APIError,
+    ) as err:
+
+        def unpack_msg(err: Exception) -> str:
+            args = getattr(err, 'args', None)
+            if args:
+                return args
+
         # could be more specific so let's check if it's just perms.
-        if 'PermissionError' in err.args[0]:
-            raise DockerException('You dint run as root yo!')
+        if err.args:
+            errs = err.args
+            for err in errs:
+                msg = unpack_msg(err)
+                if msg and 'PermissionError' in msg:
+                    raise DockerException('You dint run as root yo!')
 
         # not perms?
         raise
@@ -233,7 +246,13 @@ async def start_ahab(
         loglevel='runtime',
     ) as tn:
 
-        portal = await tn.start_actor('ahab', enable_modules=[__name__])
+        portal = await tn.start_actor(
+            'marketstored',
+            enable_modules=[__name__]
+        )
+
+        # de-escalate root perms to the original user
+        # after the docker supervisor actor is spawned.
         if config._parent_user:
             import pwd
             os.setuid(