From c419168cd145ad90bfac657a11228b9b2e163756 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Edgar=20Ram=C3=ADrez-Mondrag=C3=B3n?= <edgarrm358@gmail.com>
Date: Fri, 13 Sep 2024 17:24:42 -0600
Subject: [PATCH] chore: Add a file (CSV) tap for testing

---
 samples/sample_tap_csv/sample_tap_csv.py | 58 ++++++++++++++++++++++++
 1 file changed, 58 insertions(+)
 create mode 100644 samples/sample_tap_csv/sample_tap_csv.py

diff --git a/samples/sample_tap_csv/sample_tap_csv.py b/samples/sample_tap_csv/sample_tap_csv.py
new file mode 100644
index 000000000..5d116544e
--- /dev/null
+++ b/samples/sample_tap_csv/sample_tap_csv.py
@@ -0,0 +1,58 @@
+"""Sample Tap for CSV files."""  # noqa: INP001
+
+from __future__ import annotations
+
+import enum
+import os
+
+import singer_sdk.typing as th
+from singer_sdk import Tap
+
+
+def file_path_to_stream_name(file_path: str) -> str:
+    """Convert a file path to a stream name."""
+    return os.path.basename(file_path).replace(".csv", "").replace(os.sep, "__")  # noqa: PTH119
+
+
+class ReadMode(str, enum.Enum):
+    """Sync mode for the tap."""
+
+    one_stream_per_file = "one_stream_per_file"
+    merge = "merge"
+
+
+class SampleTapCSV(Tap):
+    """Sample Tap for CSV files."""
+
+    name = "sample-tap-countries"
+
+    config_jsonschema = th.PropertiesList(
+        th.Property(
+            "path",
+            th.StringType,
+            required=True,
+            description="Path to CSV files.",
+        ),
+        th.Property(
+            "read_mode",
+            th.StringType,
+            required=True,
+            description=(
+                "Use `one_stream_per_file` to read each file as a separate stream, or "
+                "`merge` to merge all files into a single stream."
+            ),
+            allowed_values=[ReadMode.one_stream_per_file, ReadMode.merge],
+        ),
+        th.Property(
+            "stream_name",
+            th.StringType,
+            required=False,
+            description="Name of the stream to use when `read_mode` is `merge`.",
+        ),
+        # TODO(edgarmondragon): Other configuration options.
+    ).to_dict()
+
+    def discover_streams(self) -> list:
+        # TODO(edgarmondragon): Implement stream discovery, based on the configured path
+        # and read mode.
+        raise NotImplementedError