Chore: bump aleph-message to 0.4.0a3

Author: odesenfans

setup.cfg

@@ -38,7 +38,7 @@ install_requires =
     eciespy>=0.3.13; python_version>="3.11"
     typing_extensions
     typer
-    aleph-message~=0.3.2
+    aleph-message==0.4.0a3
     eth_account>=0.4.0
     # Required to fix a dependency issue with parsimonious and Python3.11
     eth_abi==4.0.0b2; python_version>="3.11"

src/aleph/sdk/chains/common.py

@@ -11,6 +11,7 @@
 
 logger = logging.getLogger(__name__)
 
+
 def get_verification_buffer(message: Dict) -> bytes:
     """
     Returns the verification buffer that Aleph nodes use to verify the signature of a message.

src/aleph/sdk/client.py

@@ -32,20 +32,20 @@
     ForgetContent,
     ForgetMessage,
     ItemType,
-    Message,
     MessageType,
     PostContent,
     PostMessage,
     ProgramMessage,
     StoreContent,
     StoreMessage,
+    parse_message,
+    ProgramContent,
 )
-from aleph_message.models.program import Encoding, ProgramContent
+from aleph_message.models.execution.base import Encoding
 from aleph_message.status import MessageStatus
 from pydantic import ValidationError
 
 from aleph.sdk.types import Account, GenericMessage, StorageEnum
-
 from .conf import settings
 from .exceptions import (
     BroadcastError,
@@ -713,7 +713,7 @@ async def get_messages(
             messages: List[AlephMessage] = []
             for message_raw in messages_raw:
                 try:
-                    message = Message(**message_raw)
+                    message = parse_message(message_raw)
                     messages.append(message)
                 except KeyError as e:
                     if not ignore_invalid_messages:
@@ -835,7 +835,7 @@ async def watch_messages(
                         break
                     else:
                         data = json.loads(msg.data)
-                        yield Message(**data)
+                        yield parse_message(data)
                 elif msg.type == aiohttp.WSMsgType.ERROR:
                     break
 
@@ -1387,7 +1387,7 @@ async def _prepare_aleph_message(
                 message_dict["item_type"] = ItemType.storage
 
         message_dict = await self.account.sign_message(message_dict)
-        return Message(**message_dict)
+        return parse_message(message_dict)
 
     async def submit(
         self,

src/aleph/sdk/utils.py

@@ -7,7 +7,7 @@
 from zipfile import BadZipFile, ZipFile
 
 from aleph_message.models import MessageType
-from aleph_message.models.program import Encoding
+from aleph_message.models.execution.program import Encoding
 
 from aleph.sdk.conf import settings
 from aleph.sdk.types import GenericMessage