Add historical endpoint

augusthorlen0 · Feb 21, 2024 · 58b372c · 58b372c
1 parent bd93619
commit 58b372c
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 0 deletions.
diff --git a/tap_estr/streams.py b/tap_estr/streams.py
@@ -25,3 +25,14 @@ class EstrLatest(TapEstrStream):
         th.Property("date", th.StringType),
         th.Property("value", th.NumberType),
     ).to_dict()
+
+class EstrHistorical(TapEstrStream):
+    """To fetch the latest €STR"""
+
+    name = "historical"
+    path = "/historical"
+    primary_keys: t.ClassVar[list[str]] = ["date"]
+    schema = th.PropertiesList(
+        th.Property("date", th.StringType),
+        th.Property("value", th.NumberType),
+    ).to_dict()
diff --git a/tap_estr/tap.py b/tap_estr/tap.py
@@ -19,6 +19,7 @@ def discover_streams(self) -> list[streams.TapEstrStream]:
         """
         return [
             streams.EstrLatest(self),
+            streams.EstrHistorical(self),
         ]
-Original file line number
+Diff line change
@@ Expand Up / @@ -19,6 +19,7 @@ def discover_streams(self) -> list[streams.TapEstrStream]: @@
             """
             return [
                 streams.EstrLatest(self),
+                streams.EstrHistorical(self),
             ]
@@ Expand Down @@