Skip to content

Commit 7c5fffd

Browse files
committed
Chore: bump aleph-message to 0.4.0a3
1 parent ab0f432 commit 7c5fffd

File tree

3 files changed

+7
-8
lines changed

3 files changed

+7
-8
lines changed

setup.cfg

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ install_requires =
3838
eciespy>=0.3.13; python_version>="3.11"
3939
typing_extensions
4040
typer
41-
aleph-message~=0.3.2
41+
aleph-message==0.4.0a3
4242
eth_account>=0.4.0
4343
# Required to fix a dependency issue with parsimonious and Python3.11
4444
eth_abi==4.0.0b2; python_version>="3.11"

src/aleph/sdk/client.py

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -32,15 +32,14 @@
3232
ForgetContent,
3333
ForgetMessage,
3434
ItemType,
35-
Message,
3635
MessageType,
3736
PostContent,
3837
PostMessage,
3938
ProgramMessage,
4039
StoreContent,
41-
StoreMessage,
40+
StoreMessage, parse_message, ProgramContent,
4241
)
43-
from aleph_message.models.program import Encoding, ProgramContent
42+
from aleph_message.models.execution.base import Encoding
4443
from aleph_message.status import MessageStatus
4544
from pydantic import ValidationError
4645

@@ -713,7 +712,7 @@ async def get_messages(
713712
messages: List[AlephMessage] = []
714713
for message_raw in messages_raw:
715714
try:
716-
message = Message(**message_raw)
715+
message = parse_message(message_raw)
717716
messages.append(message)
718717
except KeyError as e:
719718
if not ignore_invalid_messages:
@@ -835,7 +834,7 @@ async def watch_messages(
835834
break
836835
else:
837836
data = json.loads(msg.data)
838-
yield Message(**data)
837+
yield parse_message(data)
839838
elif msg.type == aiohttp.WSMsgType.ERROR:
840839
break
841840

@@ -1387,7 +1386,7 @@ async def _prepare_aleph_message(
13871386
message_dict["item_type"] = ItemType.storage
13881387

13891388
message_dict = await self.account.sign_message(message_dict)
1390-
return Message(**message_dict)
1389+
return parse_message(message_dict)
13911390

13921391
async def submit(
13931392
self,

src/aleph/sdk/utils.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
from zipfile import BadZipFile, ZipFile
88

99
from aleph_message.models import MessageType
10-
from aleph_message.models.program import Encoding
10+
from aleph_message.models.execution.program import Encoding
1111

1212
from aleph.sdk.conf import settings
1313
from aleph.sdk.types import GenericMessage

0 commit comments

Comments
 (0)