oops, type hint didn't go there. :)

Author: mikeckennedy

code/ch8-async-databases/.idea/ch8-async-databases.iml

@@ -107,7 +107,7 @@ def find_users(data: List[dict]) -> dict:
 
     with progressbar.ProgressBar(max_value=len(data)) as bar:
         for idx, p in enumerate(data):
-            info = p.get('info')
+            info = p.get('info', {})
             found_users.update(get_email_and_name_from_text(info.get('author'), info.get('author_email')))
             found_users.update(get_email_and_name_from_text(info.get('maintainer'), info.get('maintainer_email')))
             bar.update(idx)
@@ -181,7 +181,7 @@ def load_package(data: dict, user_lookup: Dict[str, User]):
 
         p.author = info.get('author')
         p.author_email = info.get('author_email')
-        p.license = detect_license(info.get('license'))
+        p.license = detect_license(info.get('license')) or 'MIT'
 
         session = db_session.create_session()
         session.add(p)
@@ -227,7 +227,7 @@ def build_releases(package_id: str, releases: dict) -> List[Release]:
 
         r = Release()
         r.package_id = package_id
-        r.major_ver, r.minor_ver, r.build_ver = make_version_num(k)
+        r.major_ver, r.minor_ver, r.build_ver = make_version_num(k) # type: ignore[reportGeneralTypeIssues]
         r.created_date = parse(v.get('upload_time'))
         r.comment = v.get('comment_text')
         r.url = v.get('url')

code/ch8-async-databases/bin/load_data.py

@@ -15,7 +15,14 @@ async def user_count() -> int:
         return result.scalar()
 
 
-async def create_account(name: str, email: str, password: str) -> User:
+async def create_account(name: Optional[str], email: Optional[str], password: Optional[str]) -> User:
+    if not password:
+        raise Exception('password is required')
+    if not email:
+        raise Exception('email is required')
+    if not name:
+        raise Exception('name is required')
+
     user = User()
     user.email = email
     user.name = name

code/ch8-async-databases/services/user_service.py

@@ -23,14 +23,14 @@ async def index(request: Request):
 
 @router.get('/account/register', include_in_schema=False)
 @template()
-def register(request: Request):
+def register_get(request: Request):
     vm = RegisterViewModel(request)
     return vm.to_dict()
 
 
 @router.post('/account/register', include_in_schema=False)
 @template()
-async def register(request: Request):
+async def register_post(request: Request):
     vm = RegisterViewModel(request)
     await vm.load()