Update app.py

app.py

@@ -25,7 +25,13 @@ st.sidebar.title("🌍 Environmental Data Dashboard")
 data_source = st.sidebar.selectbox(  
     "Select Data Source",  
     ["Weather Data", "Marine", "Solunar & Tide Data", "Fish Categories Data"]  
-)  
+)
+
+# Initialize global lists for each data source  
+openweather_historical_readings = []  
+openweather_forecast_readings = []  
+stormglass_marine_readings = []  
+solunar_tide_readings = []   
 
 # --- API CALLING FUNCTIONS ---  
 def fetch_openweather_data(lat, lon, datetime_input):  
@@ -35,7 +41,22 @@ def fetch_openweather_data(lat, lon, datetime_input):
     try:  
         response = requests.get(url)  # Make the API call  
         response.raise_for_status()  # Raise an error for bad responses  
-        data = response.json()  # Parse JSON response  
+        data = response.json()  # Parse JSON response
+
+        # Store the data in the global list  
+        if data:  
+            processed_entry = {  
+                'timestamp': datetime_input,  
+                'latitude': lat,  
+                'longitude': lon,  
+                'temperature': data.get('temp', {}),  
+                'humidity': data.get('humidity', None),  
+                'wind_speed': data.get('wind_speed', None),  
+                # Add other relevant fields  
+            }  
+            openweather_historical_readings.append(processed_entry)
+
+            
         return data  
     except requests.exceptions.HTTPError as http_err:  
         st.error(f"HTTP error occurred: {http_err}")  
@@ -49,7 +70,25 @@ def fetch_openweather_forecast(lat, lon):
     try:  
         response = requests.get(url)  
         response.raise_for_status()  # Raise HTTPError for bad responses  
-        return response.json()  
+                data = response.json()  
+
+        # Store the forecast data in the global list  
+        if data and 'daily' in data:  
+            for day_data in data['daily']:  
+                processed_entry = {  
+                    'date': day_data.get('dt', None),  
+                    'latitude': lat,  
+                    'longitude': lon,  
+                    'temperature_day': day_data.get('temp', {}).get('day', None),  
+                    'temperature_night': day_data.get('temp', {}).get('night', None),  
+                    'humidity': day_data.get('humidity', None),  
+                    'wind_speed': day_data.get('wind_speed', None),  
+                    # Add other relevant fields  
+                }  
+                openweather_forecast_readings.append(processed_entry)  
+
+        return data 
+  
     except requests.exceptions.RequestException as e:  
         st.error(f"Error fetching OpenWeather forecast data: {e}")  
         return None  
@@ -64,7 +103,23 @@ def fetch_stormglass_data(lat, lng, start_datetime, end_datetime, selected_param
     try:  
         response = requests.get(url, headers=headers)  
         response.raise_for_status()  
-        return response.json()  
+        data = response.json()  
+
+        # Store the marine data in the global list  
+        if data and 'hours' in data:  
+            for hour_data in data['hours']:  
+                processed_entry = {  
+                    'timestamp': hour_data.get('time', None),  
+                    'latitude': lat,  
+                    'longitude': lng,  
+                    'wave_height': hour_data.get('waveHeight', {}).get('value', None),  
+                    'wind_speed': hour_data.get('windSpeed', {}).get('value', None),  
+                    'temperature': hour_data.get('temperature', {}).get('value', None),  
+                    # Add other relevant fields  
+                }  
+                stormglass_marine_readings.append(processed_entry)  
+
+        return data  
     except requests.exceptions.RequestException as e:  
         st.error(f"Error fetching Stormglass data: {e}")  
         return None  
@@ -84,6 +139,17 @@ def fetch_solunar_tide_data(lat, lon, datetime_input):
 
         tide_data = tide_response.json() if tide_response.status_code == 200 else None  
         astronomy_data = astronomy_response.json() if astronomy_response.status_code == 200 else None  
+        # Store the solunar and tide data in the global list  
+        if tide_data or astronomy_data:  
+            processed_entry = {  
+                'date': datetime_input.date().isoformat(),  
+                'latitude': lat,  
+                'longitude': lon,  
+                'tide_data': tide_data,  
+                'astronomy_data': astronomy_data  
+            }  
+            solunar_tide_readings.append(processed_entry)  
+        
 
         return {  
             'tide': tide_data,  
@@ -92,7 +158,44 @@ def fetch_solunar_tide_data(lat, lon, datetime_input):
 
     except Exception as e:  
         st.error(f"Error fetching Solunar and Tide data: {e}")  
-        return None  
+        return None
+
+def save_openweather_historical_to_csv():  
+    """Save historical OpenWeather data to CSV."""  
+    if not openweather_historical_readings:  
+        st.error("No historical weather data to save!")  
+        return  
+    
+    df = pd.DataFrame(openweather_historical_readings)  
+    return df  
+
+def save_openweather_forecast_to_csv():  
+    """Save forecast OpenWeather data to CSV."""  
+    if not openweather_forecast_readings:  
+        st.error("No forecast weather data to save!")  
+        return  
+    
+    df = pd.DataFrame(openweather_forecast_readings)  
+    return df  
+
+def save_stormglass_marine_to_csv():  
+    """Save Stormglass marine data to CSV."""  
+    if not stormglass_marine_readings:  
+        st.error("No marine data to save!")  
+        return  
+    
+    df = pd.DataFrame(stormglass_marine_readings)  
+    return df  
+
+def save_solunar_tide_to_csv():  
+    """Save solunar and tide data to CSV."""  
+    if not solunar_tide_readings:  
+        st.error("No solunar or tide data to save!")  
+        return  
+    
+    df = pd.DataFrame(solunar_tide_readings)  
+    return df
+
 
 # --- MAIN APPLICATION LOGIC ---  
 def main():  
@@ -176,6 +279,20 @@ def main():
                         ).add_to(m)  
 
                         folium_static(m)  
+        # Download button for historical data  
+        if st.button("Download Historical Weather Data"):  
+            df = save_openweather_historical_to_csv()  
+            if isinstance(df, pd.DataFrame):  
+                csv = df.to_csv(index=False).encode('utf-8')  
+                st.download_button(  
+                    label="Download Historical Weather Data CSV",  
+                    data=csv,  
+                    file_name=f"openweather_historical_data_{datetime.now().strftime('%Y%m%d_%H%M%S')}.csv",  
+                    mime="text/csv",  
+                )  
+                st.success("Historical weather data saved and ready for download!")  
+            else:  
+                st.error("Failed to prepare the historical weather data CSV.")  
 
         with col2:  
             if st.button("Get Weather Forecast"):