From 4c16632b2f942eb426ccaeac768e8415cce629e9 Mon Sep 17 00:00:00 2001
From: Daniel Roth <daniel_roth@hotmail.co.uk>
Date: Fri, 23 Jan 2026 14:01:21 +0000
Subject: [PATCH] process both file types in local runner

---
 backend/condition/local_runner.py    | 23 ++++++++++++++++-------
 backend/condition/parsing/factory.py |  4 ++++
 2 files changed, 20 insertions(+), 7 deletions(-)

diff --git a/backend/condition/local_runner.py b/backend/condition/local_runner.py
index 28f9b06c..404f64d4 100644
--- a/backend/condition/local_runner.py
+++ b/backend/condition/local_runner.py
@@ -2,6 +2,7 @@ from pathlib import Path
 
 from backend.condition.processor import process_file
 
+
 def main() -> None:
     try:
         # Works in scripts / debugger / pytest
@@ -12,14 +13,22 @@ def main() -> None:
 
     path: Path = ROOT_DIR / "condition" / "sample_data"
 
-    lbwf_path: Path = path / "lbwf" / "LBWF - Example Asset Data September 2025.xlsx"  # TODO: get this from s3 as part of devcontainer init
+    # TODO: get these from s3, maybe as part of devcontainer init
+    lbwf_path: Path = path / "lbwf" / "LBWF - Example Asset Data September 2025.xlsx"
+    peabody_path: Path = (
+        path
+        / "peabody"
+        / "2026_01_06 - Peabody - Stock Condition Data - Survey Records - D  Lower.xlsx"
+    )
+    filepaths = [lbwf_path, peabody_path]
+
+    for fp in filepaths:
+        with fp.open("rb") as f:
+            process_file(
+                file_stream=f,
+                source_key=fp.as_posix(),
+            )
 
-    with lbwf_path.open("rb") as f:
-        process_file(
-            file_stream=f,
-            source_key=lbwf_path.as_posix(),
-        )
 
 if __name__ == "__main__":
     main()
-
diff --git a/backend/condition/parsing/factory.py b/backend/condition/parsing/factory.py
index 7233a1df..68ca0292 100644
--- a/backend/condition/parsing/factory.py
+++ b/backend/condition/parsing/factory.py
@@ -1,5 +1,6 @@
 from backend.condition.domain.mapping.lbwf.lbwf_mapper import LbwfMapper
 from backend.condition.domain.mapping.mapper import Mapper
+from backend.condition.domain.mapping.peabody.peabody_mapper import PeabodyMapper
 from backend.condition.file_type import FileType
 from backend.condition.parsing.parser import Parser
 from backend.condition.parsing.lbwf_parser import LbwfParser
@@ -20,4 +21,7 @@ def select_mapper(file_type: FileType) -> Mapper:
     if file_type is FileType.LBWF:
         return LbwfMapper()
 
+    if file_type is FileType.Peabody:
+        return PeabodyMapper()
+
     raise ValueError("Unrecognised file type, unable to instantiate Mapper")