From bea7653433f5e2ae6aa639bfce1e76c2dd53b0d7 Mon Sep 17 00:00:00 2001
From: Mars Ultor <krishna@ayyalasomayajula.net>
Date: Tue, 23 Dec 2025 23:39:42 -0600
Subject: [PATCH] created file processing module

---
 src/processing_utils.cpp | 11 +++++++++++
 src/processing_utils.hpp |  9 +++++++++
 2 files changed, 20 insertions(+)
 create mode 100644 src/processing_utils.cpp
 create mode 100644 src/processing_utils.hpp

diff --git a/src/processing_utils.cpp b/src/processing_utils.cpp
new file mode 100644
index 0000000..0dfb889
--- /dev/null
+++ b/src/processing_utils.cpp
@@ -0,0 +1,11 @@
+#include "processing_utils.hpp"
+#include "spdlog/spdlog.h"
+
+namespace processing_utils {
+  void process_to_eof(std::string path, std::shared_ptr<clickhouse::Client>client, bool compressed){
+    spdlog::info("Processing file {} ", path);
+  }
+  void process_blocking(std::string path, std::shared_ptr<clickhouse::Client> client){
+    spdlog::info("Processing file {}", path);
+  }
+}
diff --git a/src/processing_utils.hpp b/src/processing_utils.hpp
new file mode 100644
index 0000000..cf8d85f
--- /dev/null
+++ b/src/processing_utils.hpp
@@ -0,0 +1,9 @@
+#pragma once
+
+#include "clickhouse/client.h"
+#include <memory>
+#include <string>
+namespace processing_utils {
+  void process_to_eof(std::string path, std::shared_ptr<clickhouse::Client>client, bool compressed = true);
+  void process_blocking(std::string path, std::shared_ptr<clickhouse::Client> client);
+}