wip

4 files changed, 33 insertions, 19 deletions

diff --git a/modules/codec/c++/transport.hpp b/modules/codec/c++/transport.hpp
index 6116497..1dbe038 100644
--- a/modules/codec/c++/transport.hpp
+++ b/modules/codec/c++/transport.hpp
@@ -40,11 +40,22 @@ public:
 		return data_view;
 	}
 
-	error_or<array_buffer> chain_slice(chain_array_buffer& buff) const {
-		(void) buff;
+	error_or<uint64_t> wrap(buffer& out_buff, buffer& in_buff){
+		using trans_type = typename native_data_type<schema::Primitive<schema::UnsignedInteger, Len>>::type;
+		trans_type val{};
+		val = static_cast<trans_type>(in_buff.read_composite_length());
 
+		auto eov = stream_value<schema::Primitive<schema::UnsignedInteger, Len>>::encode(val, out_buff);
+		if(eov.is_error()){
+			auto& err = eov.get_error();
+			return std::move(err);
+		}
 
+		return Len;
+	}
 
+	error_or<array_buffer> chain_slice(chain_array_buffer& buff) const {
+		(void) buff;
 		return make_error<err::not_implemented>();
 	}
 };
diff --git a/modules/io_codec/c++/io_peer.tmpl.hpp b/modules/io_codec/c++/io_peer.tmpl.hpp
index 4deabd3..faf8c7b 100644
--- a/modules/io_codec/c++/io_peer.tmpl.hpp
+++ b/modules/io_codec/c++/io_peer.tmpl.hpp
@@ -91,7 +91,17 @@ error_or<void> streaming_io_peer<Incoming, Outgoing, TransportEncoding, ContentE
 										   msg) {
 	bool restart_write = (out_buffer_.read_segment_length() == 0u);
 
-	auto eov = out_buffer_.write_from(msg.get_buffer());
+	auto& msg_buff = msg.get_buffer();
+	{
+		auto eov = in_codec_.wrap(out_buffer_, msg_buff);
+		if(eov.is_error()){
+			auto& err = eov.get_error();
+			return std::move(err);
+		}
+		// auto& len_val = eov.get_value();
+	}
+
+	auto eov = out_buffer_.write_from(msg_buff);
 	if (eov.is_error()) {
 		auto& err = eov.get_error();
 		return std::move(err);
diff --git a/modules/io_codec/examples/echo.hpp b/modules/io_codec/examples/echo.hpp
index 84b9b31..04819b0 100644
--- a/modules/io_codec/examples/echo.hpp
+++ b/modules/io_codec/examples/echo.hpp
@@ -13,6 +13,6 @@ using Echo = String;
 }
 
 namespace saw {
-constexpr std::string echo_address = "::1";
+constexpr std::string echo_address = "127.0.0.1";
 constexpr uint16_t echo_port = 4322;
 }
diff --git a/modules/io_codec/examples/peer_echo_client.cpp b/modules/io_codec/examples/peer_echo_client.cpp
index d2c4351..90f9627 100644
--- a/modules/io_codec/examples/peer_echo_client.cpp
+++ b/modules/io_codec/examples/peer_echo_client.cpp
@@ -35,16 +35,8 @@ int main(){
 	auto& addr = eo_addr.get_value();
 
 	data<sch::Echo> nat_echo{"hello"};
-	data<sch::Echo, encode::KelSimple> simple_echo;
 	codec<sch::Echo, encode::KelSimple> simple_codec;
 
-	{
-		auto eov = simple_codec.encode(nat_echo, simple_echo);
-		if(eov.is_error()){
-			return -1;
-		}
-	}
-
 	network.connect(*addr).then([&](saw::own<saw::io_stream> client){
 		if(!client){
 			return;
@@ -54,6 +46,14 @@ int main(){
 		auto echo_peer_stream_p = saw::new_streaming_io_peer<sch::Echo, sch::Echo, trans::FixedLength<8u>, encode::KelSimple, ring_buffer>(std::move(echo_stream));
 
 		std::cout<<"Connected"<<std::endl;
+
+		data<sch::Echo, encode::KelSimple> simple_echo;
+		{
+			auto eov = simple_codec.encode(nat_echo, simple_echo);
+			if(eov.is_error()){
+				return ;
+			}
+		}
 		{
 			auto eo_send = echo_peer_stream_p.first->send(std::move(simple_echo));
 			if(eo_send.is_error()){
@@ -61,13 +61,6 @@ int main(){
 			}
 		}
 		std::cout<<"Sent data"<<std::endl;
-		{
-			simple_echo = {};
-			auto eov = simple_codec.encode(nat_echo, simple_echo);
-			if(eov.is_error()){
-				return ;
-			}
-		}
 		
 		data<sch::Echo> nat_resp;
 		echo_peer_stream_p.second.then([&](auto simp_resp){