fix test_server and reorganize requirements files
This commit is contained in:
committed by
Pedro Ferreira
parent
dc1389d634
commit
aab2ac18b3
@@ -47,10 +47,13 @@ async def test_client():
|
||||
handler.send(True, end=True)
|
||||
break
|
||||
|
||||
"""
|
||||
# TODO: save this blob, first.
|
||||
async for data in api.call('blobs.get', ['&/6q7JOKythgnnzoBI5xxvotCr5HeFkAIZSAuqHiZfLw=.sha256'], 'source'):
|
||||
if data.type.name == 'BUFFER':
|
||||
with open('./funny_img.png', 'wb') as f:
|
||||
f.write(data.data)
|
||||
"""
|
||||
|
||||
|
||||
async def main():
|
||||
|
@@ -5,13 +5,15 @@ from colorlog import ColoredFormatter
|
||||
|
||||
from secret_handshake import SHSServer
|
||||
from ssb.packet_stream import PacketStream
|
||||
from ssb.protocol.streams import stream_api
|
||||
from ssb.muxrpc import MuxRPCAPI
|
||||
from ssb.util import load_ssb_secret
|
||||
|
||||
api = MuxRPCAPI()
|
||||
|
||||
|
||||
async def on_connect(conn):
|
||||
packet_stream = PacketStream(conn)
|
||||
stream_api.add_connection(packet_stream)
|
||||
api.add_connection(packet_stream)
|
||||
|
||||
print('connect', conn)
|
||||
async for msg in packet_stream:
|
||||
|
Reference in New Issue
Block a user