From d7269106db9d07a09191dc37c674b6bd6582c87e Mon Sep 17 00:00:00 2001
From: Salil <32305505+Deadpool2000@users.noreply.github.com>
Date: Fri, 24 Jan 2025 12:22:28 +0530
Subject: [PATCH] Added - animal_shelter Get Data

Import all German animal shelters
---
 src/fellchensammlung/animal_shelter.py | 57 ++++++++++++++++++++++++++
 1 file changed, 57 insertions(+)
 create mode 100644 src/fellchensammlung/animal_shelter.py

diff --git a/src/fellchensammlung/animal_shelter.py b/src/fellchensammlung/animal_shelter.py
new file mode 100644
index 0000000..9fe1060
--- /dev/null
+++ b/src/fellchensammlung/animal_shelter.py
@@ -0,0 +1,57 @@
+import json
+import requests
+
+OSM_DATA_FILE = "osm_data.geojson"
+ENDPOINT = "https://test.notfellchen.org/api/organizations/"
+HEADERS = {
+    "Authorization": "API_KEY",
+    "Content-Type": "application/json"
+}
+
+def load_osm_data(file_path):
+    #Load OSM data from a GeoJSON file.
+    with open(file_path, "r", encoding="utf-8") as file:
+        data = json.load(file)
+    return data
+
+def transform_osm_data(feature):
+    #Transform a single OSM feature into the API payload format
+    prop = feature.get("prop", {})
+    geometry = feature.get("geometry", {})
+
+    return {
+        "name": prop.get("name", "Unnamed Shelter"),
+        "phone": prop.get("phone"),
+        "website": prop.get("website"),
+        "opening_hours": prop.get("opening_hours"),
+        "email": prop.get("email"),
+        "location": {
+            "type": geometry.get("type", "Point"),
+            "coordinates": geometry.get("coordinates", [])
+        },
+        "external_object_id": prop.get("@id"),
+        "external_source_id": "OSM"
+    }
+
+def send_to_api(data):
+    #Send transformed data to the Notfellchen API.
+    response = requests.post(ENDPOINT, headers=HEADERS, json=data)
+    if response.status_code == 201:
+        print(f"Success: Shelter '{data['name']}' uploaded.")
+    elif response.status_code == 400:
+        print(f"Error: Shelter '{data['name']}' already exists or invalid data.")
+    else:
+        print(f"Unexpected Error: {response.status_code} - {response.text}")
+
+def main():
+    # Step 1: Load OSM data
+    osm_data = load_osm_data(OSM_DATA_FILE)
+    
+
+    # Step 2: Process each shelter and send it to the API
+    for feature in osm_data.get("features", []):
+        shelter_data = transform_osm_data(feature)
+        send_to_api(shelter_data)
+
+if __name__ == "__main__":
+    main()