[V0_FILE]plaintext:file="lib/widgets/earthquake_map.dart" isMerged="true" import 'package:flutter/material.dart'; import 'package:provider/provider.dart'; import 'package:flutter_map/flutter_map.dart'; import 'package:latlong2/latlong.dart'; import 'package:globalquake/providers/earthquake_provider.dart'; import 'package:globalquake/models/earthquake.dart'; class EarthquakeMap extends StatefulWidget { const EarthquakeMap({Key? key}) : super(key: key); @override State createState() => _EarthquakeMapState(); } class _EarthquakeMapState extends State { final MapController _mapController = MapController(); @override Widget build(BuildContext context) { final earthquakeProvider = Provider.of(context); final earthquakes = earthquakeProvider.earthquakes; final isLoading = earthquakeProvider.isLoading; return Stack( children: [ FlutterMap( mapController: _mapController, options: MapOptions( center: LatLng(0, 0), zoom: 2, minZoom: 1, maxZoom: 18, ), children: [ TileLayer( urlTemplate: 'https://{s}.tile.openstreetmap.org/{z}/{x}/{y}.png', subdomains: const ['a', 'b', 'c'], ), MarkerLayer( markers: earthquakes.map((earthquake) => _buildMarker(earthquake)).toList(), ), ], ), if (isLoading) const Center( child: CircularProgressIndicator(), ), Positioned( right: 16, bottom: 16, child: Column( children: [ FloatingActionButton( heroTag: 'zoomIn', mini: true, onPressed: () { _mapController.move( _mapController.center, _mapController.zoom + 1, ); }, child: const Icon(Icons.add), ), const SizedBox(height: 8), FloatingActionButton( heroTag: 'zoomOut', mini: true, onPressed: () { _mapController.move( _mapController.center, _mapController.zoom - 1, ); }, child: const Icon(Icons.remove), ), ], ), ), ], ); } Marker _buildMarker(Earthquake earthquake) { // Calculate marker size based on magnitude final double size = 20 + (earthquake.magnitude * 4); // Calculate color based on depth Color markerColor; if (earthquake.depth < 10) { markerColor = Colors.red; } else if (earthquake.depth < 50) { markerColor = Colors.orange; } else if (earthquake.depth < 100) { markerColor = Colors.yellow; } else { markerColor = Colors.green; } return Marker( point: LatLng(earthquake.latitude, earthquake.longitude), width: size, height: size, builder: (context) => GestureDetector( onTap: () { _showEarthquakeDetails(context, earthquake); }, child: Container( decoration: BoxDecoration( color: markerColor.withOpacity(0.6), shape: BoxShape.circle, border: Border.all(color: markerColor, width: 2), ), child: Center( child: Text( earthquake.magnitude.toStringAsFixed(1), style: const TextStyle( color: Colors.white, fontWeight: FontWeight.bold, fontSize: 10, ), ), ), ), ), ); } void _showEarthquakeDetails(BuildContext context, Earthquake earthquake) { showModalBottomSheet( context: context, builder: (context) => Padding( padding: const EdgeInsets.all(16.0), child: Column( mainAxisSize: MainAxisSize.min, crossAxisAlignment: CrossAxisAlignment.start, children: [ Text( 'M${earthquake.magnitude.toStringAsFixed(1)} - ${earthquake.location}', style: Theme.of(context).textTheme.titleLarge, ), const SizedBox(height: 8), Text( 'Time: ${_formatDateTime(earthquake.time)}', style: Theme.of(context).textTheme.bodyLarge, ), Text( 'Depth: ${earthquake.depth.toStringAsFixed(1)} km', style: Theme.of(context).textTheme.bodyLarge, ), Text( 'Coordinates: ${earthquake.latitude.toStringAsFixed(4)}, ${earthquake.longitude.toStringAsFixed(4)}', style: Theme.of(context).textTheme.bodyLarge, ), const SizedBox(height: 16), const Text( 'Note: This is an experimental system and should not be used as an official earthquake warning system.', style: TextStyle( fontStyle: FontStyle.italic, color: Colors.red, ), ), ], ), ), ); } String _formatDateTime(DateTime dateTime) { return '${dateTime.day}/${dateTime.month}/${dateTime.year} ${dateTime.hour}:${dateTime.minute.toString().padLeft(2, '0')}'; } } [V0_FILE]plaintext:file="lib/widgets/earthquake_list.dart" isMerged="true" import 'package:flutter/material.dart'; import 'package:provider/provider.dart'; import 'package:globalquake/providers/earthquake_provider.dart'; import 'package:globalquake/models/earthquake.dart'; import 'package:intl/intl.dart'; class EarthquakeList extends StatelessWidget { const EarthquakeList({Key? key}) : super(key: key); @override Widget build(BuildContext context) { final earthquakeProvider = Provider.of(context); final earthquakes = earthquakeProvider.earthquakes; final isLoading = earthquakeProvider.isLoading; if (isLoading && earthquakes.isEmpty) { return const Center( child: CircularProgressIndicator(), ); } if (earthquakes.isEmpty) { return const Center( child: Text('No earthquakes found'), ); } return RefreshIndicator( onRefresh: () => earthquakeProvider.fetchEarthquakes(), child: ListView.builder( itemCount: earthquakes.length, itemBuilder: (context, index) { final earthquake = earthquakes[index]; return _buildEarthquakeListItem(context, earthquake); }, ), ); } Widget _buildEarthquakeListItem(BuildContext context, Earthquake earthquake) { // Determine color based on magnitude Color magnitudeColor; if (earthquake.magnitude < 4.0) { magnitudeColor = Colors.green; } else if (earthquake.magnitude < 6.0) { magnitudeColor = Colors.orange; } else { magnitudeColor = Colors.red; } return Card( margin: const EdgeInsets.symmetric(horizontal: 16, vertical: 8), child: ListTile( leading: CircleAvatar( backgroundColor: magnitudeColor, child: Text( earthquake.magnitude.toStringAsFixed(1), style: const TextStyle( color: Colors.white, fontWeight: FontWeight.bold, ), ), ), title: Text(earthquake.location), subtitle: Text( '${DateFormat('dd MMM yyyy, HH:mm').format(earthquake.time)} - Depth: ${earthquake.depth.toStringAsFixed(1)} km', ), trailing: const Icon(Icons.chevron_right), onTap: () { _showEarthquakeDetails(context, earthquake); }, ), ); } void _showEarthquakeDetails(BuildContext context, Earthquake earthquake) { showDialog( context: context, builder: (context) => AlertDialog( title: Text('M${earthquake.magnitude.toStringAsFixed(1)} - ${earthquake.location}'), content: Column( mainAxisSize: MainAxisSize.min, crossAxisAlignment: CrossAxisAlignment.start, children: [ Text('Time: ${DateFormat('dd MMM yyyy, HH:mm:ss').format(earthquake.time)}'), const SizedBox(height: 8), Text('Depth: ${earthquake.depth.toStringAsFixed(1)} km'), const SizedBox(height: 8), Text('Latitude: ${earthquake.latitude.toStringAsFixed(4)}'), Text('Longitude: ${earthquake.longitude.toStringAsFixed(4)}'), const SizedBox(height: 16), const Text( 'Note: This is an experimental system and should not be used as an official earthquake warning system.', style: TextStyle( fontStyle: FontStyle.italic, fontSize: 12, color: Colors.red, ), ), ], ), actions: [ TextButton( onPressed: () => Navigator.of(context).pop(), child: const Text('Close'), ), ], ), ); } } [V0_FILE]plaintext:file="lib/widgets/connection_status.dart" isMerged="true" import 'package:flutter/material.dart'; import 'package:provider/provider.dart'; import 'package:globalquake/providers/earthquake_provider.dart'; class ConnectionStatus extends StatelessWidget { const ConnectionStatus({Key? key}) : super(key: key); @override Widget build(BuildContext context) { final earthquakeProvider = Provider.of(context); final hasError = earthquakeProvider.hasError; final errorMessage = earthquakeProvider.errorMessage; if (!hasError) { return const SizedBox.shrink(); } return Container( width: double.infinity, padding: const EdgeInsets.symmetric(vertical: 8, horizontal: 16), color: Colors.red, child: Row( children: [ const Icon( Icons.error_outline, color: Colors.white, ), const SizedBox(width: 8), Expanded( child: Text( errorMessage ?? 'Connection error. GlobalQuake is an experimental system.', style: const TextStyle( color: Colors.white, fontWeight: FontWeight.bold, ), ), ), IconButton( icon: const Icon( Icons.refresh, color: Colors.white, ), onPressed: () { earthquakeProvider.fetchEarthquakes(); }, ), ], ), ); } } [V0_FILE]plaintext:file="lib/screens/about_screen.dart" isMerged="true" import 'package:flutter/material.dart'; import 'package:url_launcher/url_launcher.dart'; class AboutScreen extends StatelessWidget { const AboutScreen({Key? key}) : super(key: key); @override Widget build(BuildContext context) { return Scaffold( appBar: AppBar( title: const Text('About GlobalQuake'), ), body: SingleChildScrollView( padding: const EdgeInsets.all(16.0), child: Column( crossAxisAlignment: CrossAxisAlignment.start, children: [ Center( child: Image.asset( 'assets/images/logo.png', height: 120, errorBuilder: (context, error, stackTrace) { return const Icon( Icons.public, size: 120, color: Colors.blue, ); }, ), ), const SizedBox(height: 24), Text( 'GlobalQuake', style: Theme.of(context).textTheme.headlineMedium, textAlign: TextAlign.center, ), const SizedBox(height: 8), Text( 'Version 1.0.0', style: Theme.of(context).textTheme.bodyLarge, textAlign: TextAlign.center, ), const SizedBox(height: 24), Text( 'About', style: Theme.of(context).textTheme.titleLarge, ), const SizedBox(height: 8), const Text( 'GlobalQuake is an open-source application that monitors earthquakes worldwide in real-time. It retrieves seismic data from Seedlink and FDSNWS sources, visualizing earthquake locations, magnitudes, and depths.', ), const SizedBox(height: 16), Text( 'Data Sources', style: Theme.of(context).textTheme.titleLarge, ), const SizedBox(height: 8), const Text( 'GlobalQuake retrieves data from multiple seismic networks worldwide through Seedlink and FDSNWS protocols. The data is processed and displayed in near real-time.', ), const SizedBox(height: 16), Text( 'Disclaimer', style: Theme.of(context).textTheme.titleLarge?.copyWith( color: Colors.red, ), ), const SizedBox(height: 8), const Text( 'IMPORTANT: GlobalQuake is an experimental system and should NOT be used as an official earthquake warning system. The data provided may be delayed, incomplete, or inaccurate. Always refer to official government sources for critical information.', style: TextStyle( fontWeight: FontWeight.bold, color: Colors.red, ), ), const SizedBox(height: 24), Text( 'Community', style: Theme.of(context).textTheme.titleLarge, ), const SizedBox(height: 8), const Text( 'Join our Discord community to connect with other users, report issues, and contribute to the development of GlobalQuake.', ), const SizedBox(height: 16), Center( child: ElevatedButton.icon( icon: const Icon(Icons.group), label: const Text('Join Discord Community'), onPressed: () async { final Uri url = Uri.parse('https://discord.gg/globalquake'); if (!await launchUrl(url)) { if (context.mounted) { ScaffoldMessenger.of(context).showSnackBar( const SnackBar(content: Text('Could not launch Discord community link')), ); } } }, ), ), const SizedBox(height: 24), Text( 'Open Source', style: Theme.of(context).textTheme.titleLarge, ), const SizedBox(height: 8), const Text( 'GlobalQuake is open-source software. You can view the source code, report issues, and contribute to the project on GitHub.', ), const SizedBox(height: 16), Center( child: ElevatedButton.icon( icon: const Icon(Icons.code), label: const Text('View on GitHub'), onPressed: () async { final Uri url = Uri.parse('https://github.com/globalquake/globalquake'); if (!await launchUrl(url)) { if (context.mounted) { ScaffoldMessenger.of(context).showSnackBar( const SnackBar(content: Text('Could not launch GitHub link')), ); } } }, ), ), ], ), ), ); } } [V0_FILE]plaintext:file="lib/services/audio_service.dart" isMerged="true" import 'package:just_audio/just_audio.dart'; import 'package:flutter/foundation.dart'; class AudioService { final AudioPlayer _audioPlayer = AudioPlayer(); // Singleton pattern static final AudioService _instance = AudioService._internal(); factory AudioService() { return _instance; } AudioService._internal(); Future playAlertSound(double magnitude) async { try { String soundPath; // Select sound based on magnitude if (magnitude >= 7.0) { soundPath = 'assets/sounds/severe_alert.mp3'; } else if (magnitude >= 5.0) { soundPath = 'assets/sounds/moderate_alert.mp3'; } else { soundPath = 'assets/sounds/minor_alert.mp3'; } await _audioPlayer.setAsset(soundPath); await _audioPlayer.play(); } catch (e) { debugPrint('Error playing alert sound: $e'); } } Future playCustomSound(String soundPath) async { try { await _audioPlayer.setAsset(soundPath); await _audioPlayer.play(); } catch (e) { debugPrint('Error playing custom sound: $e'); } } Future stop() async { await _audioPlayer.stop(); } Future dispose() async { await _audioPlayer.dispose(); } } [V0_FILE]shellscript:file="setup_globalquake.sh" isEdit="true" isMerged="true" #!/bin/bash # GlobalQuake Gelişmiş Kurulum Scripti echo "GlobalQuake gelişmiş kurulumu başlatılıyor..." # Renkli çıktı için RED='\033[0;31m' GREEN='\033[0;32m' YELLOW='\033[0;33m' BLUE='\033[0;34m' NC='\033[0m' # No Color # Flutter'ın kurulu olup olmadığını kontrol et if ! command -v flutter &> /dev/null; then echo -e "${RED}Flutter kurulu değil. Lütfen Flutter'ı kurun: https://flutter.dev/docs/get-started/install/linux${NC}" exit 1 fi # Linux desteğinin etkin olup olmadığını kontrol et LINUX_ENABLED=$(flutter config --list | grep "enable-linux" | awk '{print $2}') if [ "$LINUX_ENABLED" != "true" ]; then echo -e "${YELLOW}Linux desteği etkinleştiriliyor...${NC}" flutter config --enable-linux-desktop fi # Gerekli paketlerin kurulu olup olmadığını kontrol et echo -e "${BLUE}Gerekli sistem paketleri kontrol ediliyor...${NC}" REQUIRED_PACKAGES="libgtk-3-dev libblkid-dev liblzma-dev libsecret-1-dev libgstreamer1.0-dev libgstreamer-plugins-base1.0-dev" for package in $REQUIRED_PACKAGES; do if ! dpkg -l | grep -q $package; then echo -e "${YELLOW}$package paketi kurulu değil. Kurulacak...${NC}" sudo apt-get update && sudo apt-get install -y $package fi done # Proje dizinini oluştur echo -e "${BLUE}Proje dizini oluşturuluyor...${NC}" mkdir -p globalquake cd globalquake # pubspec.yaml dosyasını oluştur echo -e "${BLUE}pubspec.yaml dosyası oluşturuluyor...${NC}" cat > pubspec.yaml << 'EOL' name: globalquake description: Türkiye dahil tüm dünyadan gerçek zamanlı deprem verilerini izleyen açık kaynaklı bir uygulama. publish_to: 'none' version: 1.0.0+1 environment: sdk: '>=3.0.0 <4.0.0' dependencies: flutter: sdk: flutter flutter_localizations: sdk: flutter # UI cupertino_icons: ^1.0.6 flutter_map: ^6.0.1 latlong2: ^0.9.0 flutter_globe: ^2.0.0 fl_chart: ^0.65.0 syncfusion_flutter_charts: ^23.1.44 syncfusion_flutter_maps: ^23.1.44 lottie: ^2.6.0 # State management provider: ^6.1.1 flutter_bloc: ^8.1.3 # Data http: ^1.1.0 dio: ^5.3.3 shared_preferences: ^2.2.2 hive: ^2.2.3 hive_flutter: ^1.1.0 sqflite: ^2.3.0 path_provider: ^2.1.1 intl: ^0.18.1 # Notifications and audio flutter_local_notifications: ^16.1.0 just_audio: ^0.9.36 background_fetch: ^1.2.1 workmanager: ^0.5.1 # Location geolocator: ^10.1.0 geocoding: ^2.1.1 # Utils url_launcher: ^6.2.1 share_plus: ^7.2.1 connectivity_plus: ^5.0.1 package_info_plus: ^4.2.0 device_info_plus: ^9.1.0 flutter_native_splash: ^2.3.5 flutter_launcher_icons: ^0.13.1 # 3D Visualization vector_math: ^2.1.4 flutter_gl: ^0.0.21 three_dart: ^0.0.16 dev_dependencies: flutter_test: sdk: flutter flutter_lints: ^3.0.0 build_runner: ^2.4.6 hive_generator: ^2.0.1 flutter: uses-material-design: true assets: - assets/images/ - assets/sounds/ - assets/animations/ - assets/data/ - assets/models/ fonts: - family: Roboto fonts: - asset: assets/fonts/Roboto-Regular.ttf - asset: assets/fonts/Roboto-Bold.ttf weight: 700 - asset: assets/fonts/Roboto-Light.ttf weight: 300 EOL # Dizin yapısını oluştur echo -e "${BLUE}Dizin yapısı oluşturuluyor...${NC}" mkdir -p lib/{models,providers,screens,services,widgets,utils,repositories,blocs,data_sources,config} mkdir -p lib/widgets/{map,charts,settings,notifications,common} mkdir -p assets/{images,sounds,animations,data,models,fonts} mkdir -p linux # Ses dosyalarını oluştur (boş dosyalar) echo -e "${BLUE}Ses dosyaları oluşturuluyor...${NC}" touch assets/sounds/alert1.mp3 touch assets/sounds/alert2.mp3 touch assets/sounds/alert3.mp3 touch assets/sounds/siren.mp3 touch assets/sounds/beep.mp3 touch assets/sounds/minor_alert.mp3 touch assets/sounds/moderate_alert.mp3 touch assets/sounds/severe_alert.mp3 touch assets/sounds/tsunami_warning.mp3 # Logo ve diğer görselleri oluştur echo -e "${BLUE}Logo ve görseller oluşturuluyor...${NC}" cat > assets/images/logo.png << 'EOL' iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAADUlEQVR42mP8z8BQDwAEhQGAhKmMIQAAAABJRU5ErkJggg== EOL # Font dosyalarını indir echo -e "${BLUE}Font dosyaları indiriliyor...${NC}" mkdir -p downloads/fonts cd downloads/fonts wget -q -O Roboto-Regular.ttf "https://github.com/google/fonts/raw/main/apache/roboto/Roboto-Regular.ttf" || echo "Roboto-Regular.ttf indirilemedi" wget -q -O Roboto-Bold.ttf "https://github.com/google/fonts/raw/main/apache/roboto/Roboto-Bold.ttf" || echo "Roboto-Bold.ttf indirilemedi" wget -q -O Roboto-Light.ttf "https://github.com/google/fonts/raw/main/apache/roboto/Roboto-Light.ttf" || echo "Roboto-Light.ttf indirilemedi" mkdir -p ../../assets/fonts mv *.ttf ../../assets/fonts/ 2>/dev/null || echo "Font dosyaları taşınamadı" cd ../.. # Animasyon dosyalarını indir echo -e "${BLUE}Animasyon dosyaları indiriliyor...${NC}" mkdir -p downloads/animations cd downloads/animations wget -q -O earthquake.json "https://assets9.lottiefiles.com/packages/lf20_khrclx93.json" || echo "earthquake.json indirilemedi" wget -q -O loading.json "https://assets5.lottiefiles.com/packages/lf20_usmfx6bp.json" || echo "loading.json indirilemedi" wget -q -O warning.json "https://assets8.lottiefiles.com/private_files/lf30_plicdd0k.json" || echo "warning.json indirilemedi" mkdir -p ../../assets/animations mv *.json ../../assets/animations/ 2>/dev/null || echo "Animasyon dosyaları taşınamadı" cd ../.. # Tektonik plaka verileri echo -e "${BLUE}Tektonik plaka verileri indiriliyor...${NC}" mkdir -p downloads/data cd downloads/data wget -q -O tectonic_plates.json "https://raw.githubusercontent.com/fraxen/tectonicplates/master/GeoJSON/PB2002_boundaries.json" || echo "tectonic_plates.json indirilemedi" mkdir -p ../../assets/data mv *.json ../../assets/data/ 2>/dev/null || echo "Veri dosyaları taşınamadı" cd ../.. # Dosyaları oluştur echo -e "${BLUE}Uygulama dosyaları oluşturuluyor...${NC}" # config/constants.dart cat > lib/config/constants.dart << 'EOL' class AppConstants { // API Endpoints static const String usgsEarthquakeApi = 'https://earthquake.usgs.gov/fdsnws/event/1/query'; static const String afadEarthquakeApi = 'https://deprem.afad.gov.tr/apiv2/event/filter'; static const String kandilliEarthquakeApi = 'http://www.koeri.boun.edu.tr/scripts/lst0.asp'; static const String emscEarthquakeApi = 'https://www.seismicportal.eu/fdsnws/event/1/query'; // App Settings static const int defaultRefreshInterval = 60; // seconds static const double defaultMinimumMagnitude = 4.0; static const int maxStoredEarthquakes = 1000; static const int offlineCacheExpiryHours = 24; // Map Settings static const double defaultMapZoom = 5.0; static const double defaultMapLatitude = 39.0; // Turkey centered static const double defaultMapLongitude = 35.0; // Notification Channels static const String mainNotificationChannelId = 'earthquake_channel'; static const String mainNotificationChannelName = 'Deprem Uyarıları'; static const String mainNotificationChannelDescription = 'Önemli depremler için bildirimler'; // URLs static const String discordUrl = 'https://discord.gg/globalquake'; static const String githubUrl = 'https://github.com/globalquake/globalquake'; static const String privacyPolicyUrl = 'https://globalquake.org/privacy'; // Local Storage Keys static const String settingsBoxName = 'settings'; static const String earthquakesBoxName = 'earthquakes'; static const String favoritesBoxName = 'favorites'; // Earthquake Sources static const Map earthquakeSources = { 'usgs': 'USGS', 'afad': 'AFAD', 'kandilli': 'Kandilli Rasathanesi', 'emsc': 'EMSC', }; // Magnitude Colors static const Map magnitudeColors = { 'minor': '#4CAF50', // < 4.0 'light': '#8BC34A', // 4.0-4.9 'moderate': '#FFEB3B', // 5.0-5.9 'strong': '#FF9800', // 6.0-6.9 'major': '#FF5722', // 7.0-7.9 'great': '#F44336', // >= 8.0 }; } EOL # config/themes.dart cat > lib/config/themes.dart << 'EOL' import 'package:flutter/material.dart'; class AppThemes { static ThemeData lightTheme = ThemeData( useMaterial3: true, colorScheme: ColorScheme.fromSeed( seedColor: Colors.blue, brightness: Brightness.light, ), fontFamily: 'Roboto', appBarTheme: const AppBarTheme( centerTitle: true, elevation: 0, ), cardTheme: CardTheme( elevation: 2, shape: RoundedRectangleBorder( borderRadius: BorderRadius.circular(12), ), ), elevatedButtonTheme: ElevatedButtonThemeData( style: ElevatedButton.styleFrom( elevation: 2, shape: RoundedRectangleBorder( borderRadius: BorderRadius.circular(8), ), ), ), ); static ThemeData darkTheme = ThemeData( useMaterial3: true, colorScheme: ColorScheme.fromSeed( seedColor: Colors.blue, brightness: Brightness.dark, ), fontFamily: 'Roboto', appBarTheme: const AppBarTheme( centerTitle: true, elevation: 0, ), cardTheme: CardTheme( elevation: 2, shape: RoundedRectangleBorder( borderRadius: BorderRadius.circular(12), ), ), elevatedButtonTheme: ElevatedButtonThemeData( style: ElevatedButton.styleFrom( elevation: 2, shape: RoundedRectangleBorder( borderRadius: BorderRadius.circular(8), ), ), ), ); } EOL # main.dart cat > lib/main.dart << 'EOL' import 'package:flutter/material.dart'; import 'package:flutter_localizations/flutter_localizations.dart'; import 'package:provider/provider.dart'; import 'package:hive_flutter/hive_flutter.dart'; import 'package:flutter_bloc/flutter_bloc.dart'; import 'package:workmanager/workmanager.dart'; import 'package:background_fetch/background_fetch.dart'; import 'package:globalquake/config/constants.dart'; import 'package:globalquake/config/themes.dart'; import 'package:globalquake/models/earthquake.dart'; import 'package:globalquake/models/settings.dart'; import 'package:globalquake/providers/earthquake_provider.dart'; import 'package:globalquake/providers/settings_provider.dart'; import 'package:globalquake/providers/theme_provider.dart'; import 'package:globalquake/providers/location_provider.dart'; import 'package:globalquake/screens/home_screen.dart'; import 'package:globalquake/services/notification_service.dart'; import 'package:globalquake/services/background_service.dart'; import 'package:globalquake/blocs/earthquake/earthquake_bloc.dart'; import 'package:globalquake/repositories/earthquake_repository.dart'; import 'package:globalquake/data_sources/earthquake_data_source.dart'; import 'package:globalquake/utils/localization.dart'; void main() async { WidgetsFlutterBinding.ensureInitialized(); // Initialize Hive await Hive.initFlutter(); Hive.registerAdapter(EarthquakeAdapter()); Hive.registerAdapter(SettingsAdapter()); await Hive.openBox(AppConstants.settingsBoxName); await Hive.openBox(AppConstants.earthquakesBoxName); await Hive.openBox(AppConstants.favoritesBoxName); // Initialize background services await Workmanager().initialize( BackgroundService.callbackDispatcher, isInDebugMode: false, ); await BackgroundFetch.configure( BackgroundFetchConfig( minimumFetchInterval: 15, stopOnTerminate: false, enableHeadless: true, requiresBatteryNotLow: false, requiresCharging: false, requiresStorageNotLow: false, requiresDeviceIdle: false, requiredNetworkType: NetworkType.ANY, ), BackgroundService.onBackgroundFetch, ); // Initialize notification service final notificationService = NotificationService(); await notificationService.initialize(); // Initialize data sources and repositories final earthquakeDataSource = EarthquakeDataSource(); final earthquakeRepository = EarthquakeRepository(earthquakeDataSource); runApp( MultiRepositoryProvider( providers: [ RepositoryProvider.value(value: earthquakeRepository), ], child: MultiBlocProvider( providers: [ BlocProvider( create: (context) => EarthquakeBloc( earthquakeRepository: earthquakeRepository, )..add(FetchEarthquakes()), ), ], child: MultiProvider( providers: [ ChangeNotifierProvider(create: (_) => EarthquakeProvider(earthquakeRepository)), ChangeNotifierProvider(create: (_) => SettingsProvider()), ChangeNotifierProvider(create: (_) => ThemeProvider()), ChangeNotifierProvider(create: (_) => LocationProvider()), Provider.value(value: notificationService), ], child: const GlobalQuakeApp(), ), ), ), ); } class GlobalQuakeApp extends StatelessWidget { const GlobalQuakeApp({Key? key}) : super(key: key); @override Widget build(BuildContext context) { final themeProvider = Provider.of(context); return MaterialApp( title: 'GlobalQuake', debugShowCheckedModeBanner: false, theme: AppThemes.lightTheme, darkTheme: AppThemes.darkTheme, themeMode: themeProvider.themeMode, localizationsDelegates: const [ AppLocalizations.delegate, GlobalMaterialLocalizations.delegate, GlobalWidgetsLocalizations.delegate, GlobalCupertinoLocalizations.delegate, ], supportedLocales: const [ Locale('tr', ''), // Turkish Locale('en', ''), // English ], home: const HomeScreen(), ); } } EOL # models/earthquake.dart cat > lib/models/earthquake.dart << 'EOL' import 'package:hive/hive.dart'; part 'earthquake.g.dart'; @HiveType(typeId: 0) class Earthquake { @HiveField(0) final String id; @HiveField(1) final double magnitude; @HiveField(2) final double depth; @HiveField(3) final double latitude; @HiveField(4) final double longitude; @HiveField(5) final String location; @HiveField(6) final DateTime time; @HiveField(7) final String source; @HiveField(8) final String? country; @HiveField(9) final String? region; @HiveField(10) final double? intensity; @HiveField(11) final String? magnitudeType; @HiveField(12) final String? status; // "automatic", "reviewed", etc. @HiveField(13) final DateTime? updatedAt; @HiveField(14) final Map? additionalData; Earthquake({ required this.id, required this.magnitude, required this.depth, required this.latitude, required this.longitude, required this.location, required this.time, required this.source, this.country, this.region, this.intensity, this.magnitudeType, this.status, this.updatedAt, this.additionalData, }); factory Earthquake.fromJson(Map json, {required String source}) { switch (source) { case 'usgs': return Earthquake._fromUsgsJson(json); case 'afad': return Earthquake._fromAfadJson(json); case 'kandilli': return Earthquake._fromKandilliJson(json); case 'emsc': return Earthquake._fromEmscJson(json); default: throw Exception('Unknown earthquake source: $source'); } } // USGS format parser factory Earthquake._fromUsgsJson(Map json) { final properties = json['properties']; final geometry = json['geometry']; final coordinates = geometry['coordinates']; return Earthquake( id: json['id'], magnitude: (properties['mag'] ?? 0).toDouble(), depth: coordinates[2].toDouble(), latitude: coordinates[1].toDouble(), longitude: coordinates[0].toDouble(), location: properties['place'] ?? 'Unknown location', time: DateTime.fromMillisecondsSinceEpoch(properties['time']), source: 'usgs', country: null, // USGS doesn't provide country directly region: null, // USGS doesn't provide region directly intensity: properties['mmi']?.toDouble(), magnitudeType: properties['magType'], status: properties['status'], updatedAt: properties['updated'] != null ? DateTime.fromMillisecondsSinceEpoch(properties['updated']) : null, additionalData: { 'tsunami': properties['tsunami'], 'felt': properties['felt'], 'cdi': properties['cdi'], 'url': properties['url'], 'alert': properties['alert'], }, ); } // AFAD format parser factory Earthquake._fromAfadJson(Map json) { return Earthquake( id: json['eventID'].toString(), magnitude: (json['magnitude'] ?? 0).toDouble(), depth: (json['depth'] ?? 0).toDouble(), latitude: (json['latitude'] ?? 0).toDouble(), longitude: (json['longitude'] ?? 0).toDouble(), location: json['location'] ?? 'Bilinmeyen konum', time: DateTime.parse(json['date']), source: 'afad', country: 'Türkiye', // AFAD is Turkey's disaster agency region: json['province'], intensity: null, // AFAD doesn't provide intensity magnitudeType: json['magnitudeType'], status: json['status'], updatedAt: json['lastUpdateDate'] != null ? DateTime.parse(json['lastUpdateDate']) : null, additionalData: { 'type': json['type'], 'rms': json['rms'], }, ); } // Kandilli format parser (text parsing as Kandilli provides data in text format) factory Earthquake._fromKandilliJson(Map json) { return Earthquake( id: json['id'] ?? DateTime.now().millisecondsSinceEpoch.toString(), magnitude: (json['magnitude'] ?? 0).toDouble(), depth: (json['depth'] ?? 0).toDouble(), latitude: (json['latitude'] ?? 0).toDouble(), longitude: (json['longitude'] ?? 0).toDouble(), location: json['location'] ?? 'Bilinmeyen konum', time: json['time'] != null ? DateTime.parse(json['time']) : DateTime.now(), source: 'kandilli', country: 'Türkiye', // Kandilli is Turkey's seismological institute region: json['region'], intensity: null, magnitudeType: json['magnitudeType'] ?? 'ML', status: null, updatedAt: null, additionalData: null, ); } // EMSC format parser factory Earthquake._fromEmscJson(Map json) { final properties = json['properties']; final geometry = json['geometry']; final coordinates = geometry['coordinates']; return Earthquake( id: properties['unid'].toString(), magnitude: (properties['mag'] ?? 0).toDouble(), depth: coordinates[2].toDouble(), latitude: coordinates[1].toDouble(), longitude: coordinates[0].toDouble(), location: properties['flynn_region'] ?? 'Unknown location', time: DateTime.parse(properties['time']), source: 'emsc', country: null, region: null, intensity: null, magnitudeType: properties['magtype'], status: properties['evtype'], updatedAt: null, additionalData: { 'auth': properties['auth'], 'lastupdate': properties['lastupdate'], }, ); } Map toJson() { return { 'id': id, 'magnitude': magnitude, 'depth': depth, 'latitude': latitude, 'longitude': longitude, 'location': location, 'time': time.toIso8601String(), 'source': source, 'country': country, 'region': region, 'intensity': intensity, 'magnitudeType': magnitudeType, 'status': status, 'updatedAt': updatedAt?.toIso8601String(), 'additionalData': additionalData, }; } // Get color based on magnitude Color getMagnitudeColor() { if (magnitude < 4.0) { return const Color(0xFF4CAF50); // Green } else if (magnitude < 5.0) { return const Color(0xFF8BC34A); // Light Green } else if (magnitude < 6.0) { return const Color(0xFFFFEB3B); // Yellow } else if (magnitude < 7.0) { return const Color(0xFFFF9800); // Orange } else if (magnitude < 8.0) { return const Color(0xFFFF5722); // Deep Orange } else { return const Color(0xFFF44336); // Red } } // Get magnitude category String getMagnitudeCategory() { if (magnitude < 4.0) { return 'Hafif'; } else if (magnitude < 5.0) { return 'Orta'; } else if (magnitude < 6.0) { return 'Orta-Kuvvetli'; } else if (magnitude < 7.0) { return 'Kuvvetli'; } else if (magnitude < 8.0) { return 'Büyük'; } else { return 'Çok Büyük'; } } // Calculate distance from a point double distanceFrom(double lat, double lon) { // Haversine formula implementation const double earthRadius = 6371; // km final double dLat = _degreesToRadians(lat - latitude); final double dLon = _degreesToRadians(lon - longitude); final double a = sin(dLat / 2) * sin(dLat / 2) + cos(_degreesToRadians(latitude)) * cos(_degreesToRadians(lat)) * sin(dLon / 2) * sin(dLon / 2); final double c = 2 * atan2(sqrt(a), sqrt(1 - a)); return earthRadius * c; } double _degreesToRadians(double degrees) { return degrees * (pi / 180); } } // Generate with: flutter packages pub run build_runner build EOL # models/earthquake.g.dart (Hive adapter) cat > lib/models/earthquake.g.dart << 'EOL' // GENERATED CODE - DO NOT MODIFY BY HAND part of 'earthquake.dart'; // ************************************************************************** // TypeAdapterGenerator // ************************************************************************** class EarthquakeAdapter extends TypeAdapter { @override final int typeId = 0; @override Earthquake read(BinaryReader reader) { final numOfFields = reader.readByte(); final fields = { for (int i = 0; i < numOfFields; i++) reader.readByte(): reader.read(), }; return Earthquake( id: fields[0] as String, magnitude: fields[1] as double, depth: fields[2] as double, latitude: fields[3] as double, longitude: fields[4] as double, location: fields[5] as String, time: fields[6] as DateTime, source: fields[7] as String, country: fields[8] as String?, region: fields[9] as String?, intensity: fields[10] as double?, magnitudeType: fields[11] as String?, status: fields[12] as String?, updatedAt: fields[13] as DateTime?, additionalData: (fields[14] as Map?)?.cast(), ); } @override void write(BinaryWriter writer, Earthquake obj) { writer ..writeByte(15) ..writeByte(0) ..write(obj.id) ..writeByte(1) ..write(obj.magnitude) ..writeByte(2) ..write(obj.depth) ..writeByte(3) ..write(obj.latitude) ..writeByte(4) ..write(obj.longitude) ..writeByte(5) ..write(obj.location) ..writeByte(6) ..write(obj.time) ..writeByte(7) ..write(obj.source) ..writeByte(8) ..write(obj.country) ..writeByte(9) ..write(obj.region) ..writeByte(10) ..write(obj.intensity) ..writeByte(11) ..write(obj.magnitudeType) ..writeByte(12) ..write(obj.status) ..writeByte(13) ..write(obj.updatedAt) ..writeByte(14) ..write(obj.additionalData); } @override int get hashCode => typeId.hashCode; @override bool operator ==(Object other) => identical(this, other) || other is EarthquakeAdapter && runtimeType == other.runtimeType && typeId == other.typeId; } EOL # models/settings.dart cat > lib/models/settings.dart << 'EOL' import 'package:hive/hive.dart'; import 'package:globalquake/config/constants.dart'; part 'settings.g.dart'; @HiveType(typeId: 1) class Settings { @HiveField(0) final bool notificationsEnabled; @HiveField(1) final bool soundAlertsEnabled; @HiveField(2) final double minimumMagnitude; @HiveField(3) final String selectedSound; @HiveField(4) final int refreshInterval; @HiveField(5) final bool backgroundRefreshEnabled; @HiveField(6) final String language; @HiveField(7) final String mapType; @HiveField(8) final bool showTectonicPlates; @HiveField(9) final bool use3DGlobe; @HiveField(10) final List enabledSources; @HiveField(11) final List favoriteRegions; @HiveField(12) final bool autoStartOnBoot; @HiveField(13) final bool offlineModeEnabled; @HiveField(14) final int offlineCacheExpiryHours; @HiveField(15) final bool locationBasedAlertsEnabled; @HiveField(16) final double alertRadius; @HiveField(17) final Map? additionalSettings; Settings({ this.notificationsEnabled = true, this.soundAlertsEnabled = true, this.minimumMagnitude = 4.0, this.selectedSound = 'Alert 1 (Default)', this.refreshInterval = 60, this.backgroundRefreshEnabled = true, this.language = 'tr', this.mapType = 'standard', this.showTectonicPlates = true, this.use3DGlobe = false, this.enabledSources = const ['usgs', 'afad', 'kandilli', 'emsc'], this.favoriteRegions = const [], this.autoStartOnBoot = false, this.offlineModeEnabled = true, this.offlineCacheExpiryHours = 24, this.locationBasedAlertsEnabled = false, this.alertRadius = 300.0, // km this.additionalSettings, }); Settings copyWith({ bool? notificationsEnabled, bool? soundAlertsEnabled, double? minimumMagnitude, String? selectedSound, int? refreshInterval, bool? backgroundRefreshEnabled, String? language, String? mapType, bool? showTectonicPlates, bool? use3DGlobe, List? enabledSources, List? favoriteRegions, bool? autoStartOnBoot, bool? offlineModeEnabled, int? offlineCacheExpiryHours, bool? locationBasedAlertsEnabled, double? alertRadius, Map? additionalSettings, }) { return Settings( notificationsEnabled: notificationsEnabled ?? this.notificationsEnabled, soundAlertsEnabled: soundAlertsEnabled ?? this.soundAlertsEnabled, minimumMagnitude: minimumMagnitude ?? this.minimumMagnitude, selectedSound: selectedSound ?? this.selectedSound, refreshInterval: refreshInterval ?? this.refreshInterval, backgroundRefreshEnabled: backgroundRefreshEnabled ?? this.backgroundRefreshEnabled, language: language ?? this.language, mapType: mapType ?? this.mapType, showTectonicPlates: showTectonicPlates ?? this.showTectonicPlates, use3DGlobe: use3DGlobe ?? this.use3DGlobe, enabledSources: enabledSources ?? this.enabledSources, favoriteRegions: favoriteRegions ?? this.favoriteRegions, autoStartOnBoot: autoStartOnBoot ?? this.autoStartOnBoot, offlineModeEnabled: offlineModeEnabled ?? this.offlineModeEnabled, offlineCacheExpiryHours: offlineCacheExpiryHours ?? this.offlineCacheExpiryHours, locationBasedAlertsEnabled: locationBasedAlertsEnabled ?? this.locationBasedAlertsEnabled, alertRadius: alertRadius ?? this.alertRadius, additionalSettings: additionalSettings ?? this.additionalSettings, ); } Map toJson() { return { 'notificationsEnabled': notificationsEnabled, 'soundAlertsEnabled': soundAlertsEnabled, 'minimumMagnitude': minimumMagnitude, 'selectedSound': selectedSound, 'refreshInterval': refreshInterval, 'backgroundRefreshEnabled': backgroundRefreshEnabled, 'language': language, 'mapType': mapType, 'showTectonicPlates': showTectonicPlates, 'use3DGlobe': use3DGlobe, 'enabledSources': enabledSources, 'favoriteRegions': favoriteRegions, 'autoStartOnBoot': autoStartOnBoot, 'offlineModeEnabled': offlineModeEnabled, 'offlineCacheExpiryHours': offlineCacheExpiryHours, 'locationBasedAlertsEnabled': locationBasedAlertsEnabled, 'alertRadius': alertRadius, 'additionalSettings': additionalSettings, }; } factory Settings.fromJson(Map json) { return Settings( notificationsEnabled: json['notificationsEnabled'] ?? true, soundAlertsEnabled: json['soundAlertsEnabled'] ?? true, minimumMagnitude: json['minimumMagnitude'] ?? 4.0, selectedSound: json['selectedSound'] ?? 'Alert 1 (Default)', refreshInterval: json['refreshInterval'] ?? 60, backgroundRefreshEnabled: json['backgroundRefreshEnabled'] ?? true, language: json['language'] ?? 'tr', mapType: json['mapType'] ?? 'standard', showTectonicPlates: json['showTectonicPlates'] ?? true, use3DGlobe: json['use3DGlobe'] ?? false, enabledSources: List.from(json['enabledSources'] ?? ['usgs', 'afad', 'kandilli', 'emsc']), favoriteRegions: List.from(json['favoriteRegions'] ?? []), autoStartOnBoot: json['autoStartOnBoot'] ?? false, offlineModeEnabled: json['offlineModeEnabled'] ?? true, offlineCacheExpiryHours: json['offlineCacheExpiryHours'] ?? 24, locationBasedAlertsEnabled: json['locationBasedAlertsEnabled'] ?? false, alertRadius: json['alertRadius'] ?? 300.0, additionalSettings: json['additionalSettings'], ); } static Settings getDefault() { return Settings( notificationsEnabled: true, soundAlertsEnabled: true, minimumMagnitude: AppConstants.defaultMinimumMagnitude, selectedSound: 'Alert 1 (Default)', refreshInterval: AppConstants.defaultRefreshInterval, backgroundRefreshEnabled: true, language: 'tr', mapType: 'standard', showTectonicPlates: true, use3DGlobe: false, enabledSources: ['usgs', 'afad', 'kandilli', 'emsc'], favoriteRegions: [], autoStartOnBoot: false, offlineModeEnabled: true, offlineCacheExpiryHours: AppConstants.offlineCacheExpiryHours, locationBasedAlertsEnabled: false, alertRadius: 300.0, ); } } // Generate with: flutter packages pub run build_runner build EOL # models/settings.g.dart (Hive adapter) cat > lib/models/settings.g.dart << 'EOL' // GENERATED CODE - DO NOT MODIFY BY HAND part of 'settings.dart'; // ************************************************************************** // TypeAdapterGenerator // ************************************************************************** class SettingsAdapter extends TypeAdapter { @override final int typeId = 1; @override Settings read(BinaryReader reader) { final numOfFields = reader.readByte(); final fields = { for (int i = 0; i < numOfFields; i++) reader.readByte(): reader.read(), }; return Settings( notificationsEnabled: fields[0] as bool, soundAlertsEnabled: fields[1] as bool, minimumMagnitude: fields[2] as double, selectedSound: fields[3] as String, refreshInterval: fields[4] as int, backgroundRefreshEnabled: fields[5] as bool, language: fields[6] as String, mapType: fields[7] as String, showTectonicPlates: fields[8] as bool, use3DGlobe: fields[9] as bool, enabledSources: (fields[10] as List).cast(), favoriteRegions: (fields[11] as List).cast(), autoStartOnBoot: fields[12] as bool, offlineModeEnabled: fields[13] as bool, offlineCacheExpiryHours: fields[14] as int, locationBasedAlertsEnabled: fields[15] as bool, alertRadius: fields[16] as double, additionalSettings: (fields[17] as Map?)?.cast(), ); } @override void write(BinaryWriter writer, Settings obj) { writer ..writeByte(18) ..writeByte(0) ..write(obj.notificationsEnabled) ..writeByte(1) ..write(obj.soundAlertsEnabled) ..writeByte(2) ..write(obj.minimumMagnitude) ..writeByte(3) ..write(obj.selectedSound) ..writeByte(4) ..write(obj.refreshInterval) ..writeByte(5) ..write(obj.backgroundRefreshEnabled) ..writeByte(6) ..write(obj.language) ..writeByte(7) ..write(obj.mapType) ..writeByte(8) ..write(obj.showTectonicPlates) ..writeByte(9) ..write(obj.use3DGlobe) ..writeByte(10) ..write(obj.enabledSources) ..writeByte(11) ..write(obj.favoriteRegions) ..writeByte(12) ..write(obj.autoStartOnBoot) ..writeByte(13) ..write(obj.offlineModeEnabled) ..writeByte(14) ..write(obj.offlineCacheExpiryHours) ..writeByte(15) ..write(obj.locationBasedAlertsEnabled) ..writeByte(16) ..write(obj.alertRadius) ..writeByte(17) ..write(obj.additionalSettings); } @override int get hashCode => typeId.hashCode; @override bool operator ==(Object other) => identical(this, other) || other is SettingsAdapter && runtimeType == other.runtimeType && typeId == other.typeId; } EOL # data_sources/earthquake_data_source.dart cat > lib/data_sources/earthquake_data_source.dart << 'EOL' import 'dart:convert'; import 'dart:io'; import 'package:dio/dio.dart'; import 'package:html/parser.dart' as html_parser; import 'package:globalquake/config/constants.dart'; import 'package:globalquake/models/earthquake.dart'; import 'package:globalquake/utils/connectivity_utils.dart'; import 'package:globalquake/utils/logger.dart'; class EarthquakeDataSource { final Dio _dio = Dio(BaseOptions( connectTimeout: const Duration(seconds: 10), receiveTimeout: const Duration(seconds: 10), )); // Fetch earthquakes from USGS Future> fetchUsgsEarthquakes({ int limit = 100, double minMagnitude = 2.5, int days = 30, }) async { try { final response = await _dio.get( AppConstants.usgsEarthquakeApi, queryParameters: { 'format': 'geojson', 'limit': limit, 'minmagnitude': minMagnitude, 'starttime': DateTime.now().subtract(Duration(days: days)).toIso8601String(), 'endtime': DateTime.now().toIso8601String(), }, ); if (response.statusCode == 200) { final data = response.data; final List features = data['features']; return features.map((feature) => Earthquake.fromJson(feature, source: 'usgs') ).toList(); } else { throw Exception('Failed to load USGS earthquakes: ${response.statusCode}'); } } catch (e) { Logger.error('Error fetching USGS earthquakes: $e'); return []; } } // Fetch earthquakes from AFAD (Turkey's Disaster and Emergency Management Authority) Future> fetchAfadEarthquakes({ int limit = 100, double minMagnitude = 2.5, int days = 30, }) async { try { final response = await _dio.get( AppConstants.afadEarthquakeApi, queryParameters: { 'start': DateTime.now().subtract(Duration(days: days)).toIso8601String(), 'end': DateTime.now().toIso8601String(), 'minMag': minMagnitude, 'limit': limit, }, ); if (response.statusCode == 200) { final List earthquakes = response.data; return earthquakes.map((earthquake) => Earthquake.fromJson(earthquake, source: 'afad') ).toList(); } else { throw Exception('Failed to load AFAD earthquakes: ${response.statusCode}'); } } catch (e) { Logger.error('Error fetching AFAD earthquakes: $e'); return []; } } // Fetch earthquakes from Kandilli Observatory (Boğaziçi University, Turkey) Future> fetchKandilliEarthquakes({ double minMagnitude = 2.5, }) async { try { final response = await _dio.get(AppConstants.kandilliEarthquakeApi); if (response.statusCode == 200) { // Kandilli provides data in HTML format, so we need to parse it final document = html_parser.parse(response.data); final List earthquakes = []; // Find the pre element containing earthquake data final preElement = document.querySelector('pre'); if (preElement != null) { final lines = preElement.text.split('\n'); // Skip header lines for (int i = 7; i < lines.length; i++) { final line = lines[i].trim(); if (line.isEmpty) continue; try { // Parse the line (format may change, adjust as needed) final parts = line.split(RegExp(r'\s+')); if (parts.length < 9) continue; final date = parts[0]; final time = parts[1]; final latitude = double.tryParse(parts[2]) ?? 0; final longitude = double.tryParse(parts[3]) ?? 0; final depth = double.tryParse(parts[4]) ?? 0; final magnitude = double.tryParse(parts[6]) ?? 0; // Skip if magnitude is below threshold if (magnitude < minMagnitude) continue; // Extract location (everything after the magnitude) final location = parts.sublist(8).join(' ').trim(); final earthquake = Earthquake( id: '${date}_${time}_kandilli', magnitude: magnitude, depth: depth, latitude: latitude, longitude: longitude, location: location, time: _parseKandilliDateTime(date, time), source: 'kandilli', country: 'Türkiye', region: _extractRegionFromLocation(location), magnitudeType: 'ML', // Kandilli typically uses ML (Local Magnitude) ); earthquakes.add(earthquake); } catch (e) { Logger.error('Error parsing Kandilli earthquake line: $e'); continue; } } } return earthquakes; } else { throw Exception('Failed to load Kandilli earthquakes: ${response.statusCode}'); } } catch (e) { Logger.error('Error fetching Kandilli earthquakes: $e'); return []; } } // Fetch earthquakes from EMSC (European-Mediterranean Seismological Centre) Future> fetchEmscEarthquakes({ int limit = 100, double minMagnitude = 2.5, int days = 30, }) async { try { final response = await _dio.get( AppConstants.emscEarthquakeApi, queryParameters: { 'format': 'json', 'limit': limit, 'minmag': minMagnitude, 'start': DateTime.now().subtract(Duration(days: days)).toIso8601String(), 'end': DateTime.now().toIso8601String(), }, ); if (response.statusCode == 200) { final data = response.data; final List features = data['features']; return features.map((feature) => Earthquake.fromJson(feature, source: 'emsc') ).toList(); } else { throw Exception('Failed to load EMSC earthquakes: ${response.statusCode}'); } } catch (e) { Logger.error('Error fetching EMSC earthquakes: $e'); return []; } } // Fetch earthquakes from all sources Future> fetchAllEarthquakes({ List sources = const ['usgs', 'afad', 'kandilli', 'emsc'], double minMagnitude = 2.5, int limit = 100, int days = 30, }) async { // Check connectivity first final hasConnection = await ConnectivityUtils.hasInternetConnection(); if (!hasConnection) { Logger.warn('No internet connection, returning empty earthquake list'); return []; } final List allEarthquakes = []; final List>> futures = []; if (sources.contains('usgs')) { futures.add(fetchUsgsEarthquakes( limit: limit, minMagnitude: minMagnitude, days: days, )); } if (sources.contains('afad')) { futures.add(fetchAfadEarthquakes( limit: limit, minMagnitude: minMagnitude, days: days, )); } if (sources.contains('kandilli')) { futures.add(fetchKandilliEarthquakes( minMagnitude: minMagnitude, )); } if (sources.contains('emsc')) { futures.add(fetchEmscEarthquakes( limit: limit, minMagnitude: minMagnitude, days: days, )); } final results = await Future.wait(futures); for (final earthquakes in results) { allEarthquakes.addAll(earthquakes); } // Sort by time (newest first) allEarthquakes.sort((a, b) => b.time.compareTo(a.time)); // Limit the number of earthquakes if (allEarthquakes.length > limit) { return allEarthquakes.sublist(0, limit); } return allEarthquakes; } // Helper method to parse Kandilli date and time DateTime _parseKandilliDateTime(String date, String time) { try { final parts = date.split('.'); final day = int.parse(parts[0]); final month = int.parse(parts[1]); final year = int.parse(parts[2]); final timeParts = time.split(':'); final hour = int.parse(timeParts[0]); final minute = int.parse(timeParts[1]); final second = int.parse(timeParts[2]); return DateTime(year, month, day, hour, minute, second); } catch (e) { Logger.error('Error parsing Kandilli date time: $e'); return DateTime.now(); } } // Helper method to extract region from location String? _extractRegionFromLocation(String location) { try { final parts = location.split('-'); if (parts.length > 1) { return parts.last.trim(); } return null; } catch (e) { return null; } } } EOL # repositories/earthquake_repository.dart cat > lib/repositories/earthquake_repository.dart << 'EOL' import 'package:hive/hive.dart'; import 'package:globalquake/config/constants.dart'; import 'package:globalquake/data_sources/earthquake_data_source.dart'; import 'package:globalquake/models/earthquake.dart'; import 'package:globalquake/models/settings.dart'; import 'package:globalquake/utils/logger.dart'; class EarthquakeRepository { final EarthquakeDataSource _dataSource; EarthquakeRepository(this._dataSource); // Get earthquakes from all sources Future> getEarthquakes({ List? sources, double? minMagnitude, int? limit, int? days, bool forceRefresh = false, }) async { // Get settings final settingsBox = Hive.box(AppConstants.settingsBoxName); final settings = settingsBox.get('settings') ?? Settings.getDefault(); // Use provided parameters or defaults from settings final activeSources = sources ?? settings.enabledSources; final magnitude = minMagnitude ?? settings.minimumMagnitude; final resultLimit = limit ?? 100; final daysPeriod = days ?? 30; // Check if we should use cached data if (!forceRefresh && settings.offlineModeEnabled) { final cachedEarthquakes = _getCachedEarthquakes( minMagnitude: magnitude, limit: resultLimit, ); if (cachedEarthquakes.isNotEmpty) { Logger.info('Using ${cachedEarthquakes.length} cached earthquakes'); return cachedEarthquakes; } } // Fetch from network try { final earthquakes = await _dataSource.fetchAllEarthquakes( sources: activeSources, minMagnitude: magnitude, limit: resultLimit, days: daysPeriod, ); // Cache the results if (settings.offlineModeEnabled) { _cacheEarthquakes(earthquakes); } return earthquakes; } catch (e) { Logger.error('Error in getEarthquakes: $e'); // If network fetch fails, try to use cached data if (settings.offlineModeEnabled) { final cachedEarthquakes = _getCachedEarthquakes( minMagnitude: magnitude, limit: resultLimit, ); if (cachedEarthquakes.isNotEmpty) { Logger.info('Using ${cachedEarthquakes.length} cached earthquakes after network error'); return cachedEarthquakes; } } // If all else fails, return empty list return []; } } // Get earthquakes by region Future> getEarthquakesByRegion( String region, { double? minMagnitude, int? limit, int? days, bool forceRefresh = false, }) async { final earthquakes = await getEarthquakes( minMagnitude: minMagnitude, limit: limit ?? 500, // Use larger limit for filtering days: days, forceRefresh: forceRefresh, ); // Filter by region final filteredEarthquakes = earthquakes.where((earthquake) { final location = earthquake.location.toLowerCase(); final country = earthquake.country?.toLowerCase() ?? ''; final earthquakeRegion = earthquake.region?.toLowerCase() ?? ''; return location.contains(region.toLowerCase()) || country.contains(region.toLowerCase()) || earthquakeRegion.contains(region.toLowerCase()); }).toList(); // Apply limit if provided if (limit != null && filteredEarthquakes.length > limit) { return filteredEarthquakes.sublist(0, limit); } return filteredEarthquakes; } // Get earthquakes near a location Future> getEarthquakesNearLocation( double latitude, double longitude, { double radius = 300.0, // km double? minMagnitude, int? limit, int? days, bool forceRefresh = false, }) async { final earthquakes = await getEarthquakes( minMagnitude: minMagnitude, limit: limit ?? 500, // Use larger limit for filtering days: days, forceRefresh: forceRefresh, ); // Filter by distance final filteredEarthquakes = earthquakes.where((earthquake) { final distance = earthquake.distanceFrom(latitude, longitude); return distance <= radius; }).toList(); // Sort by distance filteredEarthquakes.sort((a, b) { final distanceA = a.distanceFrom(latitude, longitude); final distanceB = b.distanceFrom(latitude, longitude); return distanceA.compareTo(distanceB); }); // Apply limit if provided if (limit != null && filteredEarthquakes.length > limit) { return filteredEarthquakes.sublist(0, limit); } return filteredEarthquakes; } // Get earthquake statistics Future> getEarthquakeStatistics({ int days = 30, bool forceRefresh = false, }) async { final earthquakes = await getEarthquakes( days: days, limit: 1000, // Use larger limit for statistics forceRefresh: forceRefresh, ); if (earthquakes.isEmpty) { return { 'totalCount': 0, 'magnitudeDistribution': {}, 'depthDistribution': {}, 'timeDistribution': {}, 'sourceDistribution': {}, 'regionDistribution': {}, }; } // Calculate statistics final Map magnitudeDistribution = {}; final Map depthDistribution = {}; final Map timeDistribution = {}; final Map sourceDistribution = {}; final Map regionDistribution = {}; for (final earthquake in earthquakes) { // Magnitude distribution final magnitudeCategory = earthquake.getMagnitudeCategory(); magnitudeDistribution[magnitudeCategory] = (magnitudeDistribution[magnitudeCategory] ?? 0) + 1; // Depth distribution final depthCategory = _getDepthCategory(earthquake.depth); depthDistribution[depthCategory] = (depthDistribution[depthCategory] ?? 0) + 1; // Time distribution (by day) final day = '${earthquake.time.day}/${earthquake.time.month}/${earthquake.time.year}'; timeDistribution[day] = (timeDistribution[day] ?? 0) + 1; // Source distribution final source = AppConstants.earthquakeSources[earthquake.source] ?? earthquake.source; sourceDistribution[source] = (sourceDistribution[source] ?? 0) + 1; // Region distribution final region = earthquake.region ?? _extractRegionFromLocation(earthquake.location); if (region != null && region.isNotEmpty) { regionDistribution[region] = (regionDistribution[region] ?? 0) + 1; } } return { 'totalCount': earthquakes.length, 'magnitude ?? 0) + 1; } } return { 'totalCount': earthquakes.length, 'magnitudeDistribution': magnitudeDistribution, 'depthDistribution': depthDistribution, 'timeDistribution': timeDistribution, 'sourceDistribution': sourceDistribution, 'regionDistribution': regionDistribution, }; } // Helper method to get depth category String _getDepthCategory(double depth) { if (depth < 10) { return 'Sığ (0-10 km)'; } else if (depth < 30) { return 'Orta (10-30 km)'; } else if (depth < 70) { return 'Derin (30-70 km)'; } else { return 'Çok Derin (70+ km)'; } } // Helper method to extract region from location String? _extractRegionFromLocation(String location) { try { final parts = location.split('-'); if (parts.length > 1) { return parts.last.trim(); } return null; } catch (e) { return null; } } // Cache earthquakes in Hive void _cacheEarthquakes(List earthquakes) { try { final earthquakesBox = Hive.box(AppConstants.earthquakesBoxName); // Clear old cache if too many entries if (earthquakesBox.length > AppConstants.maxStoredEarthquakes) { earthquakesBox.clear(); } // Add new earthquakes for (final earthquake in earthquakes) { earthquakesBox.put(earthquake.id, earthquake); } Logger.info('Cached ${earthquakes.length} earthquakes'); } catch (e) { Logger.error('Error caching earthquakes: $e'); } } // Get cached earthquakes from Hive List _getCachedEarthquakes({ double? minMagnitude, int? limit, }) { try { final earthquakesBox = Hive.box(AppConstants.earthquakesBoxName); final settingsBox = Hive.box(AppConstants.settingsBoxName); final settings = settingsBox.get('settings') ?? Settings.getDefault(); // Get all earthquakes final earthquakes = earthquakesBox.values.toList(); // Check cache expiry final now = DateTime.now(); final expiryHours = settings.offlineCacheExpiryHours; earthquakes.removeWhere((earthquake) { final age = now.difference(earthquake.time).inHours; return age > expiryHours; }); // Filter by magnitude if (minMagnitude != null) { earthquakes.removeWhere((earthquake) => earthquake.magnitude < minMagnitude); } // Sort by time (newest first) earthquakes.sort((a, b) => b.time.compareTo(a.time)); // Apply limit if (limit != null && earthquakes.length > limit) { return earthquakes.sublist(0, limit); } return earthquakes; } catch (e) { Logger.error('Error getting cached earthquakes: $e'); return []; } } } EOL # blocs/earthquake/earthquake_bloc.dart cat > lib/blocs/earthquake/earthquake_bloc.dart << 'EOL' import 'dart:async'; import 'package:flutter_bloc/flutter_bloc.dart'; import 'package:equatable/equatable.dart'; import 'package:globalquake/models/earthquake.dart'; import 'package:globalquake/repositories/earthquake_repository.dart'; // Events abstract class EarthquakeEvent extends Equatable { const EarthquakeEvent(); @override List