Discord-History-Tracker/app/Server/Endpoints/GetViewerMessagesEndpoint.cs

using System;
using System.Net;
using System.Threading;
using System.Threading.Tasks;
using DHT.Server.Database;
using DHT.Server.Database.Export;
using DHT.Server.Service.Viewer;
using Sisk.Core.Http;
using Sisk.Core.Http.Streams;

namespace DHT.Server.Endpoints;

sealed class GetViewerMessagesEndpoint(IDatabaseFile db, ViewerSessions viewerSessions) : BaseEndpoint {
	protected override async Task<HttpResponse> Respond(HttpRequest request) {
		Guid sessionId = GetSessionId(request);
		ViewerSession session = viewerSessions.Get(sessionId);
		
		HttpResponseStreamManager response = request.GetResponseStream();
		response.SendChunked = true;
		response.SetStatus(HttpStatusCode.OK);
		response.SetHeader(HttpKnownHeaderNames.ContentType, "application/x-ndjson");
		
		await ViewerJsonExport.GetMessages(response.ResponseStream, db, session.MessageFilter, CancellationToken.None);
		
		return response.Close();
	}
}