Don't close p2p http stream for writes after sending request

This fixes talking to go ipfs instances
Peergos · Aug 12, 2023 · df0f007 · df0f007
1 parent 5e2fd65
commit df0f007
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/src/main/java/org/peergos/protocol/http/HttpProtocol.java b/src/main/java/org/peergos/protocol/http/HttpProtocol.java
@@ -57,7 +57,6 @@ public CompletableFuture<FullHttpResponse> send(FullHttpRequest req) {
             queue.add(res);
             FullHttpRequest withTargetHost = setHost(req, stream.remotePeerId());
             stream.writeAndFlush(withTargetHost);
-            stream.closeWrite();
             return res;
         }
     }

diff --git a/src/test/java/org/peergos/HttpProxyTest.java b/src/test/java/org/peergos/HttpProxyTest.java
@@ -92,8 +92,7 @@ public void p2pProxyRequest() throws IOException {
     }
 
     @Test
-    @Ignore
-    public void p2pProxyClientTest() throws IOException {
+    public void p2pProxyClientTest() throws Exception {
         InetSocketAddress unusedProxyTarget = new InetSocketAddress("127.0.0.1", 7000);
         HostBuilder builder1 = HostBuilder.create(TestPorts.getPort(),
                         new RamProviderStore(), new RamRecordStore(), new RamBlockstore(), (c, b, p, a) -> CompletableFuture.completedFuture(true))
@@ -118,7 +117,7 @@ public void p2pProxyClientTest() throws IOException {
             FullHttpRequest httpRequest = new DefaultFullHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.POST,
                     "/peergos/v0/core/getUsernamesGzip/");
             long totalTime = 0;
-            int count = 200;
+            int count = 20;
             for (int i = 0; i < count; i++) {
                 HttpProtocol.HttpController proxier = new HttpProtocol.Binding(unusedProxyTarget)
                         .dial(node1, PeerId.fromBase58(peerId), addrs)
@@ -135,8 +134,10 @@ public void p2pProxyClientTest() throws IOException {
                 resp.content().readBytes(bout, resp.headers().getInt("content-length"));
                 resp.release();
 
-                Object reply = JSONParser.parse(new String(bout.toByteArray()));
-                System.out.println();
+                GZIPInputStream gzip = new GZIPInputStream(new ByteArrayInputStream(bout.toByteArray()));
+
+                List<String> reply = (List)JSONParser.parse(new String(readFully(gzip)));
+                Assert.assertTrue(reply.contains("peergos"));
             }
             System.out.println("Average: " + totalTime / count);
         } finally {