Obsłuż publikację dni i ukrywanie kursów kierowcy

app/build.gradle.kts

@@ -34,8 +34,8 @@ android {
         applicationId = "pl.firmatpp.kierowca"
         minSdk = 26
         targetSdk = 36
-        versionCode = 131
+        versionCode = 133
-        versionName = "1.0.78"
+        versionName = "1.0.80"
         setProperty("archivesBaseName", "pl.firmatpp.kierowca")
         testInstrumentationRunner = "androidx.test.runner.AndroidJUnitRunner"
 

app/src/main/java/pl/firmatpp/kierowca/data/PhotoUploadMetadata.kt

@@ -1,5 +1,6 @@
 package pl.firmatpp.kierowca.data
 
+import java.io.Serializable
 import okhttp3.MediaType.Companion.toMediaTypeOrNull
 import okhttp3.RequestBody
 import okhttp3.RequestBody.Companion.toRequestBody
@@ -9,7 +10,7 @@ data class PhotoUploadMetadata(
     val latitude: Double? = null,
     val longitude: Double? = null,
     val locationAccuracyMeters: Double? = null,
-)
+) : Serializable
 
 fun PhotoUploadMetadata.toMultipartTextParts(): Map<String, RequestBody> = buildMap {
     takenAt?.let { put("takenAt", it.toPlainTextBody()) }

app/src/main/java/pl/firmatpp/kierowca/data/model/DriverModels.kt

@@ -42,7 +42,10 @@ data class DriverDto(
     val anonymousLabel: String?,
 )
 
+data class DayPublicationDto(val date: String, val isVisible: Boolean, val version: Long)
+
 data class BootstrapResponse(
+    val dayPublication: DayPublicationDto? = null,
     val session: DriverSessionDto,
     val routes: RoutesBucketDto,
     val driverAppSettings: DriverAppSettingsDto?,

app/src/main/java/pl/firmatpp/kierowca/data/sync/DriverCacheDao.kt

@@ -37,6 +37,9 @@ interface DriverCacheDao {
     @Query("DELETE FROM driver_bootstrap_cache")
     suspend fun clearBootstrap()
 
+    @Query("DELETE FROM driver_route_cache WHERE routeId = :routeId")
+    suspend fun deleteRoute(routeId: String)
+
     @Query("DELETE FROM driver_route_cache")
     suspend fun clearRoutes()
 

app/src/main/java/pl/firmatpp/kierowca/data/sync/DriverSyncRepository.kt

@@ -27,6 +27,13 @@ class DriverSyncRepository(
             val response = repository.bootstrap(date)
             val selectedDate = response.driverAppSettings?.selectedDate ?: requestedDate
             val routeState = response.syncState?.scopes?.firstOrNull { it.scope == SCOPE_ROUTES }
+            if (response.dayPublication?.isVisible == false) {
+                // Previously downloaded details must not survive withdrawing a day.
+                dao.allRouteCaches().forEach { cached ->
+                    val route = gson.fromJson(cached.payloadJson, RouteResponse::class.java).route
+                    if (selectedDate in routeVisibleDates(route)) dao.deleteRoute(route.id)
+                }
+            }
             dao.upsertBootstrap(
                 DriverBootstrapCacheEntity(
                     date = selectedDate,
@@ -61,6 +68,7 @@ class DriverSyncRepository(
             CachedValue(response, stale = false, syncedAtEpochMillis = System.currentTimeMillis())
         }.getOrElse { throwable ->
             throwable.rethrowIfCancellation()
+            if (throwable is HttpException && throwable.code() == 404) dao.deleteRoute(routeId)
             cachedRoute(routeId, throwable)
         }
 

app/src/main/java/pl/firmatpp/kierowca/sync/DriverFirebaseMessagingService.kt

@@ -23,6 +23,16 @@ class DriverFirebaseMessagingService : FirebaseMessagingService() {
 
     override fun onMessageReceived(message: RemoteMessage) {
         val data = message.data
+        if (data["type"] == "driver_routes_published") {
+            NewRouteNotificationWorker.enqueuePublication(
+                context = applicationContext,
+                date = data["date"],
+                version = data["publicationVersion"]?.toLongOrNull(),
+                driverId = data["driverId"],
+            )
+            DriverSyncWorker.enqueue(applicationContext, data["date"], null)
+            return
+        }
         if (data["type"] == "driver_new_route_notification") {
             NewRouteNotificationWorker.enqueue(
                 context = applicationContext,

app/src/main/java/pl/firmatpp/kierowca/sync/NewRouteNotificationWorker.kt

@@ -27,6 +27,7 @@ import pl.firmatpp.kierowca.data.ApiErrorKind
 import pl.firmatpp.kierowca.data.ApiErrorMapper
 import pl.firmatpp.kierowca.data.DriverRepository
 import pl.firmatpp.kierowca.data.rethrowIfCancellation
+import pl.firmatpp.kierowca.data.sync.DriverSyncRepository
 import pl.firmatpp.kierowca.data.sync.NetworkMonitor
 import pl.firmatpp.kierowca.diagnostics.AppDiagnostics
 import retrofit2.HttpException
@@ -39,25 +40,41 @@ class NewRouteNotificationWorker(
 
     override suspend fun doWork(): Result {
         if (!NetworkMonitor(applicationContext).isCurrentlyValidated()) return Result.retry()
-        val routeId = inputData.getString(KEY_ROUTE_ID)?.takeIf(String::isNotBlank) ?: return Result.success()
+        val routeId = inputData.getString(KEY_ROUTE_ID)?.takeIf(String::isNotBlank)
+        val publicationDate = inputData.getString(KEY_DATE)
+        val publicationVersion = inputData.getLong(KEY_PUBLICATION_VERSION, -1L)
+        val isPublication = publicationVersion >= 0L
+        if (!isPublication && routeId == null) return Result.success()
 
         return runCatching {
-            val route = repository.route(routeId).route
+            val route = if (isPublication) {
+                if (publicationDate.isNullOrBlank()) return@runCatching Result.success()
+                val bootstrap = DriverSyncRepository(applicationContext).bootstrap(publicationDate)
+                if (bootstrap.stale) return@runCatching Result.retry()
+                val publication = bootstrap.value.dayPublication
+                if (publication?.isVisible != true || publication.version != publicationVersion ||
+                    bootstrap.value.notificationPreferences?.notifyNewRoutes != true ||
+                    bootstrap.value.session.driver.id != inputData.getString(KEY_DRIVER_ID)) {
+                    return@runCatching Result.success()
+                }
+                bootstrap.value.routes.today.firstOrNull() ?: return@runCatching Result.success()
+            } else repository.route(requireNotNull(routeId)).route
             if (!canShowNotifications(applicationContext)) {
                 return@runCatching Result.success()
             }
 
             createChannel(applicationContext)
-            val contentTitle = NewRouteNotificationFormatter.title(route.routeDate ?: inputData.getString(KEY_DATE))
+            val contentTitle = if (isPublication) "Opublikowano kursy" else NewRouteNotificationFormatter.title(route.routeDate ?: publicationDate)
-            val contentText = NewRouteNotificationFormatter.collapsedText(route)
+            val contentText = if (isPublication) PublishedRoutesNotificationFormatter.text(publicationDate) else NewRouteNotificationFormatter.collapsedText(route)
-            val expandedText = NewRouteNotificationFormatter.expandedText(route)
+            val expandedText = if (isPublication) contentText else NewRouteNotificationFormatter.expandedText(route)
+            val notificationId = if (isPublication) "published-$publicationDate".hashCode() else route.id.hashCode()
             val intent = Intent(applicationContext, MainActivity::class.java).apply {
                 flags = Intent.FLAG_ACTIVITY_CLEAR_TOP or Intent.FLAG_ACTIVITY_SINGLE_TOP
                 putExtra(MainActivity.EXTRA_ROUTE_ID, route.id)
             }
             val pendingIntent = PendingIntent.getActivity(
                 applicationContext,
-                route.id.hashCode(),
+                notificationId,
                 intent,
                 PendingIntent.FLAG_UPDATE_CURRENT or PendingIntent.FLAG_IMMUTABLE,
             )
@@ -69,12 +86,13 @@ class NewRouteNotificationWorker(
                 .setStyle(NotificationCompat.BigTextStyle().bigText(expandedText))
                 .setContentIntent(pendingIntent)
                 .setAutoCancel(true)
+                .setOnlyAlertOnce(true)
                 .setCategory(NotificationCompat.CATEGORY_REMINDER)
                 .setPriority(NotificationCompat.PRIORITY_DEFAULT)
                 .build()
 
             try {
-                NotificationManagerCompat.from(applicationContext).notify(route.id.hashCode(), notification)
+                NotificationManagerCompat.from(applicationContext).notify(notificationId, notification)
             } catch (_: SecurityException) {
                 return@runCatching Result.success()
             }
@@ -125,6 +143,22 @@ class NewRouteNotificationWorker(
         private const val CHANNEL_ID = "new_routes"
         private const val KEY_ROUTE_ID = "routeId"
         private const val KEY_DATE = "date"
+        private const val KEY_PUBLICATION_VERSION = "publicationVersion"
+        private const val KEY_DRIVER_ID = "driverId"
+
+        fun enqueuePublication(context: Context, date: String?, version: Long?, driverId: String?) {
+            if (date.isNullOrBlank() || version == null || version < 1L || driverId.isNullOrBlank()) return
+            val request = OneTimeWorkRequestBuilder<NewRouteNotificationWorker>()
+                .setInputData(workDataOf(KEY_DATE to date, KEY_PUBLICATION_VERSION to version, KEY_DRIVER_ID to driverId))
+                .setConstraints(Constraints.Builder().setRequiredNetworkType(NetworkType.CONNECTED).build())
+                .setBackoffCriteria(BackoffPolicy.EXPONENTIAL, 30, TimeUnit.SECONDS)
+                .build()
+            WorkManager.getInstance(context).enqueueUniqueWork(
+                "driver-day-publication-$date",
+                ExistingWorkPolicy.REPLACE,
+                request,
+            )
+        }
 
         fun enqueue(context: Context, routeId: String?, date: String?) {
             if (routeId.isNullOrBlank()) return

app/src/main/java/pl/firmatpp/kierowca/sync/PublishedRoutesNotificationFormatter.kt

@@ -0,0 +1,22 @@
+package pl.firmatpp.kierowca.sync
+
+import java.time.DayOfWeek
+import java.time.LocalDate
+import java.time.format.DateTimeFormatter
+
+object PublishedRoutesNotificationFormatter {
+    fun text(value: String?): String {
+        val date = runCatching { LocalDate.parse(value) }.getOrNull()
+            ?: return "Opublikowano twoje kursy. Otwórz aplikację, aby je zobaczyć."
+        val weekday = when (date.dayOfWeek) {
+            DayOfWeek.MONDAY -> "poniedziałek"
+            DayOfWeek.TUESDAY -> "wtorek"
+            DayOfWeek.WEDNESDAY -> "środę"
+            DayOfWeek.THURSDAY -> "czwartek"
+            DayOfWeek.FRIDAY -> "piątek"
+            DayOfWeek.SATURDAY -> "sobotę"
+            DayOfWeek.SUNDAY -> "niedzielę"
+        }
+        return "Opublikowano twoje kursy na $weekday (${date.format(DateTimeFormatter.ofPattern("dd.MM.yyyy"))})."
+    }
+}

app/src/main/java/pl/firmatpp/kierowca/ui/DriverApp.kt

@@ -115,6 +115,7 @@ import androidx.compose.runtime.getValue
 import androidx.compose.runtime.mutableStateOf
 import androidx.compose.runtime.remember
 import androidx.compose.runtime.rememberCoroutineScope
+import androidx.compose.runtime.saveable.rememberSaveable
 import androidx.compose.runtime.snapshotFlow
 import androidx.compose.runtime.setValue
 import androidx.compose.ui.Alignment
@@ -1202,9 +1203,22 @@ private fun RoutesScreen(
     val context = LocalContext.current
     val coroutineScope = rememberCoroutineScope()
     var cameraUri by remember { mutableStateOf<Uri?>(null) }
+    var cameraLocationMetadata by remember { mutableStateOf(PhotoUploadMetadata()) }
+    var cameraMetadataGeneration by remember { mutableStateOf(0L) }
     var showPreciseLocationPermissionDialog by remember { mutableStateOf(false) }
     var showRouteDatePicker by remember { mutableStateOf(false) }
     var showTachographConfirmation by remember { mutableStateOf(false) }
+    val prepareCameraMetadata = {
+        val generation = cameraMetadataGeneration + 1
+        cameraMetadataGeneration = generation
+        cameraLocationMetadata = PhotoUploadMetadata()
+        coroutineScope.launch {
+            val metadata = cameraPhotoMetadata(context).copy(takenAt = null)
+            if (cameraMetadataGeneration == generation) {
+                cameraLocationMetadata = metadata
+            }
+        }
+    }
     val cameraLauncher = rememberLauncherForActivityResult(ActivityResultContracts.TakePicture()) { ok ->
         val capturedUri = cameraUri
         if (
@@ -1215,10 +1229,13 @@ private fun RoutesScreen(
                 hasFineLocation = hasPermission(context, Manifest.permission.ACCESS_FINE_LOCATION),
             )
         ) {
-            coroutineScope.launch {
+            onDispatchSheetUpload(
-                onDispatchSheetUpload(capturedUri, "camera", cameraPhotoMetadata(context))
+                capturedUri,
-            }
+                "camera",
+                cameraLocationMetadata.copy(takenAt = Instant.now().toString()),
+            )
         }
+        cameraMetadataGeneration += 1
         cameraUri = null
     }
     val cameraPermissionLauncher = rememberLauncherForActivityResult(ActivityResultContracts.RequestMultiplePermissions()) { grants ->
@@ -1228,10 +1245,14 @@ private fun RoutesScreen(
             hasPermission(context, Manifest.permission.ACCESS_FINE_LOCATION)
         if (!canLaunchCameraWithLocationPolicy(state.requirePreciseLocationForPhotos, fineLocationGranted)) {
             showPreciseLocationPermissionDialog = true
+            cameraMetadataGeneration += 1
             cameraUri = null
             return@rememberLauncherForActivityResult
         }
-        if (cameraGranted && pendingUri != null) cameraLauncher.launch(pendingUri)
+        if (cameraGranted && pendingUri != null) {
+            prepareCameraMetadata()
+            cameraLauncher.launch(pendingUri)
+        }
     }
 
     LaunchedEffect(state.routeDayLiveUpdateMessage) {
@@ -1339,6 +1360,7 @@ private fun RoutesScreen(
                                         requirePreciseLocation = state.requirePreciseLocationForPhotos,
                                     )
                                     if (missingPermissions.isEmpty()) {
+                                        prepareCameraMetadata()
                                         cameraLauncher.launch(newUri)
                                     } else {
                                         cameraPermissionLauncher.launch(missingPermissions)
@@ -4441,21 +4463,28 @@ private fun RouteStageScreen(
 ) {
     val context = LocalContext.current
     val coroutineScope = rememberCoroutineScope()
-    var cameraUri by remember { mutableStateOf<Uri?>(null) }
+    var cameraUri by rememberSaveable(stage) { mutableStateOf<Uri?>(null) }
-    var pendingCameraMode by remember { mutableStateOf<RouteStageCameraMode?>(null) }
+    var pendingCameraMode by rememberSaveable(stage) { mutableStateOf<RouteStageCameraMode?>(null) }
-    var showMultiplePhotoCamera by remember(stage) { mutableStateOf(false) }
+    var showMultiplePhotoCamera by rememberSaveable(stage) { mutableStateOf(false) }
-    var multiplePhotoLocationMetadata by remember(stage) { mutableStateOf(PhotoUploadMetadata()) }
+    var multiplePhotoLocationMetadata by rememberSaveable(stage) { mutableStateOf(PhotoUploadMetadata()) }
-    var showPreciseLocationPermissionDialog by remember { mutableStateOf(false) }
+    var showPreciseLocationPermissionDialog by rememberSaveable(stage) { mutableStateOf(false) }
     var voiceDictationActive by remember(stage) { mutableStateOf(false) }
-    var cameraAttachmentTarget by remember(stage) { mutableStateOf<RouteWorkflowAttachmentTarget?>(null) }
+    var cameraAttachmentTarget by rememberSaveable(stage) { mutableStateOf<RouteWorkflowAttachmentTarget?>(null) }
-    var pickerAttachmentTarget by remember(stage) { mutableStateOf<RouteWorkflowAttachmentTarget?>(null) }
+    var pickerAttachmentTarget by rememberSaveable(stage) { mutableStateOf<RouteWorkflowAttachmentTarget?>(null) }
+    var singlePhotoLocationMetadata by rememberSaveable(stage) { mutableStateOf(PhotoUploadMetadata()) }
+    var singlePhotoMetadataGeneration by rememberSaveable(stage) { mutableStateOf(0L) }
     val route = state.displaySelectedRoute
     val stagePhotos = route?.photos?.let { routePhotosForStage(it, stage) }.orEmpty()
     val stageUploads = state.photoUploads.filter { normalizedRoutePhotoStage(it.stage) == stage }
+    val stagePreparations = state.preparingPhotoUploads.filter { normalizedRoutePhotoStage(it.stage) == stage }
     val usableStageUploads = routeStageUsableUploads(stageUploads)
     val cargoStagePhotos = stagePhotos.filter { it.workflowDocumentId.isNullOrBlank() }
     val cargoStageUploads = usableStageUploads.filter { it.workflowDocumentId.isNullOrBlank() }
-    val attachmentCount = visiblePhotoAttachmentCount(cargoStagePhotos.size, cargoStageUploads.size)
+    val cargoStagePreparations = stagePreparations.filter { it.workflowDocumentId.isNullOrBlank() }
+    val attachmentCount = visiblePhotoAttachmentCount(
+        cargoStagePhotos.size,
+        cargoStageUploads.size + cargoStagePreparations.size,
+    )
     val photoRequirement = if (stage == "loading") state.loadingPhotoRequirement else state.unloadingPhotoRequirement
     val weightRequirement = if (stage == "loading") state.loadingWeightRequirement else state.unloadingWeightRequirement
     val submitBlocker = if (state.routeWorkflow != null) {
@@ -4494,9 +4523,21 @@ private fun RouteStageScreen(
         submitBlocker
     }
     val weightBlocker = submitBlocker?.takeIf { it.contains("wag", ignoreCase = true) || it.contains("popraw", ignoreCase = true) }
+    val prepareSinglePhotoMetadata = {
+        val generation = singlePhotoMetadataGeneration + 1
+        singlePhotoMetadataGeneration = generation
+        singlePhotoLocationMetadata = PhotoUploadMetadata()
+        coroutineScope.launch {
+            val metadata = cameraPhotoMetadata(context).copy(takenAt = null)
+            if (singlePhotoMetadataGeneration == generation) {
+                singlePhotoLocationMetadata = metadata
+            }
+        }
+    }
 
     val cameraLauncher = rememberLauncherForActivityResult(ActivityResultContracts.TakePicture()) { ok ->
         val capturedUri = cameraUri
+        val attachmentTarget = cameraAttachmentTarget
         if (
             ok &&
             capturedUri != null &&
@@ -4509,12 +4550,13 @@ private fun RouteStageScreen(
                 onUpload(
                     capturedUri,
                     "camera",
-                    cameraPhotoMetadata(context),
+                    singlePhotoLocationMetadata.copy(takenAt = Instant.now().toString()),
-                    cameraAttachmentTarget?.stepId,
+                    attachmentTarget?.stepId,
-                    cameraAttachmentTarget?.documentId,
+                    attachmentTarget?.documentId,
                 )
             }
         }
+        singlePhotoMetadataGeneration += 1
         cameraUri = null
         cameraAttachmentTarget = null
     }
@@ -4533,6 +4575,7 @@ private fun RouteStageScreen(
             hasPermission(context, Manifest.permission.ACCESS_FINE_LOCATION)
         if (!canLaunchCameraWithLocationPolicy(state.requirePreciseLocationForPhotos, fineLocationGranted)) {
             showPreciseLocationPermissionDialog = true
+            singlePhotoMetadataGeneration += 1
             cameraUri = null
             pendingCameraMode = null
             return@rememberLauncherForActivityResult
@@ -4540,7 +4583,10 @@ private fun RouteStageScreen(
         if (cameraGranted) {
             when (requestedMode) {
                 RouteStageCameraMode.Single -> {
-                    if (pendingUri != null) cameraLauncher.launch(pendingUri)
+                    if (pendingUri != null) {
+                        prepareSinglePhotoMetadata()
+                        cameraLauncher.launch(pendingUri)
+                    }
                 }
                 RouteStageCameraMode.Multiple -> {
                     openMultiplePhotoCamera()
@@ -4553,28 +4599,30 @@ private fun RouteStageScreen(
         pendingCameraMode = null
     }
     val pickerLauncher = rememberLauncherForActivityResult(ActivityResultContracts.PickVisualMedia()) { uri ->
+        val attachmentTarget = pickerAttachmentTarget
         if (uri != null) {
             coroutineScope.launch {
                 onUpload(
                     uri,
                     "gallery",
                     PhotoUploadMetadata(),
-                    pickerAttachmentTarget?.stepId,
+                    attachmentTarget?.stepId,
-                    pickerAttachmentTarget?.documentId,
+                    attachmentTarget?.documentId,
                 )
             }
         }
         pickerAttachmentTarget = null
     }
     val filePickerLauncher = rememberLauncherForActivityResult(ActivityResultContracts.OpenDocument()) { uri ->
+        val attachmentTarget = pickerAttachmentTarget
         if (uri != null) {
             coroutineScope.launch {
                 onUpload(
                     uri,
                     "file",
                     PhotoUploadMetadata(),
-                    pickerAttachmentTarget?.stepId,
+                    attachmentTarget?.stepId,
-                    pickerAttachmentTarget?.documentId,
+                    attachmentTarget?.documentId,
                 )
             }
         }
@@ -4629,6 +4677,7 @@ private fun RouteStageScreen(
                             weightText = state.routeStageWeightText,
                             serverPhotos = stagePhotos,
                             localUploads = usableStageUploads,
+                            preparingUploads = stagePreparations,
                             onStepToggle = onStepToggle,
                             onTakeDocumentPhoto = { stepId, documentId ->
                                 cameraAttachmentTarget = RouteWorkflowAttachmentTarget(stepId, documentId)
@@ -4641,6 +4690,7 @@ private fun RouteStageScreen(
                                 )
                                 if (missingPermissions.isEmpty()) {
                                     pendingCameraMode = null
+                                    prepareSinglePhotoMetadata()
                                     cameraLauncher.launch(newUri)
                                 } else {
                                     cameraPermissionLauncher.launch(missingPermissions)
@@ -4726,6 +4776,7 @@ private fun RouteStageScreen(
                                     )
                                     if (missingPermissions.isEmpty()) {
                                         pendingCameraMode = null
+                                        prepareSinglePhotoMetadata()
                                         cameraLauncher.launch(newUri)
                                     } else {
                                         cameraPermissionLauncher.launch(missingPermissions)
@@ -4761,6 +4812,7 @@ private fun RouteStageScreen(
                         PhotoGrid(
                             photos = cargoStagePhotos,
                             uploads = stageUploads.filter { it.workflowDocumentId.isNullOrBlank() },
+                            preparations = cargoStagePreparations,
                             deletingPhotoIds = state.deletingPhotoIds,
                             imageAuthHeader = state.imageAuthHeader,
                             onPhoto = onPhoto,
@@ -4807,7 +4859,7 @@ private fun RouteStageScreen(
 private data class RouteWorkflowAttachmentTarget(
     val stepId: String,
     val documentId: String,
-)
+) : java.io.Serializable
 
 @Composable
 private fun RouteWorkflowStepsCard(
@@ -4816,6 +4868,7 @@ private fun RouteWorkflowStepsCard(
     weightText: String,
     serverPhotos: List<RoutePhotoDto>,
     localUploads: List<PhotoUploadEntity>,
+    preparingUploads: List<PreparingPhotoUpload>,
     onStepToggle: (String, Boolean) -> Unit,
     onTakeDocumentPhoto: (String, String) -> Unit,
     onPickDocumentPhoto: (String, String) -> Unit,
@@ -4902,7 +4955,10 @@ private fun RouteWorkflowStepsCard(
                                 it.status != PhotoUploadStatus.Cancelled.storageValue &&
                                 it.status != PhotoUploadStatus.FailedPermanent.storageValue
                         }
-                        val count = documentServerPhotos.size + documentUploads.size
+                        val documentPreparations = preparingUploads.count {
+                            it.workflowStepId == step.id && it.workflowDocumentId == document.id
+                        }
+                        val count = documentServerPhotos.size + documentUploads.size + documentPreparations
                         Column(
                             Modifier
                                 .fillMaxWidth()
@@ -5951,6 +6007,7 @@ private fun CargoActionButton(label: String, icon: ImageVector, color: Color, on
 private fun PhotoGrid(
     photos: List<RoutePhotoDto>,
     uploads: List<PhotoUploadEntity>,
+    preparations: List<PreparingPhotoUpload> = emptyList(),
     deletingPhotoIds: Set<String>,
     imageAuthHeader: String?,
     onPhoto: (RoutePhotoDto) -> Unit,
@@ -5960,9 +6017,13 @@ private fun PhotoGrid(
     readOnly: Boolean = false,
 ) {
     var pendingDelete by remember { mutableStateOf<PhotoDeleteTarget?>(null) }
-    val items = (uploads.map { PhotoGridItem.Upload(it) } + photos.map { PhotoGridItem.Server(it) })
+    val items = (
+        preparations.map { PhotoGridItem.Preparing(it) } +
+            uploads.map { PhotoGridItem.Upload(it) } +
+            photos.map { PhotoGridItem.Server(it) }
+        )
         .sortedByDescending { it.sortEpochMillis }
-    val visibleAttachmentCount = visiblePhotoAttachmentCount(photos.size, uploads.size)
+    val visibleAttachmentCount = visiblePhotoAttachmentCount(photos.size, uploads.size + preparations.size)
 
     Card(
         colors = CardDefaults.cardColors(containerColor = TppTheme.colors.card),
@@ -6009,6 +6070,10 @@ private fun PhotoGrid(
                                             readOnly = readOnly,
                                             modifier = Modifier.weight(1f),
                                         )
+                                        is PhotoGridItem.Preparing -> PreparingPhotoTile(
+                                            preparation = item.preparation,
+                                            modifier = Modifier.weight(1f),
+                                        )
                                     }
                                 }
                                 if (rowItems.size == 1) {
@@ -6055,6 +6120,9 @@ private sealed class PhotoGridItem(open val sortEpochMillis: Long) {
     )
 
     data class Upload(val upload: PhotoUploadEntity) : PhotoGridItem(upload.createdAtEpochMillis)
+
+    data class Preparing(val preparation: PreparingPhotoUpload) :
+        PhotoGridItem(preparation.createdAtEpochMillis)
 }
 
 private sealed class PhotoDeleteTarget {
@@ -6288,6 +6356,40 @@ private fun PendingPhotoTile(
     }
 }
 
+@Composable
+private fun PreparingPhotoTile(
+    preparation: PreparingPhotoUpload,
+    modifier: Modifier = Modifier,
+) {
+    Box(modifier.aspectRatio(1f).background(TppTheme.colors.panel, RoundedCornerShape(4.dp))) {
+        AsyncImage(
+            model = preparation.uri,
+            contentDescription = "Przygotowywane zdjęcie",
+            contentScale = ContentScale.Crop,
+            modifier = Modifier.fillMaxSize(),
+        )
+        Box(Modifier.fillMaxSize().background(Color.Black.copy(alpha = 0.24f)))
+        CircularProgressIndicator(
+            modifier = Modifier.align(Alignment.Center).size(30.dp),
+            color = Color.White,
+            trackColor = Color.White.copy(alpha = 0.3f),
+            strokeWidth = 2.5.dp,
+        )
+        Text(
+            "Przygotowuję zdjęcie",
+            color = TppTheme.colors.ink,
+            fontFamily = FontFamily.Monospace,
+            fontWeight = FontWeight.Bold,
+            style = MaterialTheme.typography.labelMedium,
+            modifier = Modifier
+                .align(Alignment.BottomStart)
+                .fillMaxWidth()
+                .background(Color.White.copy(alpha = 0.94f))
+                .padding(10.dp),
+        )
+    }
+}
+
 @Composable
 private fun PhotoTileLoadingOverlay() {
     Box(

app/src/main/java/pl/firmatpp/kierowca/ui/DriverDayPublicationUiRules.kt

@@ -0,0 +1,14 @@
+package pl.firmatpp.kierowca.ui
+
+import java.time.LocalDate
+import pl.firmatpp.kierowca.data.model.DriverRouteDto
+
+fun routeIncludesPublicationDate(route: DriverRouteDto?, date: String?): Boolean {
+    if (route == null || date == null) return false
+    return runCatching {
+        val day = LocalDate.parse(date)
+        val start = LocalDate.parse(route.routeDate)
+        val end = LocalDate.parse(route.unloadingDate ?: route.routeDate)
+        !day.isBefore(start) && !day.isAfter(end)
+    }.getOrDefault(false)
+}

app/src/main/java/pl/firmatpp/kierowca/ui/DriverViewModel.kt

@@ -73,6 +73,16 @@ enum class DriverScreen { Initializing, Phone, Otp, Routes, Profile, Diagnostics
 
 enum class ServerConnectionState { Unknown, Reachable, Degraded }
 
+data class PreparingPhotoUpload(
+    val id: String,
+    val routeId: String,
+    val uri: Uri,
+    val stage: String,
+    val workflowStepId: String?,
+    val workflowDocumentId: String?,
+    val createdAtEpochMillis: Long = System.currentTimeMillis(),
+)
+
 data class DriverUiState(
     val screen: DriverScreen = DriverScreen.Initializing,
     val loading: Boolean = true,
@@ -111,6 +121,7 @@ data class DriverUiState(
     val routeActions: List<RouteActionEntity> = emptyList(),
     val visibleRouteActions: List<RouteActionEntity> = emptyList(),
     val photoUploads: List<PhotoUploadEntity> = emptyList(),
+    val preparingPhotoUploads: List<PreparingPhotoUpload> = emptyList(),
     val queuedPhotoUploads: List<PhotoUploadEntity> = emptyList(),
     val dispatchSheetReminder: DispatchSheetReminderDto? = null,
     val tachographReminder: TachographReminderDto? = null,
@@ -633,6 +644,10 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
                         error = null,
                     )
                 }
+                if (!cached.stale && response.dayPublication?.isVisible == false &&
+                    routeIncludesPublicationDate(_state.value.selectedRoute, response.dayPublication.date)) {
+                    _state.value.selectedRoute?.id?.let(::closeUnavailableRoute)
+                }
                 response.session.driver.id.let { driverId ->
                     liveSyncClient.start(driverId, response.realtime)
                     if (_state.value.isOnline && !cached.stale) registerPushTokenIfAvailable(driverId)
@@ -754,6 +769,8 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
                     if (generation != routeDetailRequestGeneration) return@onFailure
                     if (ApiErrorMapper.map(throwable).kind == ApiErrorKind.Auth) {
                         handleExpiredSession()
+                    } else if (ApiErrorMapper.map(throwable).statusCode == 404) {
+                        closeUnavailableRoute(routeId)
                     } else {
                         _state.update { it.withApiError(throwable) }
                     }
@@ -763,6 +780,19 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
         }
     }
 
+    private fun closeUnavailableRoute(routeId: String) {
+        routeDetailRequestGeneration++
+        _state.update { current ->
+            if (current.selectedRoute?.id != routeId) current else current.copy(
+                selectedRoute = null,
+                selectedPhoto = null,
+                routes = current.routes.filterNot { it.id == routeId },
+                refreshing = false,
+                screen = if (current.screen in setOf(DriverScreen.Detail, DriverScreen.StartRoute, DriverScreen.LoadingWeight, DriverScreen.FinishRoute, DriverScreen.Photo)) DriverScreen.Routes else current.screen,
+            )
+        }
+    }
+
     fun openProfile() {
         _state.update { it.copy(screen = DriverScreen.Profile, error = null) }
         if (
@@ -1496,23 +1526,46 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
             _state.update { it.copy(error = "Zdjęcia możesz dodać tylko w zaplanowanym zakresie kursu.") }
             return null
         }
+        val preparation = PreparingPhotoUpload(
+            id = UUID.randomUUID().toString(),
+            routeId = route.id,
+            uri = uri,
+            stage = stage,
+            workflowStepId = workflowStepId,
+            workflowDocumentId = workflowDocumentId,
+        )
+        _state.update {
+            it.copy(
+                preparingPhotoUploads = it.preparingPhotoUploads + preparation,
+                error = null,
+            )
+        }
         return viewModelScope.launch {
-            _state.update { it.copy(error = null) }
+            try {
-            runCatching {
+                runCatching {
-                photoUploadOutbox.enqueue(
+                    photoUploadOutbox.enqueue(
-                    routeId = route.id,
+                        routeId = route.id,
-                    uri = uri,
+                        uri = uri,
-                    source = source,
+                        source = source,
-                    metadata = metadata,
+                        metadata = metadata,
-                    stage = stage,
+                        stage = stage,
-                    workflowVersion = snapshot.routeWorkflow?.version,
+                        workflowVersion = snapshot.routeWorkflow?.version,
-                    workflowStepId = workflowStepId,
+                        workflowStepId = workflowStepId,
-                    workflowDocumentId = workflowDocumentId,
+                        workflowDocumentId = workflowDocumentId,
-                )
+                    )
-            }
-                .onFailure { throwable ->
-                    _state.update { it.withApiError(throwable) }
                 }
+                    .onFailure { throwable ->
+                        _state.update { it.withApiError(throwable) }
+                    }
+            } finally {
+                _state.update {
+                    it.copy(
+                        preparingPhotoUploads = it.preparingPhotoUploads.filterNot { item ->
+                            item.id == preparation.id
+                        },
+                    )
+                }
+            }
         }
     }
 
@@ -2017,7 +2070,14 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
                 DriverScreen.Detail -> {
                     photoUploadsJob?.cancel()
                     routeActionsJob?.cancel()
-                    it.copy(screen = DriverScreen.Routes, selectedRoute = null, routeActions = emptyList(), photoUploads = emptyList(), feedback = null)
+                    it.copy(
+                        screen = DriverScreen.Routes,
+                        selectedRoute = null,
+                        routeActions = emptyList(),
+                        photoUploads = emptyList(),
+                        preparingPhotoUploads = emptyList(),
+                        feedback = null,
+                    )
                 }
                 DriverScreen.Profile -> it.copy(screen = DriverScreen.Routes)
                 DriverScreen.Diagnostics -> it.copy(screen = DriverScreen.Profile)
@@ -2239,6 +2299,7 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
         val snapshot = _state.value
         when (hint.scope) {
             DriverSyncRepository.SCOPE_ROUTES -> {
+                if (routeIncludesPublicationDate(snapshot.selectedRoute, hint.date)) refreshSelectedRoute()
                 if (shouldShowRouteDayLiveUpdate(snapshot.selectedDate, hint.date)) {
                     refreshRoutesSilently()
                     if (snapshot.screen == DriverScreen.Routes) {

app/src/main/java/pl/firmatpp/kierowca/ui/MultiplePhotoCameraScreen.kt

@@ -43,6 +43,7 @@ import androidx.compose.runtime.mutableStateOf
 import androidx.compose.runtime.remember
 import androidx.compose.runtime.rememberCoroutineScope
 import androidx.compose.runtime.rememberUpdatedState
+import androidx.compose.runtime.saveable.rememberSaveable
 import androidx.compose.runtime.setValue
 import androidx.compose.ui.Alignment
 import androidx.compose.ui.Modifier
@@ -74,7 +75,7 @@ internal fun MultiplePhotoCameraScreen(
             imageCaptureMode = ImageCapture.CAPTURE_MODE_MINIMIZE_LATENCY
         }
     }
-    var capturedCount by remember { mutableIntStateOf(0) }
+    var capturedCount by rememberSaveable(stage) { mutableIntStateOf(0) }
     var pendingUploads by remember { mutableIntStateOf(0) }
     var isCapturing by remember { mutableStateOf(false) }
     var cameraUnavailable by remember { mutableStateOf(false) }

app/src/test/java/pl/firmatpp/kierowca/sync/PublishedRoutesNotificationFormatterTest.kt

@@ -0,0 +1,20 @@
+package pl.firmatpp.kierowca.sync
+
+import org.junit.Assert.assertEquals
+import org.junit.Test
+
+class PublishedRoutesNotificationFormatterTest {
+    @Test
+    fun formatsPublicationWithPolishWeekdayAndUnambiguousDate() {
+        assertEquals("Opublikowano twoje kursy na poniedziałek (28.09.2026).", PublishedRoutesNotificationFormatter.text("2026-09-28"))
+        assertEquals("Opublikowano twoje kursy na środę (30.09.2026).", PublishedRoutesNotificationFormatter.text("2026-09-30"))
+        assertEquals("Opublikowano twoje kursy na niedzielę (04.10.2026).", PublishedRoutesNotificationFormatter.text("2026-10-04"))
+    }
+
+    @Test
+    fun handlesMissingAndInvalidDates() {
+        val fallback = "Opublikowano twoje kursy. Otwórz aplikację, aby je zobaczyć."
+        assertEquals(fallback, PublishedRoutesNotificationFormatter.text(null))
+        assertEquals(fallback, PublishedRoutesNotificationFormatter.text("invalid"))
+    }
+}

app/src/test/java/pl/firmatpp/kierowca/ui/DriverDayPublicationUiRulesTest.kt

@@ -0,0 +1,38 @@
+package pl.firmatpp.kierowca.ui
+
+import org.junit.Assert.assertFalse
+import org.junit.Assert.assertTrue
+import org.junit.Test
+import pl.firmatpp.kierowca.data.model.DriverRouteDto
+
+class DriverDayPublicationUiRulesTest {
+    private val route = DriverRouteDto(
+        id = "42", routeDate = "2026-09-28", unloadingDate = "2026-09-30",
+        startsAt = "09:00", originName = "Baza", destinationName = "Zakład",
+        contractorName = "Kontrahent", contractName = null, contractCode = null, relationLabel = "Baza → Zakład",
+        status = "ZAPLANOWANA", distanceKm = 20.0, notes = null, truck = null,
+    )
+
+    @Test
+    fun hidingAnyScheduledDayCanInvalidateOpenDetails() {
+        assertTrue(routeIncludesPublicationDate(route, "2026-09-28"))
+        assertTrue(routeIncludesPublicationDate(route, "2026-09-29"))
+        assertTrue(routeIncludesPublicationDate(route, "2026-09-30"))
+    }
+
+    @Test
+    fun unrelatedOrInvalidDatesMustNotCloseTheOpenRoute() {
+        assertFalse(routeIncludesPublicationDate(route, "2026-09-27"))
+        assertFalse(routeIncludesPublicationDate(route, "2026-10-01"))
+        assertFalse(routeIncludesPublicationDate(route, "invalid"))
+        assertFalse(routeIncludesPublicationDate(null, "2026-09-28"))
+        assertFalse(routeIncludesPublicationDate(route, null))
+    }
+
+    @Test
+    fun singleDayRoutesDoNotInheritTheNextDaysPublication() {
+        val singleDay = route.copy(unloadingDate = null)
+        assertTrue(routeIncludesPublicationDate(singleDay, "2026-09-28"))
+        assertFalse(routeIncludesPublicationDate(singleDay, "2026-09-29"))
+    }
+}