add more optimalization

.gitignore

@@ -13,3 +13,4 @@
 .externalNativeBuild
 .cxx
 local.properties
+test-data

.idea/deploymentTargetSelector.xml

@@ -4,10 +4,10 @@
     <selectionStates>
       <SelectionState runConfigName="app">
         <option name="selectionMode" value="DROPDOWN" />
-        <DropdownSelection timestamp="2026-01-19T17:27:16.298528612Z">
+        <DropdownSelection timestamp="2026-01-28T21:00:38.307279245Z">
           <Target type="DEFAULT_BOOT">
             <handle>
-              <DeviceId pluginId="LocalEmulator" identifier="path=/home/lukas/.config/.android/avd/Medium_Phone_OSS.avd" />
+              <DeviceId pluginId="PhysicalDevice" identifier="serial=BS98317AA1341400032" />
             </handle>
           </Target>
         </DropdownSelection>

app/src/main/java/org/pupes/mhdrunpathfinder/GTFSUtils.kt

@@ -14,33 +14,36 @@ import kotlinx.serialization.Serializable
 import okhttp3.OkHttpClient
 import okhttp3.Request
 import ovh.plrapps.mapcompose.api.addMarker
+import ovh.plrapps.mapcompose.api.removeMarker
+import ovh.plrapps.mapcompose.ui.state.markers.model.RenderingStrategy
 import java.net.URL
 
 @Serializable
 data class GTFSRoute(
-    val agency_id: String,
+    val agency_id: String?,
     val is_night: Boolean,
-    val route_color: String,
+    val route_color: String?,
     val route_desc: String? = null,
-    val route_id: String,
+    val route_id: String?,
-    val route_long_name: String,
+    val route_long_name: String?,
-    val route_short_name: String,
+    val route_short_name: String?,
-    val route_text_color: String,
+    val route_text_color: String?,
     val route_type: Int,
-    val route_url: String,
+    val route_url: String?,
     val is_regional: Boolean,
     val is_substitute_transport: Boolean
 )
 
 // Type alias for array of GTFS routes
-typealias GTFSRoutes = List<GTFSRoute>
+typealias GTFSRoutes = MutableList<GTFSRoute>
+
+var gtfsRoutes: GTFSRoutes = mutableListOf()
 
-var gtfsRoutes: GTFSRoutes? = null
 
 @Serializable
 data class GTFSStopGeometry(
     val coordinates: List<Double>,
-    val type: String
+    val type: String?
 )
 
 @Serializable
@@ -49,7 +52,7 @@ data class GTFSStopProperties(
     val parent_station: String? = null,
     val platform_code: String? = null,
     val stop_id: String,
-    val stop_name: String,
+    val stop_name: String?,
     val wheelchair_boarding: Int,
     val zone_id: String? = null,
     val level_id: String? = null
@@ -59,16 +62,16 @@ data class GTFSStopProperties(
 data class GTFSStop(
     val geometry: GTFSStopGeometry,
     val properties: GTFSStopProperties,
-    val type: String
+    val type: String?
 )
 
 @Serializable
 data class GTFSStops(
-    val features: List<GTFSStop>,
+    val features: MutableList<GTFSStop>,
-    val type: String
+    val type: String?
 )
 
-var gtfsStops: GTFSStops? = null
+var gtfsStops: GTFSStops = GTFSStops(mutableListOf<GTFSStop>(), "FeatureCollection")
 
 
 // OkHttpClient for making HTTP requests
@@ -104,17 +107,24 @@ private fun fetchGTFSPosition(gtfsUrl: URL,api_key: String, callee: Activity) {
     }
 }
 
+
 // Start the timer with a URL:
 fun startGTFSTracking(url: String, api_key: String, callee: Activity) {
     if (GTFSIsTracking) return
 
     GTFSIsTracking = true
     GTFSTrackingThread = Thread {
-        var gtfsUrl = URL(url);
+        val gtfsUrl = URL(url);
         try {
-                if(gtfsRoutes == null) {
+                if(gtfsRoutes.isEmpty()) {
+                    GTFSMainHandler.post {
+                    Toast.makeText(callee, "Fetching routes...", Toast.LENGTH_SHORT).show()}
+
+                    var messageParsed: GTFSRoutes;
+                    var offset = 0;
+                    do {
                 val request = Request.Builder()
-                    .url("${gtfsUrl.protocol}://${gtfsUrl.host}${callee.getString(R.string.routes_path)}")
+                    .url("${gtfsUrl.protocol}://${gtfsUrl.host}${callee.getString(R.string.routes_path)}?offset=${offset}")
                     .header(
                         "User-Agent",
                         "${BuildConfig.APPLICATION_ID}/${BuildConfig.VERSION_NAME} (Android)"
@@ -127,11 +137,20 @@ fun startGTFSTracking(url: String, api_key: String, callee: Activity) {
                     } else {
                         "Error: ${response.code} ${response.message}"
                     }
-                    gtfsRoutes = json.decodeFromString<GTFSRoutes>(message)
+                    messageParsed = json.decodeFromString<GTFSRoutes>(message)
-                }}
+                    gtfsRoutes.addAll(messageParsed)
-                if(gtfsStops == null) {
+                    offset += messageParsed.size
+                }} while (messageParsed.isNotEmpty())
+                }
+                if(gtfsStops.features.isEmpty()) {
+                    GTFSMainHandler.post {
+                    Toast.makeText(callee, "Fetching stops...", Toast.LENGTH_SHORT).show()}
+
+                    var messageParsed: GTFSStops;
+                    var offset = 0;
+                    do {
                     val request = Request.Builder()
-                        .url("${gtfsUrl.protocol}://${gtfsUrl.host}${callee.getString(R.string.stops_path)}")
+                        .url("${gtfsUrl.protocol}://${gtfsUrl.host}${callee.getString(R.string.stops_path)}?offset=${offset}")
                         .header(
                             "User-Agent",
                             "${BuildConfig.APPLICATION_ID}/${BuildConfig.VERSION_NAME} (Android)"
@@ -144,25 +163,35 @@ fun startGTFSTracking(url: String, api_key: String, callee: Activity) {
                         } else {
                             "Error: ${response.code} ${response.message}"
                         }
-                        gtfsStops = json.decodeFromString<GTFSStops>(message)
+                        messageParsed = json.decodeFromString<GTFSStops>(message)
+                        gtfsStops.features.addAll(messageParsed.features)
+                    }
 
-                        // put all stops on the map
+                    offset += messageParsed.features.size;
-                        for (stop in gtfsStops!!.features) {
+                    }while(messageParsed.features.isNotEmpty())
-                            GTFSMainHandler.post {
+                }
-                                mapState.addMarker(stop.properties.stop_id, x = longitudeToXNormalized(stop.geometry.coordinates[0]), y = latitudeToYNormalized(stop.geometry.coordinates[0])) {
+            // put all stops on the map
-                                    Icon(
+            GTFSMainHandler.post {
-                                        painter = painterResource(id = R.drawable.outline_directions_bus_24),
+                Toast.makeText(callee, "Drawing stops...", Toast.LENGTH_SHORT).show()}
-                                        contentDescription = null,
+            for (stop in gtfsStops!!.features) {
-                                        modifier = Modifier.size(17.dp),
-                                        tint = Color(0xFF0000FF)
-                                    )
-                                }
 
-                            }
+                if (stop.properties.parent_station == null) {
-                        }
+                    mapState.addMarker(stop.properties.stop_id, x = longitudeToXNormalized(stop.geometry.coordinates[0]), y = latitudeToYNormalized(stop.geometry.coordinates[1]), renderingStrategy = RenderingStrategy.LazyLoading("default")) {
+                        Icon(
+                            painter = painterResource(id = R.drawable.outline_directions_bus_24),
+                            contentDescription = null,
+                            modifier = Modifier.size(12.dp),
+                            tint = Color(0xFF0000FF)
+                        )
                     }}
+            }
+            GTFSMainHandler.post {
+                Toast.makeText(callee, "Done drawing stops", Toast.LENGTH_SHORT).show()}
+
             } catch(e: Exception) {
+            GTFSMainHandler.post {
                 Toast.makeText(callee, e.message ?: "Unknown error", Toast.LENGTH_SHORT).show()
+            }
                 GTFSMainHandler.post { stopGTFSTracking() }
                 return@Thread
         }
@@ -179,6 +208,11 @@ fun startGTFSTracking(url: String, api_key: String, callee: Activity) {
 
 fun stopGTFSTracking() {
     GTFSIsTracking = false
+    for (stop in gtfsStops!!.features) {
+        if (stop.properties.parent_station == null) {
+            mapState.removeMarker(stop.properties.stop_id);
+        }
+    }
     GTFSTrackingThread?.interrupt()
     GTFSTrackingThread = null
 }

app/src/main/java/org/pupes/mhdrunpathfinder/MainActivity.kt

@@ -40,14 +40,25 @@ import androidx.compose.ui.tooling.preview.Preview
 import androidx.compose.ui.unit.dp
 import androidx.core.content.edit
 import ovh.plrapps.mapcompose.api.addLayer
+import ovh.plrapps.mapcompose.api.addLazyLoader
 import ovh.plrapps.mapcompose.api.addMarker
 import ovh.plrapps.mapcompose.api.scrollTo
 import ovh.plrapps.mapcompose.core.TileStreamProvider
 import ovh.plrapps.mapcompose.ui.MapUI
 import ovh.plrapps.mapcompose.ui.state.MapState
+import java.io.File
+import java.io.FileInputStream
+import java.io.FileOutputStream
 import java.net.URL
+import kotlinx.coroutines.*
+import java.util.concurrent.Executors
+import android.os.StrictMode
 
 
+// Thread pool for tile downloading to prevent blocking UI thread
+private val tileDownloadExecutor = Executors.newFixedThreadPool(
+    (Runtime.getRuntime().availableProcessors() - 3).coerceAtLeast(1)
+)
 // MapState configuration for OpenStreetMap
 // Max zoom level is 18, tile size is 256x256
 // At zoom level 18, there are 2^18 = 262144 tiles in each dimension
@@ -59,13 +70,108 @@ val mapState = MapState(
     tileSize = 256
 )
 
+/**
+ * Creates a cached tile stream provider for OpenStreetMap tiles
+ * Tiles are cached in the app's cache directory for offline access and faster loading
+ * Cache expires after 30 days to ensure map updates are fetched
+ * Uses background thread pool to prevent ANR (Application Not Responding)
+ */
+fun createCachedTileStreamProvider(context: Context, cacheExpiryDays: Int = 30): TileStreamProvider {
+    val cacheDir = File(context.cacheDir, "map_tiles")
+    if (!cacheDir.exists()) {
+        cacheDir.mkdirs()
+    }
 
+    val cacheExpiryMillis = cacheExpiryDays * 24 * 60 * 60 * 1000L
+
+    return TileStreamProvider { row, col, zoomLvl ->
+        try {
+            // Create a unique filename for this tile
+            val tileFile = File(cacheDir, "tile_${zoomLvl}_${col}_${row}.png")
+
+            // Check if tile exists in cache and is not expired
+            val shouldUseCache = tileFile.exists() &&
+                (System.currentTimeMillis() - tileFile.lastModified()) < cacheExpiryMillis
+
+            if (shouldUseCache) {
+                // Use cached tile
+                FileInputStream(tileFile)
+            } else {
+                // Download tile from OpenStreetMap in background thread
+                val future = tileDownloadExecutor.submit<FileInputStream?> {
+                    try {
+                        val url = URL("https://tile.openstreetmap.org/$zoomLvl/$col/$row.png")
+                        val connection = url.openConnection()
+                        // Set User-Agent header as required by OSM tile usage policy
+                        val userAgent = "${BuildConfig.APPLICATION_ID}/${BuildConfig.VERSION_NAME} (Android) (Contact: poliecho@pupes.org)"
+                        connection.setRequestProperty("User-Agent", userAgent)
+                        connection.connectTimeout = 5000 // 5 second timeout
+                        connection.readTimeout = 10000 // 10 second timeout
+
+                        val inputStream = connection.getInputStream()
+
+                        // Save to cache (overwrites if expired)
+                        val outputStream = FileOutputStream(tileFile)
+                        inputStream.use { input ->
+                            outputStream.use { output ->
+                                input.copyTo(output)
+                            }
+                        }
+
+                        // Return the cached file's input stream
+                        FileInputStream(tileFile)
+                    } catch (e: Exception) {
+                        e.printStackTrace()
+                        null
+                    }
+                }
+
+                // Wait for download with timeout
+                try {
+                    future.get() ?: run {
+                        // If download failed but we have a cached tile (even if expired), use it
+                        if (tileFile.exists()) {
+                            FileInputStream(tileFile)
+                        } else {
+                            null
+                        }
+                    }
+                } catch (e: Exception) {
+                    // If download timed out or failed, try using expired cache
+                    if (tileFile.exists()) {
+                        FileInputStream(tileFile)
+                    } else {
+                        null
+                    }
+                }
+            }
+        } catch (e: Exception) {
+            e.printStackTrace()
+            null
+        }
+    }
+}
 
 
 class MainActivity : ComponentActivity() {
     override fun onCreate(savedInstanceState: Bundle?) {
         super.onCreate(savedInstanceState)
 
+        // Configure StrictMode to detect threading violations (debug mode only)
+        if (BuildConfig.DEBUG) {
+            StrictMode.setThreadPolicy(
+                StrictMode.ThreadPolicy.Builder()
+                    .detectAll()
+                    .penaltyLog()  // Log violations instead of crashing
+                    .build()
+            )
+            StrictMode.setVmPolicy(
+                StrictMode.VmPolicy.Builder()
+                    .detectAll()
+                    .penaltyLog()
+                    .build()
+            )
+        }
 
         setContent {
             MaterialTheme {
@@ -95,15 +201,16 @@ fun MainScreen(callee: Activity) {
     var haukUrl by remember { mutableStateOf("") }
     var golemioAPIkey by remember { mutableStateOf(sharedPreferences.getString("golemioAPIkey", "")?: "" ) }
     var haukState by remember { mutableStateOf(false) }
-    var golemioState by remember { mutableStateOf(false)}
+    var golemioState by remember { mutableStateOf(golemioAPIkey.isNotEmpty())}
 
-    if (golemioAPIkey.isNotEmpty()) {
+    LaunchedEffect(Unit) {
-        golemioState = true
+        if (golemioState) {
-        startGTFSTracking(callee.getString(R.string.golemio_base_url), golemioAPIkey, callee);
+            startGTFSTracking(callee.getString(R.string.golemio_base_url), golemioAPIkey, callee)
+        }
     }
 
     Box(modifier = Modifier.fillMaxSize()) {
-        OpenStreetMapScreen()
+        OpenStreetMapScreen(callee)
         SettingsButton(
             onClick = { showSettings = true },
             modifier = Modifier
@@ -211,6 +318,7 @@ fun ShowSettingsMenu(
                     value = haukUrl,
                     onValueChange = onHaukUrlChange,
                     label = { Text("Target Hauk URL") },
+                    singleLine = true,
                     modifier = Modifier
                         .width(250.dp)
                 )
@@ -224,6 +332,7 @@ fun ShowSettingsMenu(
                     onCheckedChange = { onGolemioStateChange(it) }
                 )
                 TextField(value = golemioAPIkey, onValueChange = onGolemioAPIChange, label = { Text("Golemio API Key") },
+                    singleLine = true,
                     modifier = Modifier
                         .width(250.dp));
                 ElevatedButton(onClick = onGolemioApply, modifier = Modifier.padding(start = 5.dp), shape = RectangleShape) {
@@ -235,24 +344,27 @@ fun ShowSettingsMenu(
 
 @Preview
 @Composable
-fun OpenStreetMapScreen() {
+fun OpenStreetMapScreen(context: Context? = null) {
-    // Create tile stream provider for OpenStreetMap with User-Agent
+    // Create tile stream provider for OpenStreetMap with caching
-    val tileStreamProvider = TileStreamProvider { row, col, zoomLvl ->
+    val tileStreamProvider = remember(context) {
-        try {
+        context?.let {
-            val url = URL("https://tile.openstreetmap.org/$zoomLvl/$col/$row.png")
+            createCachedTileStreamProvider(it)
-            val connection = url.openConnection()
+        } ?: TileStreamProvider { row, col, zoomLvl ->
-            // Set User-Agent header as required by OSM tile usage policy
+            // Fallback for preview mode without context
-            // Format: AppId/Version (Platform) (Contact: email)
+            try {
-            val userAgent = "${BuildConfig.APPLICATION_ID}/${BuildConfig.VERSION_NAME} (Android) (Contact: poliecho@pupes.org)"
+                val url = URL("https://tile.openstreetmap.org/$zoomLvl/$col/$row.png")
-            connection.setRequestProperty("User-Agent", userAgent)
+                val connection = url.openConnection()
-            connection.getInputStream()
+                val userAgent = "MHDrunPathfinder/Preview (Android)"
-        } catch (e: Exception) {
+                connection.setRequestProperty("User-Agent", userAgent)
-            e.printStackTrace()
+                connection.getInputStream()
-            null
+            } catch (e: Exception) {
+                e.printStackTrace()
+                null
+            }
         }
     }
 
-
+    mapState.addLazyLoader("default");
 
     /* Add a marker at the center of the map */
     mapState.addMarker("target_position", x = longitudeToXNormalized(14.4058031), y = latitudeToYNormalized(50.0756083)) {

app/src/main/res/values/strings.xml

@@ -3,4 +3,5 @@
     <string name="routes_path">/v2/gtfs/routes</string>
     <string name="stops_path">/v2/gtfs/stops</string>
     <string name="golemio_base_url">https://api.golemio.cz</string>
+    <string name="golemio_realtime_path"></string>
 </resources>