Activity connector V1

app.py

@@ -0,0 +1,87 @@
+import requests
+import hashlib
+import datetime
+import streamlit as st
+import pandas as pd
+
+# Hotelbeds API credentials
+hotelbeds_api_key = "95ce3e45a02fc6fd9720ecc013a6f674"
+hotelbeds_api_secret = "785150201f"
+
+# Function to generate the API signature
+def generate_signature():
+    local_timestamp = int(datetime.datetime.now().timestamp())
+    assemble = hotelbeds_api_key + hotelbeds_api_secret + str(local_timestamp)
+    signature = hashlib.sha256(assemble.encode()).hexdigest()
+    return signature
+
+# Function to make the POST request to the Hotelbeds API and handle pagination
+def fetch_activities(latitude, longitude, from_date, to_date, language="en", paxes=[{"age": 5}, {"age": 70}], order="DEFAULT"):
+    url = "https://api.test.hotelbeds.com/activity-api/3.0/activities/availability"
+    signature = generate_signature()
+    headers = {
+        "Content-Type": "application/json",
+        "Api-Key": hotelbeds_api_key,
+        "X-Signature": signature,
+        "Accept": "application/json",
+    }
+    
+    payload = {
+        "filters": [
+            {
+                "searchFilterItems": [
+                    {
+                        "type": "gps",
+                        "latitude": latitude,
+                        "longitude": longitude
+                    }
+                ]
+            }
+        ],
+        "from": from_date,
+        "to": to_date,
+        "language": language,
+        "paxes": paxes,
+        "order": order
+    }
+
+    activities = []
+    page = 1
+    items_per_page = 100
+    total_items = 0
+
+    while True:
+        payload['pagination'] = {"page": page, "itemsPerPage": items_per_page}
+        response = requests.post(url, headers=headers, json=payload)
+        if response.status_code != 200:
+            st.error(f"Error fetching activities: {response.status_code}")
+            return None
+
+        data = response.json()
+        if page == 1:
+            total_items = data['pagination']['totalItems']
+            items_per_page = data['pagination']['itemsPerPage']
+
+        activities.extend(data['activities'])
+
+        if total_items <= items_per_page * page:
+            break
+
+        page += 1
+
+    return activities
+
+# Streamlit app
+st.title("Hotelbeds Activity Availability Checker")
+
+latitude = st.number_input("Latitude", value=40.730610)
+longitude = st.number_input("Longitude", value=-73.93524)
+from_date = st.date_input("From Date", value=pd.to_datetime("2024-06-20"))
+to_date = st.date_input("To Date", value=pd.to_datetime("2024-06-24"))
+
+if st.button("Check Availability"):
+    activities = fetch_activities(latitude, longitude, from_date.isoformat(), to_date.isoformat())
+    if activities:
+        st.json(activities)
+    else:
+        st.error("No activities found or an error occurred.")