Fix return types in async client, as done w/ sync.

Author: andrew-chang-dewitt

db_wrapper/client/async_client.py

@@ -2,6 +2,7 @@
 
 from __future__ import annotations
 from typing import (
+    cast,
     Any,
     TypeVar,
     Union,
@@ -10,8 +11,8 @@
     List,
     Dict)
 
-import aiopg  # type: ignore
-from psycopg2.extras import register_uuid
+import aiopg
+from psycopg2.extras import register_uuid, RealDictRow
 from psycopg2 import sql
 
 from db_wrapper.connection import ConnectionParameters, connect
@@ -20,10 +21,6 @@
 register_uuid()
 
 
-# Generic doesn't need a more descriptive name
-# pylint: disable=invalid-name
-T = TypeVar('T')
-
 Query = Union[str, sql.Composed]
 
 
@@ -57,6 +54,11 @@ async def _execute_query(
         query: Query,
         params: Optional[Dict[Hashable, Any]] = None,
     ) -> None:
+        # aiopg type is incorrect & thinks execute only takes str
+        # when in the query is passed through to psycopg2's
+        # cursor.execute which does accept sql.Composed objects.
+        query = cast(str, query)
+
         if params:
             await cursor.execute(query, params)
         else:
@@ -88,7 +90,7 @@ async def execute_and_return(
         self,
         query: Query,
         params: Optional[Dict[Hashable, Any]] = None,
-    ) -> List[T]:
+    ) -> List[RealDictRow]:
         """Execute the given SQL query & return the result.
 
         Arguments:
@@ -102,5 +104,5 @@ async def execute_and_return(
         async with self._connection.cursor() as cursor:
             await self._execute_query(cursor, query, params)
 
-            result: List[T] = await cursor.fetchall()
+            result: List[RealDictRow] = await cursor.fetchall()
             return result

db_wrapper/model/async_model.py

@@ -1,18 +1,20 @@
 """Asynchronous Model objects."""
 
-from typing import Any, Dict, List
+from typing import Any, Dict, List, Type
 from uuid import UUID
 
+from psycopg2.extras import RealDictRow
+
 from db_wrapper.client import AsyncClient
 from .base import (
     ensure_exactly_one,
+    sql,
     T,
     CreateABC,
     ReadABC,
     UpdateABC,
     DeleteABC,
     ModelABC,
-    sql,
 )
 
 
@@ -23,16 +25,22 @@ class AsyncCreate(CreateABC[T]):
 
     _client: AsyncClient
 
-    def __init__(self, client: AsyncClient, table: sql.Composable) -> None:
-        super().__init__(table)
+    def __init__(
+        self,
+        client: AsyncClient,
+        table: sql.Composable,
+        return_constructor: Type[T]
+    ) -> None:
+        super().__init__(table, return_constructor)
         self._client = client
 
     async def one(self, item: T) -> T:
         """Create one new record with a given item."""
-        result: List[T] = await self._client.execute_and_return(
-            self._query_one(item))
+        query_result: List[RealDictRow] = \
+            await self._client.execute_and_return(self._query_one(item))
+        result: T = self._return_constructor(**query_result[0])
 
-        return result[0]
+        return result
 
 
 class AsyncRead(ReadABC[T]):
@@ -42,19 +50,27 @@ class AsyncRead(ReadABC[T]):
 
     _client: AsyncClient
 
-    def __init__(self, client: AsyncClient, table: sql.Composable) -> None:
-        super().__init__(table)
+    def __init__(
+        self,
+        client: AsyncClient,
+        table: sql.Composable,
+        return_constructor: Type[T]
+    ) -> None:
+        super().__init__(table, return_constructor)
         self._client = client
 
     async def one_by_id(self, id_value: UUID) -> T:
         """Read a row by it's id."""
-        result: List[T] = await self._client.execute_and_return(
-            self._query_one_by_id(id_value))
+        query_result: List[RealDictRow] = \
+            await self._client.execute_and_return(
+                self._query_one_by_id(id_value))
 
         # Should only return one item from DB
-        ensure_exactly_one(result)
+        ensure_exactly_one(query_result)
+
+        result: T = self._return_constructor(**query_result[0])
 
-        return result[0]
+        return result
 
 
 class AsyncUpdate(UpdateABC[T]):
@@ -64,8 +80,13 @@ class AsyncUpdate(UpdateABC[T]):
 
     _client: AsyncClient
 
-    def __init__(self, client: AsyncClient, table: sql.Composable) -> None:
-        super().__init__(table)
+    def __init__(
+        self,
+        client: AsyncClient,
+        table: sql.Composable,
+        return_constructor: Type[T]
+    ) -> None:
+        super().__init__(table, return_constructor)
         self._client = client
 
     async def one_by_id(self, id_value: str, changes: Dict[str, Any]) -> T:
@@ -79,12 +100,14 @@ async def one_by_id(self, id_value: str, changes: Dict[str, Any]) -> T:
         Returns:
             full value of row updated
         """
-        result: List[T] = await self._client.execute_and_return(
-            self._query_one_by_id(id_value, changes))
+        query_result: List[RealDictRow] = \
+            await self._client.execute_and_return(
+                self._query_one_by_id(id_value, changes))
 
-        ensure_exactly_one(result)
+        ensure_exactly_one(query_result)
+        result: T = self._return_constructor(**query_result[0])
 
-        return result[0]
+        return result
 
 
 class AsyncDelete(DeleteABC[T]):
@@ -94,19 +117,26 @@ class AsyncDelete(DeleteABC[T]):
 
     _client: AsyncClient
 
-    def __init__(self, client: AsyncClient, table: sql.Composable) -> None:
-        super().__init__(table)
+    def __init__(
+        self,
+        client: AsyncClient,
+        table: sql.Composable,
+        return_constructor: Type[T]
+    ) -> None:
+        super().__init__(table, return_constructor)
         self._client = client
 
     async def one_by_id(self, id_value: str) -> T:
         """Delete one record with matching ID."""
-        result: List[T] = await self._client.execute_and_return(
-            self._query_one_by_id(id_value))
+        query_result: List[RealDictRow] = \
+            await self._client.execute_and_return(
+                self._query_one_by_id(id_value))
 
         # Should only return one item from DB
-        ensure_exactly_one(result)
+        ensure_exactly_one(query_result)
+        result = self._return_constructor(**query_result[0])
 
-        return result[0]
+        return result
 
 
 class AsyncModel(ModelABC[T]):
@@ -122,19 +152,22 @@ class AsyncModel(ModelABC[T]):
     _update: AsyncUpdate[T]
     _delete: AsyncDelete[T]
 
-    # PENDS python 3.9 support in pylint
-    # pylint: disable=unsubscriptable-object
     def __init__(
         self,
         client: AsyncClient,
         table: str,
+        return_constructor: Type[T],
     ) -> None:
         super().__init__(client, table)
 
-        self._create = AsyncCreate[T](self.client, self.table)
-        self._read = AsyncRead[T](self.client, self.table)
-        self._update = AsyncUpdate[T](self.client, self.table)
-        self._delete = AsyncDelete[T](self.client, self.table)
+        self._create = AsyncCreate[T](
+            self.client, self.table, return_constructor)
+        self._read = AsyncRead[T](
+            self.client, self.table, return_constructor)
+        self._update = AsyncUpdate[T](
+            self.client, self.table, return_constructor)
+        self._delete = AsyncDelete[T](
+            self.client, self.table, return_constructor)
 
     @property
     def create(self) -> AsyncCreate[T]:

db_wrapper/model/sync_model.py

@@ -7,14 +7,14 @@
 
 from db_wrapper.client import SyncClient
 from .base import (
+    ensure_exactly_one,
+    sql,
     T,
     CreateABC,
     DeleteABC,
     ReadABC,
     UpdateABC,
     ModelABC,
-    ensure_exactly_one,
-    sql,
 )
 
 
@@ -150,8 +150,6 @@ class SyncModel(ModelABC[T]):
     _update: SyncUpdate[T]
     _delete: SyncDelete[T]
 
-    # PENDS python 3.9 support in pylint
-    # pylint: disable=unsubscriptable-object
     def __init__(
         self,
         client: SyncClient,
@@ -162,7 +160,8 @@ def __init__(
 
         self._create = SyncCreate[T](
             self.client, self.table, return_constructor)
-        self._read = SyncRead[T](self.client, self.table, return_constructor)
+        self._read = SyncRead[T](
+            self.client, self.table, return_constructor)
         self._update = SyncUpdate[T](
             self.client, self.table, return_constructor)
         self._delete = SyncDelete[T](