Update core to version a4d007e7 (#149)

* Update core to version a4d007e7

* Update core functions to raise typed errors

---------

Co-authored-by: 1PasswordSDKBot <[email protected]>

Author: edif2008

example/example.py

@@ -172,6 +172,7 @@ async def main():
     await client.items.delete(created_item.vault_id, updated_item.id)
     # [developer-docs.sdk.python.delete-item]-end
 
+
 ## NOTE: this is in a separate function to avoid creating a new item
 ## NOTE: just for the sake of archiving it. This is because the SDK
 ## NOTE: only works with active items, so archiving and then deleting
@@ -207,14 +208,15 @@ async def share_item(client: Client, vault_id: str, item_id: str):
         item,
         policy,
         ItemShareParams(
-            recipients = valid_recipients,
-            expireAfter= ItemShareDuration.ONEHOUR,
-            oneTimeOnly= False,
+            recipients=valid_recipients,
+            expireAfter=ItemShareDuration.ONEHOUR,
+            oneTimeOnly=False,
         ),
     )
 
     print(share_link)
     # [developer-docs.sdk.python.item-share-create-share]-end
 
+
 if __name__ == "__main__":
     asyncio.run(main())

src/onepassword/__init__.py

@@ -3,6 +3,7 @@
 from .client import Client
 from .defaults import DEFAULT_INTEGRATION_NAME, DEFAULT_INTEGRATION_VERSION
 from .types import *  # noqa F403
+from .errors import *  # noqa F403
 from .secrets import Secrets
 from .items import Items
 from .vaults import Vaults
@@ -32,3 +33,11 @@
         or type(obj) == typing._LiteralGenericAlias
     ):
         __all__.append(name)
+
+for name, obj in inspect.getmembers(sys.modules["onepassword.errors"]):
+    # Add all classes defined in errors.py.
+    if (
+        inspect.isclass(obj)
+        and inspect.getmodule(obj) == sys.modules["onepassword.errors"]
+    ):
+        __all__.append(name)

src/onepassword/core.py

@@ -1,6 +1,8 @@
 import json
 import platform
 
+from onepassword.errors import raise_typed_exception
+
 
 machine_arch = platform.machine().lower()
 
@@ -16,17 +18,26 @@
 
 # InitClient creates a client instance in the current core module and returns its unique ID.
 async def _init_client(client_config):
-    return await core.init_client(json.dumps(client_config))
+    try:
+        return await core.init_client(json.dumps(client_config))
+    except Exception as e:
+        raise_typed_exception(e)
 
 
 # Invoke calls specified business logic from the SDK core.
 async def _invoke(invoke_config):
-    return await core.invoke(json.dumps(invoke_config))
+    try:
+        return await core.invoke(json.dumps(invoke_config))
+    except Exception as e:
+        raise_typed_exception(e)
 
 
 # Invoke calls specified business logic from the SDK core.
 def _invoke_sync(invoke_config):
-    return core.invoke_sync(json.dumps(invoke_config))
+    try:
+        return core.invoke_sync(json.dumps(invoke_config))
+    except Exception as e:
+        raise_typed_exception(e)
 
 
 # ReleaseClient releases memory in the SDK core associated with the given client ID.

src/onepassword/errors.py

@@ -0,0 +1,26 @@
+# Code generated by op-codegen - DO NO EDIT MANUALLY
+
+import json
+
+
+class RateLimitExceededException(Exception):
+    def __init__(self, message):
+        self.message = message
+        super().__init__(self.message)
+
+
+def raise_typed_exception(e: Exception):
+    try:
+        typed_error = json.loads(e.msg)
+    except Exception:
+        raise e
+
+    error_name = typed_error.get("name")
+    message = typed_error.get("message")
+
+    if error_name == "RateLimitExceeded":
+        raise RateLimitExceededException(message)
+    elif message is not None:
+        raise Exception(message)
+    else:
+        raise e

src/onepassword/items.py

@@ -1,7 +1,8 @@
 # Code generated by op-codegen - DO NO EDIT MANUALLY
 
-from .core import _invoke
+from .core import _invoke, _invoke_sync
 from .iterator import SDKIterator
+from typing import Optional, List
 from pydantic import TypeAdapter
 from .items_shares import ItemsShares
 from .types import Item, ItemCreateParams, ItemOverview
@@ -73,7 +74,7 @@ async def put(self, item: Item) -> Item:
         response = TypeAdapter(Item).validate_json(response)
         return response
 
-    async def delete(self, vault_id: str, item_id: str):
+    async def delete(self, vault_id: str, item_id: str) -> None:
         """
         Delete an item.
         """
@@ -91,7 +92,7 @@ async def delete(self, vault_id: str, item_id: str):
 
         return None
 
-    async def archive(self, vault_id: str, item_id: str):
+    async def archive(self, vault_id: str, item_id: str) -> None:
         """
         Archive an item.
         """
@@ -125,5 +126,5 @@ async def list_all(self, vault_id: str) -> SDKIterator[ItemOverview]:
             }
         )
 
-        response = TypeAdapter(list[ItemOverview]).validate_json(response)
+        response = TypeAdapter(List[ItemOverview]).validate_json(response)
         return SDKIterator(response)

src/onepassword/items_shares.py

@@ -1,6 +1,8 @@
 # Code generated by op-codegen - DO NO EDIT MANUALLY
 
-from .core import _invoke
+from .core import _invoke, _invoke_sync
+from .iterator import SDKIterator
+from typing import Optional, List
 from pydantic import TypeAdapter
 from .types import Item, ItemShareAccountPolicy, ItemShareParams, ValidRecipient
 
@@ -31,8 +33,8 @@ async def get_account_policy(
         return response
 
     async def validate_recipients(
-        self, policy: ItemShareAccountPolicy, recipients: list[str]
-    ) -> list[ValidRecipient]:
+        self, policy: ItemShareAccountPolicy, recipients: List[str]
+    ) -> List[ValidRecipient]:
         """
         Validate the recipients of an item sharing link.
         """
@@ -51,7 +53,7 @@ async def validate_recipients(
             }
         )
 
-        response = TypeAdapter(list[ValidRecipient]).validate_json(response)
+        response = TypeAdapter(List[ValidRecipient]).validate_json(response)
         return response
 
     async def create(