From cba40164617b07bb253ba9415fc0ff966fdf0b63 Mon Sep 17 00:00:00 2001 From: Gusto Date: Wed, 17 Jul 2024 19:37:56 +0300 Subject: [PATCH] Use dispersal proto message in poc executor --- da/network/executor.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/da/network/executor.py b/da/network/executor.py index 395c451..4bd0f10 100644 --- a/da/network/executor.py +++ b/da/network/executor.py @@ -9,6 +9,7 @@ from constants import HASH_LENGTH, PROTOCOL_ID from libp2p import host, new_host from libp2p.network.stream.net_stream_interface import INetStream from libp2p.peer.peerinfo import info_from_p2p_addr +from da.network.dispersal import proto class Executor: @@ -94,4 +95,9 @@ class Executor: Send data to peer (async) The index is the subnet number """ - await stream.write(self.data[index]) + + blob_id = sha256(self.data) + blob_data = self.data[index] + + message = proto.new_dispersal_req_msg(blob_id, blob_data) + await stream.write(message)