fix: improve output

Author: kyleratti

ApplicationData/Services/RedditPostProvider.cs

@@ -26,16 +26,17 @@ public async Task<Maybe<string>> GetPostTitleByPostId(string redditPostId, Cance
 		return reader.TryGetString(0);
 	}
 
-	public async IAsyncEnumerable<string> GetPostIdsWithoutTitleFetched([EnumeratorCancellation] CancellationToken cancellationToken)
+	public async IAsyncEnumerable<(string PostId, string? Title)> GetPostsWithoutTitleFetched([EnumeratorCancellation] CancellationToken cancellationToken)
 	{
 		await using var connection = _dbConnectionFactory.CreateReadOnlyConnection();
-		await using var reader = await connection.ExecuteReader(
-			"SELECT reddit_post_id FROM reddit_posts WHERE post_title IS NULL AND is_title_fetched = 0",
+
+		var query = connection.QueryUnbuffered<(string PostId, string? Title)>(
+			"SELECT reddit_post_id AS PostId, post_title AS Title FROM reddit_posts WHERE is_title_fetched = 0",
 			cancellationToken: cancellationToken);
 
-		while (await reader.ReadAsync(cancellationToken))
+		await foreach (var redditPostId in query)
 		{
-			yield return reader.GetString(0);
+			yield return redditPostId;
 		}
 	}
 
@@ -59,15 +60,4 @@ UPDATE reddit_posts
 			WHERE reddit_post_id = @redditPostId
 			""", new { redditPostId, title }, cancellationToken);
 	}
-
-	public async IAsyncEnumerable<string> GetPostsNeedingTitleFetched([EnumeratorCancellation] CancellationToken cancellationToken)
-	{
-		await using var connection = _dbConnectionFactory.CreateReadOnlyConnection();
-
-		var query = connection.QueryUnbuffered<string>("SELECT reddit_post_id FROM reddit_posts WHERE is_title_fetched = 0",
-			cancellationToken: cancellationToken);
-
-		await foreach (var redditPostId in query)
-			yield return redditPostId;
-	}
 }

BackgroundProcessor/Processors/RedditPostTitleFetcher.cs

@@ -25,11 +25,11 @@ SubmissionBrowser submissionBrowser
 	/// <inheritdoc />
 	public async Task Process(CancellationToken cancellationToken)
 	{
-		var query = _redditPostProvider.GetPostIdsWithoutTitleFetched(cancellationToken)
+		var query = _redditPostProvider.GetPostsWithoutTitleFetched(cancellationToken)
 			.Take(10)
 			.WithCancellation(cancellationToken);
 
-		await foreach (var redditPostId in query)
+		await foreach (var (redditPostId, _) in query)
 		{
 			try
 			{

WebApi/Controllers/Admin/AdminQueueController.cs

@@ -55,8 +55,8 @@ public async Task<IActionResult> GetProcessingQueue(CancellationToken cancellati
 	/// </summary>
 	[HttpGet]
 	[Route("post-title-backlog")]
-	public IAsyncEnumerable<string> GetPostTitleFetchBacklog(CancellationToken cancellationToken)
-	{
-		return _redditPostProvider.GetPostsNeedingTitleFetched(cancellationToken);
-	}
+	public IAsyncEnumerable<object> GetPostTitleFetchBacklog(CancellationToken cancellationToken) =>
+		_redditPostProvider.GetPostsWithoutTitleFetched(cancellationToken)
+			.Select(x => new { x.PostId, x.Title })
+			.AsAsyncEnumerable();
 }