Handle completed curl operations in a job

Removes the need to block the main thread from reading stdin while
performing post curl operation actions, such as updating user agent
details.

1 files changed, 4 insertions, 0 deletions

diff --git a/src/ingestor.hpp b/src/ingestor.hpp
index a51c46c..1125692 100644
--- a/src/ingestor.hpp
+++ b/src/ingestor.hpp
@@ -75,6 +75,7 @@ namespace WebStat {
 		std::expected<std::filesystem::path, int> parkLogLines(LineBatch &);
 		void runJobsAsNeeded();
 
+		Job::Result jobHandleCompleteCurlOps();
 		Job::Result jobReadParkedLines();
 		Job::Result jobPurgeOldLogs();
 		Job::Result jobStoreQueuedLines();
@@ -105,6 +106,7 @@ namespace WebStat {
 		bool terminated = false;
 
 		Job::LastRunTime lastCheckedJobs {Job::LastRunTime::clock::now()};
+		Job handleCompleteCurlOps;
 		Job ingestParkedLines;
 		Job purgeOldLogs;
 		Job storeQueueLines;
@@ -115,6 +117,8 @@ namespace WebStat {
 		void storeNewEntities(DB::Connection *, std::span<Entity *>) const;
 		void storeNewEntity(DB::Connection *, Entity &) const;
 		void onNewUserAgent(const Entity &) const;
+		auto withCurlLock(auto &&...);
+		bool haveCurlOperations();
 		void handleCurlOperations();
 		void logStats() const;
 		void clearStats();