From 87f792b8ebc2be88100b380b23578bbf8a39c12d Mon Sep 17 00:00:00 2001
From: Jason Volk <jason@zemos.net>
Date: Mon, 30 Apr 2018 10:38:00 -0700
Subject: [PATCH] modules/federation/backfill_ids: Chunk direct to socket.

---
 modules/federation/backfill_ids.cc | 52 ++++++++++++++++--------------
 1 file changed, 27 insertions(+), 25 deletions(-)

diff --git a/modules/federation/backfill_ids.cc b/modules/federation/backfill_ids.cc
index cc436dadd..b8d90f7d3 100644
--- a/modules/federation/backfill_ids.cc
+++ b/modules/federation/backfill_ids.cc
@@ -85,37 +85,39 @@ get__backfill_ids(client &client,
 		room_id, event_id
 	};
 
-	 //TODO: chunk direct to socket
 	const unique_buffer<mutable_buffer> buf
 	{
-		512 * limit //TODO: XXX
+		4_KiB
 	};
 
-	json::stack out{buf};
+	resource::response::chunked response
 	{
-		json::stack::object top{out};
-		json::stack::member pdus_m
-		{
-			top, "pdu_ids"
-		};
-
-		json::stack::array pdus
-		{
-			pdus_m
-		};
-
-		size_t count{0};
-		for(; it && count < limit; ++count, --it)
-			pdus.append(it.event_id());
-	}
-
-	return resource::response
-	{
-		client, json::object
-		{
-			out.completed()
-		}
+		client, http::OK
 	};
+
+	json::stack out{buf, [&response]
+	(const const_buffer &buf)
+	{
+		response.write(buf);
+		return buf;
+	}};
+
+	json::stack::object top{out};
+	json::stack::member pdus_m
+	{
+		top, "pdu_ids"
+	};
+
+	json::stack::array pdus
+	{
+		pdus_m
+	};
+
+	size_t count{0};
+	for(; it && count < limit; ++count, --it)
+		pdus.append(it.event_id());
+
+	return {};
 }
 
 resource::method