From 67c16d5eab4babed6e357298771a775444f9b83c Mon Sep 17 00:00:00 2001
From: Nicolas Thouvenin <nthouvenin@gmail.com>
Date: Wed, 29 Mar 2023 12:19:51 +0200
Subject: [PATCH] =?UTF-8?q?feat:=20=F0=9F=8E=B8=20use=20POST=20for=20/afte?=
 =?UTF-8?q?r?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 packages/conditor/src/corhal-fetch.js | 30 ++++++++++++++++++++-------
 1 file changed, 22 insertions(+), 8 deletions(-)

diff --git a/packages/conditor/src/corhal-fetch.js b/packages/conditor/src/corhal-fetch.js
index ab3959b57..97c945181 100644
--- a/packages/conditor/src/corhal-fetch.js
+++ b/packages/conditor/src/corhal-fetch.js
@@ -63,10 +63,6 @@ export default async function CORHALFetch(data, feed) {
     const cURL = new URL(`${url}/mergedDocuments`);
     cURL.search = new URLSearchParams(data);
     const controller = new AbortController();
-    const parameters = {
-        timeout,
-        signal: controller.signal,
-    };
     const options = {
         retries,
     };
@@ -80,13 +76,24 @@ export default async function CORHALFetch(data, feed) {
             await write(stream, arr);
         }
         if (afterKeyToken) {
-            const href = `${url}/after/${afterKeyToken}`;
+            const href = `${url}/after`;
             try {
-                const responseBis = await retry(request(href, parameters), options);
+                const responseBis = await retry(request(
+                    href,
+                    {
+                        method: 'POST',
+                        timeout,
+                        signal: controller.signal,
+                        headers: {
+                            'Content-Type': 'application/json',
+                        },
+                        body: JSON.stringify({ afterKeyToken: String(afterKeyToken).trim() }),
+                    },
+                ), options);
                 const noticesBis = await responseBis.json();
                 const afterKeyTokenBis = responseBis.headers.get('after-key-token');
                 loop(stream, noticesBis, afterKeyTokenBis);
-            } catch(e) {
+            } catch (e) {
                 console.error(`Error with ${href}`, e.message);
                 stream.end();
             }
@@ -96,7 +103,14 @@ export default async function CORHALFetch(data, feed) {
     };
     try {
         const output = ezs.createStream(ezs.objectMode());
-        const response = await retry(request(cURL.href, parameters), options);
+        const response = await retry(
+            request(cURL.href,
+                {
+                    timeout,
+                    signal: controller.signal,
+                }),
+            options,
+        );
         const afterKeyToken = response.headers.get('after-key-token');
         const notices = await response.json();
         await loop(output, notices, afterKeyToken);