fix: return post ids from controller

Author: kyleratti

ApplicationData/Services/RedditPostProvider.cs

@@ -60,11 +60,14 @@ UPDATE reddit_posts
 			""", new { redditPostId, title }, cancellationToken);
 	}
 
-	public async Task<int> CountPostsNeedingTitleFetched(CancellationToken cancellationToken)
+	public async IAsyncEnumerable<string> GetPostsNeedingTitleFetched([EnumeratorCancellation] CancellationToken cancellationToken)
 	{
 		await using var connection = _dbConnectionFactory.CreateReadOnlyConnection();
-		return await connection.ExecuteScalar<int>(
-			"SELECT COUNT(*) FROM reddit_posts WHERE is_title_fetched = 0",
+
+		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;
 	}
 }

WebApi/Controllers/Admin/AdminQueueController.cs

@@ -55,13 +55,8 @@ public async Task<IActionResult> GetProcessingQueue(CancellationToken cancellati
 	/// </summary>
 	[HttpGet]
 	[Route("post-title-backlog")]
-	public async Task<IActionResult> GetPostTitleFetchBacklog(CancellationToken cancellationToken)
+	public IAsyncEnumerable<string> GetPostTitleFetchBacklog(CancellationToken cancellationToken)
 	{
-		var count = await _redditPostProvider.CountPostsNeedingTitleFetched(cancellationToken);
-
-		return new OkObjectResult(new
-		{
-			postsNeedingTitleFetchedCount = count,
-		});
+		return _redditPostProvider.GetPostsNeedingTitleFetched(cancellationToken);
 	}
 }