1- import asyncio
21import json
32from hashlib import sha256
43
54import pytest
6- from aleph_message .models import AlephMessage , PostMessage , PostContent , MessageType , Chain
5+ from aleph_message .models import Chain , MessageType , PostContent , PostMessage
76
87from aleph .sdk .cache import MessageCache
98from aleph .sdk .chains .ethereum import get_fallback_account
10- from aleph .sdk .client import AlephClient , AuthenticatedAlephClient
9+ from aleph .sdk .client import AlephClient
1110from aleph .sdk .conf import settings
1211
1312
@@ -52,11 +51,11 @@ async def test_message_cache_listener():
5251 async def mock_message_stream ():
5352 for i in range (3 ):
5453 content = PostContent (
55- content = {"hello" : f"world{ i } " },
56- type = "test" ,
57- address = get_fallback_account ().get_address (),
58- time = 0 ,
59- )
54+ content = {"hello" : f"world{ i } " },
55+ type = "test" ,
56+ address = get_fallback_account ().get_address (),
57+ time = 0 ,
58+ )
6059 message = PostMessage (
6160 sender = get_fallback_account ().get_address (),
6261 item_hash = sha256 (json .dumps (content .dict ()).encode ()).hexdigest (),
@@ -68,6 +67,7 @@ async def mock_message_stream():
6867 item_content = json .dumps (content .dict ()),
6968 )
7069 yield message
70+
7171 cache = MessageCache ()
7272 # test listener
7373 coro = cache .listen_to (mock_message_stream ())
0 commit comments