From e558fd8f9452d448af35bb558207f7d446940fa6 Mon Sep 17 00:00:00 2001
From: Arnaud <arnaud@status.im>
Date: Thu, 27 Feb 2025 10:48:59 +0100
Subject: [PATCH] Enable http pipeline

---
 codex/codex.nim                   | 1 +
 tests/integration/codexclient.nim | 5 ++++-
 tests/integration/testsales.nim   | 8 --------
 3 files changed, 5 insertions(+), 9 deletions(-)

diff --git a/codex/codex.nim b/codex/codex.nim
index dc577373..47e1332f 100644
--- a/codex/codex.nim
+++ b/codex/codex.nim
@@ -310,6 +310,7 @@ proc new*(
         initTAddress(config.apiBindAddress, config.apiPort),
         bufferSize = (1024 * 64),
         maxRequestBodySize = int.high,
+        serverFlags = {HttpServerFlags.Http11Pipeline},
       )
       .expect("Should start rest server!")
 
diff --git a/tests/integration/codexclient.nim b/tests/integration/codexclient.nim
index beb5f248..44c5f7d0 100644
--- a/tests/integration/codexclient.nim
+++ b/tests/integration/codexclient.nim
@@ -24,7 +24,10 @@ const HttpClientTimeoutMs = 60 * 1000
 
 proc new*(_: type CodexClient, baseurl: string): CodexClient =
   CodexClient(
-    http: newHttpClient(timeout = HttpClientTimeoutMs),
+    http: newHttpClient(
+      timeout = HttpClientTimeoutMs,
+      headers = newHttpHeaders({"Connection": "keep-alive"}),
+    ),
     baseurl: baseurl,
     session: HttpSessionRef.new({HttpClientFlag.Http11Pipeline}),
   )
diff --git a/tests/integration/testsales.nim b/tests/integration/testsales.nim
index 49c1fb46..85a1ab1a 100644
--- a/tests/integration/testsales.nim
+++ b/tests/integration/testsales.nim
@@ -84,8 +84,6 @@ multinodesuite "Sales":
       until = until.some,
     )
 
-    host.restart()
-
     let updatedAvailability = (host.getAvailabilities().get).findItem(availability).get
     check updatedAvailability.duration == 100.uint64
     check updatedAvailability.minPricePerBytePerSecond == 2
@@ -116,8 +114,6 @@ multinodesuite "Sales":
     ).get
     host.patchAvailability(availability.id, totalSize = 100000.uint64.some)
 
-    host.restart()
-
     let updatedAvailability = (host.getAvailabilities().get).findItem(availability).get
     check updatedAvailability.totalSize == 100000
     check updatedAvailability.freeSize == 100000
@@ -157,15 +153,11 @@ multinodesuite "Sales":
     let totalSizeResponse =
       host.patchAvailabilityRaw(availability.id, totalSize = (utilizedSize - 1).some)
 
-    host.restart()
-
     check totalSizeResponse.status == "400 Bad Request"
     check "totalSize must be larger then current totalSize" in totalSizeResponse.body
 
     host.patchAvailability(availability.id, totalSize = (originalSize + 20000).some)
 
-    host.restart()
-
     let newUpdatedAvailability =
       (host.getAvailabilities().get).findItem(availability).get
     check newUpdatedAvailability.totalSize == originalSize + 20000