Compare commits
14
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
062415a75d | ||
|
|
ab68be4c1e | ||
|
|
513c1785ef | ||
|
|
e70a53eca7 | ||
|
|
c3004a3d2e | ||
|
|
fda4b462dc | ||
|
|
6a1a15ade9 | ||
|
|
ea44cf5d2e | ||
|
|
984feb170a | ||
|
|
5691c87e91 | ||
|
|
227e08a671 | ||
|
|
3bfb5f9788 | ||
|
|
bf1cf3865a | ||
|
|
0c3bed6213 |
@@ -22,7 +22,7 @@ val keystoreProperties = Properties().apply {
|
|||||||
|
|
||||||
android {
|
android {
|
||||||
namespace = "pl.firmatpp.kierowca"
|
namespace = "pl.firmatpp.kierowca"
|
||||||
compileSdk = 35
|
compileSdk = 36
|
||||||
|
|
||||||
fun configValue(name: String, default: String): String =
|
fun configValue(name: String, default: String): String =
|
||||||
providers.gradleProperty(name)
|
providers.gradleProperty(name)
|
||||||
@@ -33,9 +33,9 @@ android {
|
|||||||
defaultConfig {
|
defaultConfig {
|
||||||
applicationId = "pl.firmatpp.kierowca"
|
applicationId = "pl.firmatpp.kierowca"
|
||||||
minSdk = 26
|
minSdk = 26
|
||||||
targetSdk = 35
|
targetSdk = 36
|
||||||
versionCode = 119
|
versionCode = 125
|
||||||
versionName = "1.0.66"
|
versionName = "1.0.72"
|
||||||
setProperty("archivesBaseName", "pl.firmatpp.kierowca")
|
setProperty("archivesBaseName", "pl.firmatpp.kierowca")
|
||||||
testInstrumentationRunner = "androidx.test.runner.AndroidJUnitRunner"
|
testInstrumentationRunner = "androidx.test.runner.AndroidJUnitRunner"
|
||||||
|
|
||||||
|
|||||||
@@ -9,6 +9,10 @@
|
|||||||
<uses-permission android:name="android.permission.FOREGROUND_SERVICE" />
|
<uses-permission android:name="android.permission.FOREGROUND_SERVICE" />
|
||||||
<uses-permission android:name="android.permission.FOREGROUND_SERVICE_LOCATION" />
|
<uses-permission android:name="android.permission.FOREGROUND_SERVICE_LOCATION" />
|
||||||
|
|
||||||
|
<uses-feature
|
||||||
|
android:name="android.hardware.camera"
|
||||||
|
android:required="false" />
|
||||||
|
|
||||||
<queries>
|
<queries>
|
||||||
<intent>
|
<intent>
|
||||||
<action android:name="android.speech.RecognitionService" />
|
<action android:name="android.speech.RecognitionService" />
|
||||||
|
|||||||
@@ -20,6 +20,7 @@ class AppPreferencesStore(
|
|||||||
|
|
||||||
private val themeModeKey = stringPreferencesKey("theme_mode")
|
private val themeModeKey = stringPreferencesKey("theme_mode")
|
||||||
private val routeProgressNotificationEnabledKey = booleanPreferencesKey("route_progress_notification_enabled")
|
private val routeProgressNotificationEnabledKey = booleanPreferencesKey("route_progress_notification_enabled")
|
||||||
|
private val routeLocationEnabledKey = booleanPreferencesKey("route_location_enabled")
|
||||||
|
|
||||||
val themeMode: Flow<AppThemeMode> = dataStore.data
|
val themeMode: Flow<AppThemeMode> = dataStore.data
|
||||||
.map { preferences -> AppThemeMode.fromStoredValue(preferences[themeModeKey]) }
|
.map { preferences -> AppThemeMode.fromStoredValue(preferences[themeModeKey]) }
|
||||||
@@ -27,6 +28,9 @@ class AppPreferencesStore(
|
|||||||
val routeProgressNotificationEnabled: Flow<Boolean> = dataStore.data
|
val routeProgressNotificationEnabled: Flow<Boolean> = dataStore.data
|
||||||
.map { preferences -> preferences[routeProgressNotificationEnabledKey] ?: true }
|
.map { preferences -> preferences[routeProgressNotificationEnabledKey] ?: true }
|
||||||
|
|
||||||
|
val routeLocationEnabled: Flow<Boolean> = dataStore.data
|
||||||
|
.map { preferences -> preferences[routeLocationEnabledKey] ?: false }
|
||||||
|
|
||||||
suspend fun setThemeMode(themeMode: AppThemeMode) {
|
suspend fun setThemeMode(themeMode: AppThemeMode) {
|
||||||
dataStore.edit { preferences ->
|
dataStore.edit { preferences ->
|
||||||
preferences[themeModeKey] = themeMode.storedValue
|
preferences[themeModeKey] = themeMode.storedValue
|
||||||
@@ -38,4 +42,10 @@ class AppPreferencesStore(
|
|||||||
preferences[routeProgressNotificationEnabledKey] = enabled
|
preferences[routeProgressNotificationEnabledKey] = enabled
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
suspend fun setRouteLocationEnabled(enabled: Boolean) {
|
||||||
|
dataStore.edit { preferences ->
|
||||||
|
preferences[routeLocationEnabledKey] = enabled
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -22,17 +22,6 @@ class DeviceInfoProvider(
|
|||||||
androidVersion = Build.VERSION.RELEASE,
|
androidVersion = Build.VERSION.RELEASE,
|
||||||
sdkInt = Build.VERSION.SDK_INT,
|
sdkInt = Build.VERSION.SDK_INT,
|
||||||
appVersion = BuildConfig.VERSION_NAME,
|
appVersion = BuildConfig.VERSION_NAME,
|
||||||
serialNumber = readSerialNumber(),
|
serialNumber = null,
|
||||||
)
|
)
|
||||||
|
|
||||||
private fun readSerialNumber(): String? =
|
|
||||||
runCatching {
|
|
||||||
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
|
|
||||||
Build.getSerial()
|
|
||||||
} else {
|
|
||||||
@Suppress("DEPRECATION")
|
|
||||||
Build.SERIAL
|
|
||||||
}
|
|
||||||
}.getOrNull()
|
|
||||||
?.takeUnless { it.isBlank() || it.equals(Build.UNKNOWN, ignoreCase = true) }
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -12,6 +12,7 @@ import okhttp3.RequestBody.Companion.toRequestBody
|
|||||||
import pl.firmatpp.kierowca.data.api.ApiFactory
|
import pl.firmatpp.kierowca.data.api.ApiFactory
|
||||||
import pl.firmatpp.kierowca.data.api.MobileDriverApi
|
import pl.firmatpp.kierowca.data.api.MobileDriverApi
|
||||||
import pl.firmatpp.kierowca.data.model.BootstrapResponse
|
import pl.firmatpp.kierowca.data.model.BootstrapResponse
|
||||||
|
import pl.firmatpp.kierowca.data.model.AcknowledgeTachographReminderBody
|
||||||
import pl.firmatpp.kierowca.data.model.BroadcastAuthBody
|
import pl.firmatpp.kierowca.data.model.BroadcastAuthBody
|
||||||
import pl.firmatpp.kierowca.data.model.BroadcastAuthResponse
|
import pl.firmatpp.kierowca.data.model.BroadcastAuthResponse
|
||||||
import pl.firmatpp.kierowca.data.model.CancelLeaveRequestBody
|
import pl.firmatpp.kierowca.data.model.CancelLeaveRequestBody
|
||||||
@@ -33,6 +34,7 @@ import pl.firmatpp.kierowca.data.model.RoutePointsResponse
|
|||||||
import pl.firmatpp.kierowca.data.model.RouteResponse
|
import pl.firmatpp.kierowca.data.model.RouteResponse
|
||||||
import pl.firmatpp.kierowca.data.model.StartRouteBody
|
import pl.firmatpp.kierowca.data.model.StartRouteBody
|
||||||
import pl.firmatpp.kierowca.data.model.SyncStateResponse
|
import pl.firmatpp.kierowca.data.model.SyncStateResponse
|
||||||
|
import pl.firmatpp.kierowca.data.model.TachographReminderDto
|
||||||
import pl.firmatpp.kierowca.data.model.VerifyOtpBody
|
import pl.firmatpp.kierowca.data.model.VerifyOtpBody
|
||||||
import pl.firmatpp.kierowca.data.upload.DispatchSheetUploadEntity
|
import pl.firmatpp.kierowca.data.upload.DispatchSheetUploadEntity
|
||||||
import pl.firmatpp.kierowca.data.upload.PhotoUploadEntity
|
import pl.firmatpp.kierowca.data.upload.PhotoUploadEntity
|
||||||
@@ -56,6 +58,12 @@ class DriverRepository(
|
|||||||
suspend fun bootstrap(date: String? = null): BootstrapResponse =
|
suspend fun bootstrap(date: String? = null): BootstrapResponse =
|
||||||
api.bootstrap(authHeader(requireToken()), date)
|
api.bootstrap(authHeader(requireToken()), date)
|
||||||
|
|
||||||
|
suspend fun acknowledgeTachographReminder(taskIds: List<String>): TachographReminderDto =
|
||||||
|
api.acknowledgeTachographReminder(
|
||||||
|
authHeader(requireToken()),
|
||||||
|
AcknowledgeTachographReminderBody(taskIds),
|
||||||
|
).tachographReminder
|
||||||
|
|
||||||
suspend fun route(routeId: String): RouteResponse =
|
suspend fun route(routeId: String): RouteResponse =
|
||||||
api.route(authHeader(requireToken()), routeId)
|
api.route(authHeader(requireToken()), routeId)
|
||||||
|
|
||||||
|
|||||||
@@ -3,6 +3,8 @@ package pl.firmatpp.kierowca.data.api
|
|||||||
import okhttp3.MultipartBody
|
import okhttp3.MultipartBody
|
||||||
import okhttp3.RequestBody
|
import okhttp3.RequestBody
|
||||||
import pl.firmatpp.kierowca.data.model.BootstrapResponse
|
import pl.firmatpp.kierowca.data.model.BootstrapResponse
|
||||||
|
import pl.firmatpp.kierowca.data.model.AcknowledgeTachographReminderBody
|
||||||
|
import pl.firmatpp.kierowca.data.model.AcknowledgeTachographReminderResponse
|
||||||
import pl.firmatpp.kierowca.data.model.BroadcastAuthBody
|
import pl.firmatpp.kierowca.data.model.BroadcastAuthBody
|
||||||
import pl.firmatpp.kierowca.data.model.BroadcastAuthResponse
|
import pl.firmatpp.kierowca.data.model.BroadcastAuthResponse
|
||||||
import pl.firmatpp.kierowca.data.model.CancelLeaveRequestBody
|
import pl.firmatpp.kierowca.data.model.CancelLeaveRequestBody
|
||||||
@@ -67,6 +69,12 @@ interface MobileDriverApi {
|
|||||||
@Query("date") date: String?,
|
@Query("date") date: String?,
|
||||||
): BootstrapResponse
|
): BootstrapResponse
|
||||||
|
|
||||||
|
@POST("mobile/driver/tachograph-reminder/acknowledge")
|
||||||
|
suspend fun acknowledgeTachographReminder(
|
||||||
|
@Header("Authorization") authorization: String,
|
||||||
|
@Body body: AcknowledgeTachographReminderBody,
|
||||||
|
): AcknowledgeTachographReminderResponse
|
||||||
|
|
||||||
@GET("mobile/driver/leave-request-types")
|
@GET("mobile/driver/leave-request-types")
|
||||||
suspend fun leaveRequestTypes(
|
suspend fun leaveRequestTypes(
|
||||||
@Header("Authorization") authorization: String,
|
@Header("Authorization") authorization: String,
|
||||||
|
|||||||
@@ -47,6 +47,7 @@ data class BootstrapResponse(
|
|||||||
val routes: RoutesBucketDto,
|
val routes: RoutesBucketDto,
|
||||||
val driverAppSettings: DriverAppSettingsDto?,
|
val driverAppSettings: DriverAppSettingsDto?,
|
||||||
val dispatchSheetReminder: DispatchSheetReminderDto? = null,
|
val dispatchSheetReminder: DispatchSheetReminderDto? = null,
|
||||||
|
val tachographReminder: TachographReminderDto? = null,
|
||||||
val notificationPreferences: NotificationPreferencesDto? = null,
|
val notificationPreferences: NotificationPreferencesDto? = null,
|
||||||
val realtime: RealtimeConfigDto? = null,
|
val realtime: RealtimeConfigDto? = null,
|
||||||
val syncState: SyncStateResponse? = null,
|
val syncState: SyncStateResponse? = null,
|
||||||
@@ -72,6 +73,7 @@ data class DriverAppSettingsDto(
|
|||||||
val allowGalleryUploads: Boolean?,
|
val allowGalleryUploads: Boolean?,
|
||||||
val allowRouteCompletion: Boolean?,
|
val allowRouteCompletion: Boolean?,
|
||||||
val requirePreciseLocationForPhotos: Boolean?,
|
val requirePreciseLocationForPhotos: Boolean?,
|
||||||
|
val routeLocationMode: String? = null,
|
||||||
val loadingPhotoRequirement: String? = null,
|
val loadingPhotoRequirement: String? = null,
|
||||||
val loadingWeightRequirement: String? = null,
|
val loadingWeightRequirement: String? = null,
|
||||||
val unloadingPhotoRequirement: String? = null,
|
val unloadingPhotoRequirement: String? = null,
|
||||||
@@ -79,6 +81,7 @@ data class DriverAppSettingsDto(
|
|||||||
val dispatchSheetRemindersEnabled: Boolean? = null,
|
val dispatchSheetRemindersEnabled: Boolean? = null,
|
||||||
val dispatchSheetOnFridays: Boolean? = null,
|
val dispatchSheetOnFridays: Boolean? = null,
|
||||||
val dispatchSheetOnLastWorkingDay: Boolean? = null,
|
val dispatchSheetOnLastWorkingDay: Boolean? = null,
|
||||||
|
val tachographRemindersEnabled: Boolean? = null,
|
||||||
val leaveRequests: LeaveRequestsConfigDto? = null,
|
val leaveRequests: LeaveRequestsConfigDto? = null,
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -98,6 +101,30 @@ data class DispatchSheetReminderDto(
|
|||||||
val canUpload: Boolean = false,
|
val canUpload: Boolean = false,
|
||||||
)
|
)
|
||||||
|
|
||||||
|
data class TachographReminderDto(
|
||||||
|
val enabled: Boolean = false,
|
||||||
|
val visible: Boolean = false,
|
||||||
|
val title: String? = null,
|
||||||
|
val message: String? = null,
|
||||||
|
val confirmationLabel: String? = null,
|
||||||
|
val tasks: List<TachographReminderTaskDto>? = null,
|
||||||
|
)
|
||||||
|
|
||||||
|
data class TachographReminderTaskDto(
|
||||||
|
val id: String,
|
||||||
|
val type: String,
|
||||||
|
val label: String,
|
||||||
|
)
|
||||||
|
|
||||||
|
data class AcknowledgeTachographReminderBody(
|
||||||
|
val taskIds: List<String>,
|
||||||
|
)
|
||||||
|
|
||||||
|
data class AcknowledgeTachographReminderResponse(
|
||||||
|
val ok: Boolean,
|
||||||
|
val tachographReminder: TachographReminderDto,
|
||||||
|
)
|
||||||
|
|
||||||
data class DispatchSheetPhotoDto(
|
data class DispatchSheetPhotoDto(
|
||||||
val id: String,
|
val id: String,
|
||||||
val driverId: String,
|
val driverId: String,
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ import com.google.gson.Gson
|
|||||||
import java.io.IOException
|
import java.io.IOException
|
||||||
import java.time.LocalDate
|
import java.time.LocalDate
|
||||||
import pl.firmatpp.kierowca.data.DriverRepository
|
import pl.firmatpp.kierowca.data.DriverRepository
|
||||||
|
import pl.firmatpp.kierowca.data.rethrowIfCancellation
|
||||||
import pl.firmatpp.kierowca.data.model.BootstrapResponse
|
import pl.firmatpp.kierowca.data.model.BootstrapResponse
|
||||||
import pl.firmatpp.kierowca.data.model.DriverRouteDto
|
import pl.firmatpp.kierowca.data.model.DriverRouteDto
|
||||||
import pl.firmatpp.kierowca.data.model.RouteResponse
|
import pl.firmatpp.kierowca.data.model.RouteResponse
|
||||||
@@ -38,6 +39,7 @@ class DriverSyncRepository(
|
|||||||
saveSyncStates(response.syncState)
|
saveSyncStates(response.syncState)
|
||||||
CachedValue(response, stale = false, syncedAtEpochMillis = System.currentTimeMillis())
|
CachedValue(response, stale = false, syncedAtEpochMillis = System.currentTimeMillis())
|
||||||
}.getOrElse { throwable ->
|
}.getOrElse { throwable ->
|
||||||
|
throwable.rethrowIfCancellation()
|
||||||
cachedBootstrap(requestedDate, throwable)
|
cachedBootstrap(requestedDate, throwable)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -58,6 +60,7 @@ class DriverSyncRepository(
|
|||||||
saveSyncStates(response.syncState)
|
saveSyncStates(response.syncState)
|
||||||
CachedValue(response, stale = false, syncedAtEpochMillis = System.currentTimeMillis())
|
CachedValue(response, stale = false, syncedAtEpochMillis = System.currentTimeMillis())
|
||||||
}.getOrElse { throwable ->
|
}.getOrElse { throwable ->
|
||||||
|
throwable.rethrowIfCancellation()
|
||||||
cachedRoute(routeId, throwable)
|
cachedRoute(routeId, throwable)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -14,6 +14,61 @@ interface RouteActionDao {
|
|||||||
@Query("SELECT * FROM route_actions WHERE clientActionId = :clientActionId LIMIT 1")
|
@Query("SELECT * FROM route_actions WHERE clientActionId = :clientActionId LIMIT 1")
|
||||||
suspend fun find(clientActionId: String): RouteActionEntity?
|
suspend fun find(clientActionId: String): RouteActionEntity?
|
||||||
|
|
||||||
|
@Query(
|
||||||
|
"""
|
||||||
|
SELECT * FROM route_actions
|
||||||
|
WHERE routeId = :routeId
|
||||||
|
AND action = 'start'
|
||||||
|
AND createdAtEpochMillis < :beforeEpochMillis
|
||||||
|
ORDER BY createdAtEpochMillis DESC
|
||||||
|
LIMIT 1
|
||||||
|
""",
|
||||||
|
)
|
||||||
|
suspend fun latestStartBefore(routeId: String, beforeEpochMillis: Long): RouteActionEntity?
|
||||||
|
|
||||||
|
@Query(
|
||||||
|
"""
|
||||||
|
SELECT * FROM route_actions
|
||||||
|
WHERE routeId = :routeId
|
||||||
|
AND action = 'finish'
|
||||||
|
AND createdAtEpochMillis > :afterEpochMillis
|
||||||
|
AND status != 'CONFIRMED'
|
||||||
|
ORDER BY createdAtEpochMillis ASC
|
||||||
|
""",
|
||||||
|
)
|
||||||
|
suspend fun unconfirmedFinishesAfter(routeId: String, afterEpochMillis: Long): List<RouteActionEntity>
|
||||||
|
|
||||||
|
@Query(
|
||||||
|
"""
|
||||||
|
SELECT EXISTS(
|
||||||
|
SELECT 1 FROM route_actions
|
||||||
|
WHERE routeId = :routeId
|
||||||
|
AND action = 'finish'
|
||||||
|
AND status = 'CONFIRMED'
|
||||||
|
AND createdAtEpochMillis > :afterEpochMillis
|
||||||
|
)
|
||||||
|
""",
|
||||||
|
)
|
||||||
|
suspend fun hasConfirmedFinishAfter(routeId: String, afterEpochMillis: Long): Boolean
|
||||||
|
|
||||||
|
@Query(
|
||||||
|
"""
|
||||||
|
UPDATE route_actions
|
||||||
|
SET status = 'CONFIRMED',
|
||||||
|
lastError = NULL,
|
||||||
|
updatedAtEpochMillis = :updatedAt
|
||||||
|
WHERE routeId = :routeId
|
||||||
|
AND action = 'finish'
|
||||||
|
AND createdAtEpochMillis < :beforeEpochMillis
|
||||||
|
AND status != 'CONFIRMED'
|
||||||
|
""",
|
||||||
|
)
|
||||||
|
suspend fun confirmSupersededFinishes(
|
||||||
|
routeId: String,
|
||||||
|
beforeEpochMillis: Long,
|
||||||
|
updatedAt: Long = System.currentTimeMillis(),
|
||||||
|
)
|
||||||
|
|
||||||
@Query("SELECT * FROM route_actions WHERE status != 'CONFIRMED'")
|
@Query("SELECT * FROM route_actions WHERE status != 'CONFIRMED'")
|
||||||
suspend fun allUnsent(): List<RouteActionEntity>
|
suspend fun allUnsent(): List<RouteActionEntity>
|
||||||
|
|
||||||
|
|||||||
@@ -8,9 +8,11 @@ import pl.firmatpp.kierowca.data.ApiErrorKind
|
|||||||
import pl.firmatpp.kierowca.data.ApiErrorMapper
|
import pl.firmatpp.kierowca.data.ApiErrorMapper
|
||||||
import pl.firmatpp.kierowca.data.DriverRepository
|
import pl.firmatpp.kierowca.data.DriverRepository
|
||||||
import pl.firmatpp.kierowca.data.rethrowIfCancellation
|
import pl.firmatpp.kierowca.data.rethrowIfCancellation
|
||||||
|
import pl.firmatpp.kierowca.data.model.DriverRouteDto
|
||||||
import pl.firmatpp.kierowca.data.model.FinishRouteBody
|
import pl.firmatpp.kierowca.data.model.FinishRouteBody
|
||||||
import pl.firmatpp.kierowca.data.model.RouteActionResponse
|
import pl.firmatpp.kierowca.data.model.RouteActionResponse
|
||||||
import pl.firmatpp.kierowca.data.model.StartRouteBody
|
import pl.firmatpp.kierowca.data.model.StartRouteBody
|
||||||
|
import pl.firmatpp.kierowca.data.model.driverLifecycleStatus
|
||||||
import pl.firmatpp.kierowca.data.sync.DriverSyncRepository
|
import pl.firmatpp.kierowca.data.sync.DriverSyncRepository
|
||||||
import pl.firmatpp.kierowca.data.sync.NetworkMonitor
|
import pl.firmatpp.kierowca.data.sync.NetworkMonitor
|
||||||
import pl.firmatpp.kierowca.diagnostics.AppDiagnostics
|
import pl.firmatpp.kierowca.diagnostics.AppDiagnostics
|
||||||
@@ -31,6 +33,33 @@ class RouteActionWorker(
|
|||||||
if (!NetworkMonitor(applicationContext).isCurrentlyValidated()) return Result.retry()
|
if (!NetworkMonitor(applicationContext).isCurrentlyValidated()) return Result.retry()
|
||||||
val clientActionId = inputData.getString(KEY_CLIENT_ACTION_ID) ?: return Result.failure()
|
val clientActionId = inputData.getString(KEY_CLIENT_ACTION_ID) ?: return Result.failure()
|
||||||
val action = dao.find(clientActionId) ?: return Result.failure()
|
val action = dao.find(clientActionId) ?: return Result.failure()
|
||||||
|
if (action.status == RouteActionStatus.Confirmed) return Result.success()
|
||||||
|
val startPrerequisite = if (action.action == RouteActionType.Finish) {
|
||||||
|
dao.latestStartBefore(action.routeId, action.createdAtEpochMillis)
|
||||||
|
} else {
|
||||||
|
null
|
||||||
|
}
|
||||||
|
when (routeActionPrerequisiteState(action, startPrerequisite)) {
|
||||||
|
RouteActionPrerequisiteState.Waiting -> {
|
||||||
|
dao.updateStatus(
|
||||||
|
clientActionId = clientActionId,
|
||||||
|
status = RouteActionStatus.Pending,
|
||||||
|
lastError = "Czekam na potwierdzenie rozpoczęcia kursu.",
|
||||||
|
attemptIncrement = 0,
|
||||||
|
)
|
||||||
|
return Result.retry()
|
||||||
|
}
|
||||||
|
RouteActionPrerequisiteState.Failed -> {
|
||||||
|
dao.updateStatus(
|
||||||
|
clientActionId = clientActionId,
|
||||||
|
status = RouteActionStatus.FailedConflict,
|
||||||
|
lastError = "Najpierw trzeba potwierdzić rozpoczęcie kursu.",
|
||||||
|
attemptIncrement = 0,
|
||||||
|
)
|
||||||
|
return Result.failure()
|
||||||
|
}
|
||||||
|
RouteActionPrerequisiteState.Ready -> Unit
|
||||||
|
}
|
||||||
val photoClientRequestIds = photoClientRequestIds(action)
|
val photoClientRequestIds = photoClientRequestIds(action)
|
||||||
|
|
||||||
val photoDependencies = photoClientRequestIds.mapNotNull { photoDao.find(it) }
|
val photoDependencies = photoClientRequestIds.mapNotNull { photoDao.find(it) }
|
||||||
@@ -72,12 +101,25 @@ class RouteActionWorker(
|
|||||||
lastError = null,
|
lastError = null,
|
||||||
attemptIncrement = 0,
|
attemptIncrement = 0,
|
||||||
)
|
)
|
||||||
|
if (action.action == RouteActionType.Finish) {
|
||||||
|
dao.confirmSupersededFinishes(action.routeId, action.createdAtEpochMillis)
|
||||||
|
}
|
||||||
syncRepository.cacheConfirmedRoute(response.route, response.route.routeDate)
|
syncRepository.cacheConfirmedRoute(response.route, response.route.routeDate)
|
||||||
DriverSyncWorker.enqueue(applicationContext, response.route.routeDate, response.route.id)
|
DriverSyncWorker.enqueue(applicationContext, response.route.routeDate, response.route.id)
|
||||||
|
if (action.action == RouteActionType.Start) {
|
||||||
|
val outbox = RouteActionOutbox(applicationContext)
|
||||||
|
dao.unconfirmedFinishesAfter(action.routeId, action.createdAtEpochMillis)
|
||||||
|
.forEach { outbox.enqueueWorker(it.clientActionId) }
|
||||||
|
}
|
||||||
Result.success()
|
Result.success()
|
||||||
}.getOrElse { throwable ->
|
}.getOrElse { throwable ->
|
||||||
throwable.rethrowIfCancellation()
|
throwable.rethrowIfCancellation()
|
||||||
val error = ApiErrorMapper.map(throwable)
|
val error = ApiErrorMapper.map(throwable)
|
||||||
|
val serverRoute = if (error.kind == ApiErrorKind.Conflict) {
|
||||||
|
runCatching { repository.route(action.routeId).route }.getOrNull()
|
||||||
|
} else {
|
||||||
|
null
|
||||||
|
}
|
||||||
AppDiagnostics.reportNonFatal(
|
AppDiagnostics.reportNonFatal(
|
||||||
throwable = throwable,
|
throwable = throwable,
|
||||||
operation = "route_action_worker",
|
operation = "route_action_worker",
|
||||||
@@ -89,8 +131,30 @@ class RouteActionWorker(
|
|||||||
"api_error_code" to error.code,
|
"api_error_code" to error.code,
|
||||||
"api_status_code" to error.statusCode,
|
"api_status_code" to error.statusCode,
|
||||||
"retryable" to error.retryable,
|
"retryable" to error.retryable,
|
||||||
|
"server_route_status" to serverRoute?.driverLifecycleStatus(),
|
||||||
),
|
),
|
||||||
)
|
)
|
||||||
|
val supersededByConfirmedFinish = action.action == RouteActionType.Finish &&
|
||||||
|
dao.hasConfirmedFinishAfter(action.routeId, action.createdAtEpochMillis)
|
||||||
|
if (serverRoute != null &&
|
||||||
|
(
|
||||||
|
routeActionMatchesServer(action, photoClientRequestIds, serverRoute) ||
|
||||||
|
routeActionWasSuperseded(action, supersededByConfirmedFinish, serverRoute)
|
||||||
|
)
|
||||||
|
) {
|
||||||
|
dao.updateStatus(
|
||||||
|
clientActionId = clientActionId,
|
||||||
|
status = RouteActionStatus.Confirmed,
|
||||||
|
lastError = null,
|
||||||
|
attemptIncrement = 0,
|
||||||
|
)
|
||||||
|
if (action.action == RouteActionType.Finish) {
|
||||||
|
dao.confirmSupersededFinishes(action.routeId, action.createdAtEpochMillis)
|
||||||
|
}
|
||||||
|
syncRepository.cacheConfirmedRoute(serverRoute, serverRoute.routeDate)
|
||||||
|
DriverSyncWorker.enqueue(applicationContext, serverRoute.routeDate, serverRoute.id)
|
||||||
|
return@getOrElse Result.success()
|
||||||
|
}
|
||||||
val status = when {
|
val status = when {
|
||||||
error.kind == ApiErrorKind.Conflict -> RouteActionStatus.FailedConflict
|
error.kind == ApiErrorKind.Conflict -> RouteActionStatus.FailedConflict
|
||||||
error.retryable -> RouteActionStatus.FailedRetryable
|
error.retryable -> RouteActionStatus.FailedRetryable
|
||||||
@@ -99,7 +163,7 @@ class RouteActionWorker(
|
|||||||
dao.updateStatus(
|
dao.updateStatus(
|
||||||
clientActionId = clientActionId,
|
clientActionId = clientActionId,
|
||||||
status = status,
|
status = status,
|
||||||
lastError = error.message,
|
lastError = routeActionConflictMessage(error.message, serverRoute),
|
||||||
attemptIncrement = 0,
|
attemptIncrement = 0,
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -146,3 +210,84 @@ class RouteActionWorker(
|
|||||||
fun uniqueWorkName(clientActionId: String): String = "route-action-$clientActionId"
|
fun uniqueWorkName(clientActionId: String): String = "route-action-$clientActionId"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
internal fun routeActionMatchesServer(
|
||||||
|
action: RouteActionEntity,
|
||||||
|
photoClientRequestIds: List<String>,
|
||||||
|
serverRoute: DriverRouteDto,
|
||||||
|
): Boolean {
|
||||||
|
val lifecycleMatches = when (action.action) {
|
||||||
|
RouteActionType.Start -> serverRoute.driverLifecycleStatus() in setOf("W TRAKCIE", "ZAKOŃCZONA")
|
||||||
|
RouteActionType.Finish -> serverRoute.driverLifecycleStatus() == "ZAKOŃCZONA"
|
||||||
|
else -> false
|
||||||
|
}
|
||||||
|
if (!lifecycleMatches) return false
|
||||||
|
|
||||||
|
val serverWeight = when (action.action) {
|
||||||
|
RouteActionType.Start -> serverRoute.loadingWeight
|
||||||
|
RouteActionType.Finish -> serverRoute.unloadingWeight
|
||||||
|
else -> null
|
||||||
|
}
|
||||||
|
val serverNotes = when (action.action) {
|
||||||
|
RouteActionType.Start -> serverRoute.loadingNotes
|
||||||
|
RouteActionType.Finish -> serverRoute.unloadingNotes
|
||||||
|
else -> null
|
||||||
|
}
|
||||||
|
val weightMatches = when {
|
||||||
|
action.weight == null && serverWeight == null -> true
|
||||||
|
action.weight == null || serverWeight == null -> false
|
||||||
|
else -> kotlin.math.abs(action.weight - serverWeight) < 0.0005
|
||||||
|
}
|
||||||
|
val notesMatch = action.notes.normalizedRouteActionNotes() == serverNotes.normalizedRouteActionNotes()
|
||||||
|
val serverPhotoRequestIds = serverRoute.photos
|
||||||
|
.mapNotNull { it.clientRequestId?.trim()?.takeIf(String::isNotBlank) }
|
||||||
|
.toSet()
|
||||||
|
val photosMatch = photoClientRequestIds.all(serverPhotoRequestIds::contains)
|
||||||
|
|
||||||
|
return weightMatches && notesMatch && photosMatch
|
||||||
|
}
|
||||||
|
|
||||||
|
internal fun routeActionWasSuperseded(
|
||||||
|
action: RouteActionEntity,
|
||||||
|
hasConfirmedFinishAfter: Boolean,
|
||||||
|
serverRoute: DriverRouteDto,
|
||||||
|
): Boolean =
|
||||||
|
action.action == RouteActionType.Finish &&
|
||||||
|
hasConfirmedFinishAfter &&
|
||||||
|
serverRoute.driverLifecycleStatus() == "ZAKOŃCZONA"
|
||||||
|
|
||||||
|
internal fun routeActionConflictMessage(message: String, serverRoute: DriverRouteDto?): String {
|
||||||
|
val serverStatus = serverRoute?.driverLifecycleStatus() ?: return message
|
||||||
|
val operationalStatus = serverRoute.operationalStatus
|
||||||
|
?.takeIf(String::isNotBlank)
|
||||||
|
?.let { ", status operacyjny: $it" }
|
||||||
|
.orEmpty()
|
||||||
|
|
||||||
|
return "$message Status kursu na serwerze: $serverStatus$operationalStatus. Dane w telefonie pozostają zachowane."
|
||||||
|
}
|
||||||
|
|
||||||
|
private fun String?.normalizedRouteActionNotes(): String? =
|
||||||
|
this?.trim()?.takeIf(String::isNotEmpty)
|
||||||
|
|
||||||
|
internal enum class RouteActionPrerequisiteState {
|
||||||
|
Ready,
|
||||||
|
Waiting,
|
||||||
|
Failed,
|
||||||
|
}
|
||||||
|
|
||||||
|
internal fun routeActionPrerequisiteState(
|
||||||
|
action: RouteActionEntity,
|
||||||
|
precedingStart: RouteActionEntity?,
|
||||||
|
): RouteActionPrerequisiteState {
|
||||||
|
if (action.action != RouteActionType.Finish || precedingStart == null) {
|
||||||
|
return RouteActionPrerequisiteState.Ready
|
||||||
|
}
|
||||||
|
|
||||||
|
return when (precedingStart.status) {
|
||||||
|
RouteActionStatus.Confirmed -> RouteActionPrerequisiteState.Ready
|
||||||
|
RouteActionStatus.FailedConflict,
|
||||||
|
RouteActionStatus.FailedPermanent,
|
||||||
|
-> RouteActionPrerequisiteState.Failed
|
||||||
|
else -> RouteActionPrerequisiteState.Waiting
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
@@ -229,18 +229,28 @@ class DiagnosticSnapshotProvider(private val context: Context) {
|
|||||||
val validated = capabilities.hasCapability(NetworkCapabilities.NET_CAPABILITY_INTERNET) &&
|
val validated = capabilities.hasCapability(NetworkCapabilities.NET_CAPABILITY_INTERNET) &&
|
||||||
capabilities.hasCapability(NetworkCapabilities.NET_CAPABILITY_VALIDATED)
|
capabilities.hasCapability(NetworkCapabilities.NET_CAPABILITY_VALIDATED)
|
||||||
val links = activeNetwork?.let(manager::getLinkProperties)
|
val links = activeNetwork?.let(manager::getLinkProperties)
|
||||||
|
val roaming = if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.P) {
|
||||||
|
yesNo(!capabilities.hasCapability(NetworkCapabilities.NET_CAPABILITY_NOT_ROAMING))
|
||||||
|
} else {
|
||||||
|
"niedostępne"
|
||||||
|
}
|
||||||
|
val mtu = if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.Q) {
|
||||||
|
links?.mtu?.toString() ?: "brak"
|
||||||
|
} else {
|
||||||
|
"niedostępne"
|
||||||
|
}
|
||||||
return listOf(
|
return listOf(
|
||||||
DiagnosticEntry("Transport", transports.joinToString()),
|
DiagnosticEntry("Transport", transports.joinToString()),
|
||||||
DiagnosticEntry("Internet zweryfikowany", yesNo(validated), if (validated) DiagnosticSeverity.Good else DiagnosticSeverity.Error),
|
DiagnosticEntry("Internet zweryfikowany", yesNo(validated), if (validated) DiagnosticSeverity.Good else DiagnosticSeverity.Error),
|
||||||
DiagnosticEntry("NET_CAPABILITY_INTERNET", yesNo(capabilities.hasCapability(NetworkCapabilities.NET_CAPABILITY_INTERNET))),
|
DiagnosticEntry("NET_CAPABILITY_INTERNET", yesNo(capabilities.hasCapability(NetworkCapabilities.NET_CAPABILITY_INTERNET))),
|
||||||
DiagnosticEntry("NET_CAPABILITY_VALIDATED", yesNo(capabilities.hasCapability(NetworkCapabilities.NET_CAPABILITY_VALIDATED))),
|
DiagnosticEntry("NET_CAPABILITY_VALIDATED", yesNo(capabilities.hasCapability(NetworkCapabilities.NET_CAPABILITY_VALIDATED))),
|
||||||
DiagnosticEntry("Sieć mierzona", yesNo(!capabilities.hasCapability(NetworkCapabilities.NET_CAPABILITY_NOT_METERED))),
|
DiagnosticEntry("Sieć mierzona", yesNo(!capabilities.hasCapability(NetworkCapabilities.NET_CAPABILITY_NOT_METERED))),
|
||||||
DiagnosticEntry("Roaming", yesNo(!capabilities.hasCapability(NetworkCapabilities.NET_CAPABILITY_NOT_ROAMING))),
|
DiagnosticEntry("Roaming", roaming),
|
||||||
DiagnosticEntry("Pasmo downstream / upstream", "${capabilities.linkDownstreamBandwidthKbps} / ${capabilities.linkUpstreamBandwidthKbps} kb/s"),
|
DiagnosticEntry("Pasmo downstream / upstream", "${capabilities.linkDownstreamBandwidthKbps} / ${capabilities.linkUpstreamBandwidthKbps} kb/s"),
|
||||||
DiagnosticEntry("Interfejs", links?.interfaceName ?: "brak"),
|
DiagnosticEntry("Interfejs", links?.interfaceName ?: "brak"),
|
||||||
DiagnosticEntry("Adresy IP", links?.linkAddresses?.joinToString { it.toString() }?.ifBlank { "brak" } ?: "brak"),
|
DiagnosticEntry("Adresy IP", links?.linkAddresses?.joinToString { it.toString() }?.ifBlank { "brak" } ?: "brak"),
|
||||||
DiagnosticEntry("DNS", links?.dnsServers?.joinToString { it.hostAddress ?: it.toString() }?.ifBlank { "brak" } ?: "brak"),
|
DiagnosticEntry("DNS", links?.dnsServers?.joinToString { it.hostAddress ?: it.toString() }?.ifBlank { "brak" } ?: "brak"),
|
||||||
DiagnosticEntry("MTU", links?.mtu?.toString() ?: "brak"),
|
DiagnosticEntry("MTU", mtu),
|
||||||
DiagnosticEntry("Proxy", links?.httpProxy?.toString() ?: "brak"),
|
DiagnosticEntry("Proxy", links?.httpProxy?.toString() ?: "brak"),
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -57,7 +57,11 @@ class LeaveRequestDecisionNotificationWorker(
|
|||||||
.setPriority(NotificationCompat.PRIORITY_DEFAULT)
|
.setPriority(NotificationCompat.PRIORITY_DEFAULT)
|
||||||
.build()
|
.build()
|
||||||
|
|
||||||
|
try {
|
||||||
NotificationManagerCompat.from(applicationContext).notify(leaveRequestId.hashCode(), notification)
|
NotificationManagerCompat.from(applicationContext).notify(leaveRequestId.hashCode(), notification)
|
||||||
|
} catch (_: SecurityException) {
|
||||||
|
return Result.success()
|
||||||
|
}
|
||||||
return Result.success()
|
return Result.success()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -73,7 +73,11 @@ class NewRouteNotificationWorker(
|
|||||||
.setPriority(NotificationCompat.PRIORITY_DEFAULT)
|
.setPriority(NotificationCompat.PRIORITY_DEFAULT)
|
||||||
.build()
|
.build()
|
||||||
|
|
||||||
|
try {
|
||||||
NotificationManagerCompat.from(applicationContext).notify(route.id.hashCode(), notification)
|
NotificationManagerCompat.from(applicationContext).notify(route.id.hashCode(), notification)
|
||||||
|
} catch (_: SecurityException) {
|
||||||
|
return@runCatching Result.success()
|
||||||
|
}
|
||||||
Result.success()
|
Result.success()
|
||||||
}.getOrElse { throwable ->
|
}.getOrElse { throwable ->
|
||||||
throwable.rethrowIfCancellation()
|
throwable.rethrowIfCancellation()
|
||||||
|
|||||||
@@ -1,6 +1,7 @@
|
|||||||
package pl.firmatpp.kierowca.tracking
|
package pl.firmatpp.kierowca.tracking
|
||||||
|
|
||||||
import android.Manifest
|
import android.Manifest
|
||||||
|
import android.annotation.SuppressLint
|
||||||
import android.app.Notification
|
import android.app.Notification
|
||||||
import android.app.NotificationChannel
|
import android.app.NotificationChannel
|
||||||
import android.app.NotificationManager
|
import android.app.NotificationManager
|
||||||
@@ -54,6 +55,11 @@ class ActiveRouteTrackingService : Service(), LocationListener {
|
|||||||
}
|
}
|
||||||
|
|
||||||
override fun onStartCommand(intent: Intent?, flags: Int, startId: Int): Int {
|
override fun onStartCommand(intent: Intent?, flags: Int, startId: Int): Int {
|
||||||
|
if (intent?.action != ACTION_STOP && !hasLocationPermission()) {
|
||||||
|
stopSelf()
|
||||||
|
return START_NOT_STICKY
|
||||||
|
}
|
||||||
|
|
||||||
when (intent?.action) {
|
when (intent?.action) {
|
||||||
ACTION_STOP -> {
|
ACTION_STOP -> {
|
||||||
val requestedRouteId = intent.getStringExtra(EXTRA_ROUTE_ID)
|
val requestedRouteId = intent.getStringExtra(EXTRA_ROUTE_ID)
|
||||||
@@ -69,7 +75,9 @@ class ActiveRouteTrackingService : Service(), LocationListener {
|
|||||||
routeId = id
|
routeId = id
|
||||||
arrived = true
|
arrived = true
|
||||||
runCatching { locationManager.removeUpdates(this) }
|
runCatching { locationManager.removeUpdates(this) }
|
||||||
startForegroundCompat(buildNotification())
|
if (!startForegroundCompat(buildNotification())) {
|
||||||
|
return START_NOT_STICKY
|
||||||
|
}
|
||||||
}
|
}
|
||||||
return START_NOT_STICKY
|
return START_NOT_STICKY
|
||||||
}
|
}
|
||||||
@@ -97,7 +105,9 @@ class ActiveRouteTrackingService : Service(), LocationListener {
|
|||||||
?: totalDistanceMeters
|
?: totalDistanceMeters
|
||||||
progressEnabled = intent?.getBooleanExtra(EXTRA_PROGRESS_ENABLED, true) ?: progressEnabled
|
progressEnabled = intent?.getBooleanExtra(EXTRA_PROGRESS_ENABLED, true) ?: progressEnabled
|
||||||
if (routeChanged) arrived = false
|
if (routeChanged) arrived = false
|
||||||
startForegroundCompat(buildNotification())
|
if (!startForegroundCompat(buildNotification())) {
|
||||||
|
return START_NOT_STICKY
|
||||||
|
}
|
||||||
if (!arrived) requestLocationUpdates()
|
if (!arrived) requestLocationUpdates()
|
||||||
return START_NOT_STICKY
|
return START_NOT_STICKY
|
||||||
}
|
}
|
||||||
@@ -113,9 +123,9 @@ class ActiveRouteTrackingService : Service(), LocationListener {
|
|||||||
if (!arrived && remaining != null && remaining <= arrivalRadiusMeters(location)) {
|
if (!arrived && remaining != null && remaining <= arrivalRadiusMeters(location)) {
|
||||||
arrived = true
|
arrived = true
|
||||||
runCatching { locationManager.removeUpdates(this) }
|
runCatching { locationManager.removeUpdates(this) }
|
||||||
startForegroundCompat(buildNotification())
|
if (!startForegroundCompat(buildNotification())) return
|
||||||
} else {
|
} else {
|
||||||
startForegroundCompat(buildNotification())
|
if (!startForegroundCompat(buildNotification())) return
|
||||||
}
|
}
|
||||||
|
|
||||||
val (battery, charging) = batterySnapshot()
|
val (battery, charging) = batterySnapshot()
|
||||||
@@ -151,6 +161,7 @@ class ActiveRouteTrackingService : Service(), LocationListener {
|
|||||||
super.onDestroy()
|
super.onDestroy()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@SuppressLint("MissingPermission")
|
||||||
private fun requestLocationUpdates() {
|
private fun requestLocationUpdates() {
|
||||||
if (!hasLocationPermission() || routeId.isNullOrBlank() || driverId.isNullOrBlank()) {
|
if (!hasLocationPermission() || routeId.isNullOrBlank() || driverId.isNullOrBlank()) {
|
||||||
return
|
return
|
||||||
@@ -204,12 +215,26 @@ class ActiveRouteTrackingService : Service(), LocationListener {
|
|||||||
return builder.build()
|
return builder.build()
|
||||||
}
|
}
|
||||||
|
|
||||||
private fun startForegroundCompat(notification: Notification) {
|
private fun startForegroundCompat(notification: Notification): Boolean {
|
||||||
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.Q && hasLocationPermission()) {
|
if (!hasLocationPermission()) {
|
||||||
|
stopSelf()
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
|
||||||
|
return try {
|
||||||
|
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.Q) {
|
||||||
startForeground(NOTIFICATION_ID, notification, ServiceInfo.FOREGROUND_SERVICE_TYPE_LOCATION)
|
startForeground(NOTIFICATION_ID, notification, ServiceInfo.FOREGROUND_SERVICE_TYPE_LOCATION)
|
||||||
} else {
|
} else {
|
||||||
startForeground(NOTIFICATION_ID, notification)
|
startForeground(NOTIFICATION_ID, notification)
|
||||||
}
|
}
|
||||||
|
true
|
||||||
|
} catch (_: SecurityException) {
|
||||||
|
stopSelf()
|
||||||
|
false
|
||||||
|
} catch (_: IllegalStateException) {
|
||||||
|
stopSelf()
|
||||||
|
false
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private fun ensureNotificationChannel() {
|
private fun ensureNotificationChannel() {
|
||||||
@@ -220,7 +245,7 @@ class ActiveRouteTrackingService : Service(), LocationListener {
|
|||||||
"Aktywny kurs",
|
"Aktywny kurs",
|
||||||
NotificationManager.IMPORTANCE_LOW,
|
NotificationManager.IMPORTANCE_LOW,
|
||||||
).apply {
|
).apply {
|
||||||
description = "Postęp aktywnego kursu i lokalizacja w tle"
|
description = "Informacje o aktywnym kursie"
|
||||||
}
|
}
|
||||||
manager.createNotificationChannel(channel)
|
manager.createNotificationChannel(channel)
|
||||||
}
|
}
|
||||||
@@ -299,6 +324,8 @@ class ActiveRouteTrackingService : Service(), LocationListener {
|
|||||||
private const val ACTIVE_ROUTE_ID = "active_route_id"
|
private const val ACTIVE_ROUTE_ID = "active_route_id"
|
||||||
|
|
||||||
fun start(context: Context, route: DriverRouteDto, driver: DriverDto, progressEnabled: Boolean = true) {
|
fun start(context: Context, route: DriverRouteDto, driver: DriverDto, progressEnabled: Boolean = true) {
|
||||||
|
if (!hasLocationPermission(context)) return
|
||||||
|
|
||||||
val intent = Intent(context, ActiveRouteTrackingService::class.java).apply {
|
val intent = Intent(context, ActiveRouteTrackingService::class.java).apply {
|
||||||
action = ACTION_START
|
action = ACTION_START
|
||||||
putExtra(EXTRA_ROUTE_ID, route.id)
|
putExtra(EXTRA_ROUTE_ID, route.id)
|
||||||
@@ -309,7 +336,7 @@ class ActiveRouteTrackingService : Service(), LocationListener {
|
|||||||
route.destinationNavigation?.longitude?.let { putExtra(EXTRA_DESTINATION_LON, it) }
|
route.destinationNavigation?.longitude?.let { putExtra(EXTRA_DESTINATION_LON, it) }
|
||||||
route.distanceKm?.takeIf { it > 0.0 }?.let { putExtra(EXTRA_TOTAL_DISTANCE_METERS, it * 1000.0) }
|
route.distanceKm?.takeIf { it > 0.0 }?.let { putExtra(EXTRA_TOTAL_DISTANCE_METERS, it * 1000.0) }
|
||||||
}
|
}
|
||||||
ContextCompat.startForegroundService(context, intent)
|
runCatching { ContextCompat.startForegroundService(context, intent) }
|
||||||
}
|
}
|
||||||
|
|
||||||
fun stop(context: Context, routeId: String? = null) {
|
fun stop(context: Context, routeId: String? = null) {
|
||||||
@@ -325,11 +352,20 @@ class ActiveRouteTrackingService : Service(), LocationListener {
|
|||||||
}
|
}
|
||||||
|
|
||||||
fun markArrived(context: Context, routeId: String) {
|
fun markArrived(context: Context, routeId: String) {
|
||||||
|
if (!hasLocationPermission(context)) return
|
||||||
|
val activeRouteId = context.getSharedPreferences(TRACKING_PREFERENCES, Context.MODE_PRIVATE)
|
||||||
|
.getString(ACTIVE_ROUTE_ID, null)
|
||||||
|
if (activeRouteId != routeId) return
|
||||||
|
|
||||||
val intent = Intent(context, ActiveRouteTrackingService::class.java).apply {
|
val intent = Intent(context, ActiveRouteTrackingService::class.java).apply {
|
||||||
action = ACTION_MARK_ARRIVED
|
action = ACTION_MARK_ARRIVED
|
||||||
putExtra(EXTRA_ROUTE_ID, routeId)
|
putExtra(EXTRA_ROUTE_ID, routeId)
|
||||||
}
|
}
|
||||||
ContextCompat.startForegroundService(context, intent)
|
runCatching { ContextCompat.startForegroundService(context, intent) }
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private fun hasLocationPermission(context: Context): Boolean =
|
||||||
|
ContextCompat.checkSelfPermission(context, Manifest.permission.ACCESS_FINE_LOCATION) == PackageManager.PERMISSION_GRANTED ||
|
||||||
|
ContextCompat.checkSelfPermission(context, Manifest.permission.ACCESS_COARSE_LOCATION) == PackageManager.PERMISSION_GRANTED
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
File diff suppressed because it is too large
Load Diff
@@ -22,13 +22,20 @@ internal val routeActionVisibleStatuses = setOf(
|
|||||||
RouteActionStatus.FailedPermanent,
|
RouteActionStatus.FailedPermanent,
|
||||||
)
|
)
|
||||||
|
|
||||||
private val routeActionProjectionStatuses = routeActionVisibleStatuses + RouteActionStatus.Confirmed
|
private val routeActionDataProjectionStatuses = routeActionVisibleStatuses + RouteActionStatus.Confirmed
|
||||||
|
private val routeActionLifecycleProjectionStatuses = setOf(
|
||||||
|
RouteActionStatus.Pending,
|
||||||
|
RouteActionStatus.WaitingForPhotos,
|
||||||
|
RouteActionStatus.Syncing,
|
||||||
|
RouteActionStatus.FailedRetryable,
|
||||||
|
RouteActionStatus.Confirmed,
|
||||||
|
)
|
||||||
|
|
||||||
fun projectDriverRoute(route: DriverRouteDto, actions: List<RouteActionEntity>): ProjectedDriverRoute {
|
fun projectDriverRoute(route: DriverRouteDto, actions: List<RouteActionEntity>): ProjectedDriverRoute {
|
||||||
val visible = actions
|
val visible = actions
|
||||||
.filter { it.routeId == route.id && it.status in routeActionVisibleStatuses }
|
.filter { it.routeId == route.id && it.status in routeActionVisibleStatuses }
|
||||||
val projectable = actions
|
val projectable = actions
|
||||||
.filter { it.routeId == route.id && it.status in routeActionProjectionStatuses }
|
.filter { it.routeId == route.id && it.status in routeActionDataProjectionStatuses }
|
||||||
var projectedRoute = route
|
var projectedRoute = route
|
||||||
var loadingWeightPending = false
|
var loadingWeightPending = false
|
||||||
var unloadingWeightPending = false
|
var unloadingWeightPending = false
|
||||||
@@ -39,25 +46,33 @@ fun projectDriverRoute(route: DriverRouteDto, actions: List<RouteActionEntity>):
|
|||||||
when (action.action) {
|
when (action.action) {
|
||||||
RouteActionType.Start -> {
|
RouteActionType.Start -> {
|
||||||
projectedRoute = projectedRoute.copy(
|
projectedRoute = projectedRoute.copy(
|
||||||
status = "W TRAKCIE",
|
|
||||||
driverStatus = "W TRAKCIE",
|
|
||||||
loadingWeight = action.weight,
|
loadingWeight = action.weight,
|
||||||
loadingNotes = action.notes,
|
loadingNotes = action.notes,
|
||||||
trackingStatus = "active",
|
|
||||||
photos = projectedRoute.safePhotos(),
|
photos = projectedRoute.safePhotos(),
|
||||||
)
|
)
|
||||||
|
if (action.status in routeActionLifecycleProjectionStatuses) {
|
||||||
|
projectedRoute = projectedRoute.copy(
|
||||||
|
status = "W TRAKCIE",
|
||||||
|
driverStatus = "W TRAKCIE",
|
||||||
|
trackingStatus = "active",
|
||||||
|
)
|
||||||
|
}
|
||||||
loadingWeightPending = action.status != RouteActionStatus.Confirmed
|
loadingWeightPending = action.status != RouteActionStatus.Confirmed
|
||||||
}
|
}
|
||||||
RouteActionType.Finish -> {
|
RouteActionType.Finish -> {
|
||||||
projectedRoute = projectedRoute.copy(
|
projectedRoute = projectedRoute.copy(
|
||||||
status = "ZAKOŃCZONA",
|
|
||||||
driverStatus = "ZAKOŃCZONA",
|
|
||||||
unloadingWeight = action.weight,
|
unloadingWeight = action.weight,
|
||||||
unloadingNotes = action.notes,
|
unloadingNotes = action.notes,
|
||||||
trackingStatus = "finished",
|
|
||||||
completedAt = action.occurredAt,
|
|
||||||
photos = projectedRoute.safePhotos(),
|
photos = projectedRoute.safePhotos(),
|
||||||
)
|
)
|
||||||
|
if (action.status in routeActionLifecycleProjectionStatuses) {
|
||||||
|
projectedRoute = projectedRoute.copy(
|
||||||
|
status = "ZAKOŃCZONA",
|
||||||
|
driverStatus = "ZAKOŃCZONA",
|
||||||
|
trackingStatus = "finished",
|
||||||
|
completedAt = action.occurredAt,
|
||||||
|
)
|
||||||
|
}
|
||||||
unloadingWeightPending = action.status != RouteActionStatus.Confirmed
|
unloadingWeightPending = action.status != RouteActionStatus.Confirmed
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -14,6 +14,8 @@ import kotlin.math.abs
|
|||||||
import pl.firmatpp.kierowca.data.model.DriverRouteDto
|
import pl.firmatpp.kierowca.data.model.DriverRouteDto
|
||||||
import pl.firmatpp.kierowca.data.model.DispatchSheetReminderDto
|
import pl.firmatpp.kierowca.data.model.DispatchSheetReminderDto
|
||||||
import pl.firmatpp.kierowca.data.model.RoutePhotoDto
|
import pl.firmatpp.kierowca.data.model.RoutePhotoDto
|
||||||
|
import pl.firmatpp.kierowca.data.model.TachographReminderDto
|
||||||
|
import pl.firmatpp.kierowca.data.model.TachographReminderTaskDto
|
||||||
import pl.firmatpp.kierowca.data.model.driverLifecycleStatus
|
import pl.firmatpp.kierowca.data.model.driverLifecycleStatus
|
||||||
import pl.firmatpp.kierowca.data.upload.PhotoUploadEntity
|
import pl.firmatpp.kierowca.data.upload.PhotoUploadEntity
|
||||||
import pl.firmatpp.kierowca.data.upload.PhotoUploadStatus
|
import pl.firmatpp.kierowca.data.upload.PhotoUploadStatus
|
||||||
@@ -40,6 +42,42 @@ data class AppUpdateBannerUi(
|
|||||||
val downloaded: Boolean,
|
val downloaded: Boolean,
|
||||||
)
|
)
|
||||||
|
|
||||||
|
object RouteLocationMode {
|
||||||
|
const val Disabled = "disabled"
|
||||||
|
const val Optional = "optional"
|
||||||
|
const val Required = "required"
|
||||||
|
}
|
||||||
|
|
||||||
|
fun normalizeRouteLocationMode(value: String?): String = when (value) {
|
||||||
|
RouteLocationMode.Disabled,
|
||||||
|
RouteLocationMode.Required,
|
||||||
|
-> value
|
||||||
|
else -> RouteLocationMode.Optional
|
||||||
|
}
|
||||||
|
|
||||||
|
fun shouldTrackRouteLocation(
|
||||||
|
mode: String,
|
||||||
|
optionalLocationEnabled: Boolean,
|
||||||
|
hasLocationPermission: Boolean,
|
||||||
|
): Boolean = hasLocationPermission && when (normalizeRouteLocationMode(mode)) {
|
||||||
|
RouteLocationMode.Disabled -> false
|
||||||
|
RouteLocationMode.Required -> true
|
||||||
|
else -> optionalLocationEnabled
|
||||||
|
}
|
||||||
|
|
||||||
|
fun routeStartRequiresLocationPermission(
|
||||||
|
mode: String,
|
||||||
|
hasLocationPermission: Boolean,
|
||||||
|
): Boolean = normalizeRouteLocationMode(mode) == RouteLocationMode.Required && !hasLocationPermission
|
||||||
|
|
||||||
|
fun shouldWarnAboutRequiredRouteLocation(
|
||||||
|
mode: String,
|
||||||
|
hasActiveRoute: Boolean,
|
||||||
|
hasLocationPermission: Boolean,
|
||||||
|
): Boolean = normalizeRouteLocationMode(mode) == RouteLocationMode.Required &&
|
||||||
|
hasActiveRoute &&
|
||||||
|
!hasLocationPermission
|
||||||
|
|
||||||
fun appUpdateBannerUi(
|
fun appUpdateBannerUi(
|
||||||
currentVersionCode: Int,
|
currentVersionCode: Int,
|
||||||
latestVersionCode: Int?,
|
latestVersionCode: Int?,
|
||||||
@@ -635,6 +673,16 @@ fun canLaunchCameraWithLocationPolicy(requirePreciseLocation: Boolean, hasFineLo
|
|||||||
fun shouldShowDispatchSheetReminderCard(reminder: DispatchSheetReminderDto?): Boolean =
|
fun shouldShowDispatchSheetReminderCard(reminder: DispatchSheetReminderDto?): Boolean =
|
||||||
reminder?.dueToday == true && reminder.status in setOf("missing", "uploaded")
|
reminder?.dueToday == true && reminder.status in setOf("missing", "uploaded")
|
||||||
|
|
||||||
|
fun shouldShowTachographReminderCard(reminder: TachographReminderDto?): Boolean =
|
||||||
|
reminder?.enabled == true &&
|
||||||
|
reminder.visible &&
|
||||||
|
!reminder.title.isNullOrBlank() &&
|
||||||
|
!reminder.message.isNullOrBlank() &&
|
||||||
|
!reminder.tasks.isNullOrEmpty()
|
||||||
|
|
||||||
|
fun defaultTachographConfirmationSelection(tasks: List<TachographReminderTaskDto>): Set<String> =
|
||||||
|
if (tasks.size == 1) setOf(tasks.single().id) else emptySet()
|
||||||
|
|
||||||
fun dispatchSheetPrimaryActionLabel(reminder: DispatchSheetReminderDto?, hasQueuedUpload: Boolean): String =
|
fun dispatchSheetPrimaryActionLabel(reminder: DispatchSheetReminderDto?, hasQueuedUpload: Boolean): String =
|
||||||
when {
|
when {
|
||||||
hasQueuedUpload -> "Wysyłam zdjęcie..."
|
hasQueuedUpload -> "Wysyłam zdjęcie..."
|
||||||
|
|||||||
@@ -1,7 +1,10 @@
|
|||||||
package pl.firmatpp.kierowca.ui
|
package pl.firmatpp.kierowca.ui
|
||||||
|
|
||||||
|
import android.Manifest
|
||||||
import android.app.Application
|
import android.app.Application
|
||||||
|
import android.content.pm.PackageManager
|
||||||
import android.net.Uri
|
import android.net.Uri
|
||||||
|
import androidx.core.content.ContextCompat
|
||||||
import androidx.lifecycle.AndroidViewModel
|
import androidx.lifecycle.AndroidViewModel
|
||||||
import androidx.lifecycle.viewModelScope
|
import androidx.lifecycle.viewModelScope
|
||||||
import com.google.firebase.messaging.FirebaseMessaging
|
import com.google.firebase.messaging.FirebaseMessaging
|
||||||
@@ -20,6 +23,7 @@ import pl.firmatpp.kierowca.data.ApiErrorMapper
|
|||||||
import pl.firmatpp.kierowca.data.ApiErrorKind
|
import pl.firmatpp.kierowca.data.ApiErrorKind
|
||||||
import pl.firmatpp.kierowca.data.DriverRepository
|
import pl.firmatpp.kierowca.data.DriverRepository
|
||||||
import pl.firmatpp.kierowca.data.PhotoUploadMetadata
|
import pl.firmatpp.kierowca.data.PhotoUploadMetadata
|
||||||
|
import pl.firmatpp.kierowca.data.rethrowIfCancellation
|
||||||
import pl.firmatpp.kierowca.data.sync.DriverSyncRepository
|
import pl.firmatpp.kierowca.data.sync.DriverSyncRepository
|
||||||
import pl.firmatpp.kierowca.data.sync.NetworkMonitor
|
import pl.firmatpp.kierowca.data.sync.NetworkMonitor
|
||||||
import pl.firmatpp.kierowca.data.sync.StartupOfflineFallbackLoader
|
import pl.firmatpp.kierowca.data.sync.StartupOfflineFallbackLoader
|
||||||
@@ -30,6 +34,7 @@ import pl.firmatpp.kierowca.data.model.DriverLeaveCalendarEntryDto
|
|||||||
import pl.firmatpp.kierowca.data.model.DriverLeaveRequestDto
|
import pl.firmatpp.kierowca.data.model.DriverLeaveRequestDto
|
||||||
import pl.firmatpp.kierowca.data.model.DriverRouteDto
|
import pl.firmatpp.kierowca.data.model.DriverRouteDto
|
||||||
import pl.firmatpp.kierowca.data.model.RoutePhotoDto
|
import pl.firmatpp.kierowca.data.model.RoutePhotoDto
|
||||||
|
import pl.firmatpp.kierowca.data.model.TachographReminderDto
|
||||||
import pl.firmatpp.kierowca.data.model.driverLifecycleStatus
|
import pl.firmatpp.kierowca.data.model.driverLifecycleStatus
|
||||||
import pl.firmatpp.kierowca.data.upload.DispatchSheetUploadEntity
|
import pl.firmatpp.kierowca.data.upload.DispatchSheetUploadEntity
|
||||||
import pl.firmatpp.kierowca.data.upload.DispatchSheetUploadOutbox
|
import pl.firmatpp.kierowca.data.upload.DispatchSheetUploadOutbox
|
||||||
@@ -81,6 +86,8 @@ data class DriverUiState(
|
|||||||
val allowGalleryUploads: Boolean = true,
|
val allowGalleryUploads: Boolean = true,
|
||||||
val allowRouteCompletion: Boolean = false,
|
val allowRouteCompletion: Boolean = false,
|
||||||
val requirePreciseLocationForPhotos: Boolean = false,
|
val requirePreciseLocationForPhotos: Boolean = false,
|
||||||
|
val routeLocationMode: String = RouteLocationMode.Optional,
|
||||||
|
val routeLocationEnabled: Boolean = false,
|
||||||
val loadingPhotoRequirement: String = RouteStageRequirement.Required,
|
val loadingPhotoRequirement: String = RouteStageRequirement.Required,
|
||||||
val loadingWeightRequirement: String = RouteStageRequirement.Required,
|
val loadingWeightRequirement: String = RouteStageRequirement.Required,
|
||||||
val unloadingPhotoRequirement: String = RouteStageRequirement.Required,
|
val unloadingPhotoRequirement: String = RouteStageRequirement.Required,
|
||||||
@@ -97,6 +104,8 @@ data class DriverUiState(
|
|||||||
val photoUploads: List<PhotoUploadEntity> = emptyList(),
|
val photoUploads: List<PhotoUploadEntity> = emptyList(),
|
||||||
val queuedPhotoUploads: List<PhotoUploadEntity> = emptyList(),
|
val queuedPhotoUploads: List<PhotoUploadEntity> = emptyList(),
|
||||||
val dispatchSheetReminder: DispatchSheetReminderDto? = null,
|
val dispatchSheetReminder: DispatchSheetReminderDto? = null,
|
||||||
|
val tachographReminder: TachographReminderDto? = null,
|
||||||
|
val tachographReminderSubmitting: Boolean = false,
|
||||||
val appUpdate: AppUpdateDto? = null,
|
val appUpdate: AppUpdateDto? = null,
|
||||||
val dispatchSheetUploads: List<DispatchSheetUploadEntity> = emptyList(),
|
val dispatchSheetUploads: List<DispatchSheetUploadEntity> = emptyList(),
|
||||||
val leaveRequestsConfig: LeaveRequestsConfig? = null,
|
val leaveRequestsConfig: LeaveRequestsConfig? = null,
|
||||||
@@ -194,6 +203,30 @@ internal fun DriverUiState.withLoadedLeaveRequests(
|
|||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
internal fun shouldStartRoutesLoad(
|
||||||
|
screen: DriverScreen,
|
||||||
|
navigateToRoutes: Boolean,
|
||||||
|
startupOfflineOnly: Boolean,
|
||||||
|
startupLoadInProgress: Boolean = false,
|
||||||
|
): Boolean =
|
||||||
|
(!startupLoadInProgress || navigateToRoutes || startupOfflineOnly) &&
|
||||||
|
(screen != DriverScreen.Initializing || navigateToRoutes || startupOfflineOnly)
|
||||||
|
|
||||||
|
internal fun screenAfterBootstrap(
|
||||||
|
currentScreen: DriverScreen,
|
||||||
|
navigateToRoutes: Boolean,
|
||||||
|
leaveRequestsEnabled: Boolean,
|
||||||
|
): DriverScreen = when {
|
||||||
|
currentScreen == DriverScreen.Initializing -> DriverScreen.Routes
|
||||||
|
!leaveRequestsEnabled && currentScreen in setOf(
|
||||||
|
DriverScreen.LeaveRequests,
|
||||||
|
DriverScreen.LeaveRequestDetail,
|
||||||
|
DriverScreen.AddLeaveRequest,
|
||||||
|
) -> DriverScreen.Routes
|
||||||
|
navigateToRoutes -> DriverScreen.Routes
|
||||||
|
else -> currentScreen
|
||||||
|
}
|
||||||
|
|
||||||
class DriverViewModel(application: Application) : AndroidViewModel(application) {
|
class DriverViewModel(application: Application) : AndroidViewModel(application) {
|
||||||
private val appPreferencesStore = AppPreferencesStore(application)
|
private val appPreferencesStore = AppPreferencesStore(application)
|
||||||
private val repository = DriverRepository(application)
|
private val repository = DriverRepository(application)
|
||||||
@@ -228,6 +261,7 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
|
|||||||
private var routesRequestGeneration: Long = 0
|
private var routesRequestGeneration: Long = 0
|
||||||
private var routeDetailRequestGeneration: Long = 0
|
private var routeDetailRequestGeneration: Long = 0
|
||||||
private var routesLoadJob: Job? = null
|
private var routesLoadJob: Job? = null
|
||||||
|
private var startupLoadInProgress: Boolean = false
|
||||||
val state: StateFlow<DriverUiState> = _state
|
val state: StateFlow<DriverUiState> = _state
|
||||||
|
|
||||||
init {
|
init {
|
||||||
@@ -241,6 +275,12 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
|
|||||||
_state.update { it.copy(routeProgressNotificationEnabled = enabled) }
|
_state.update { it.copy(routeProgressNotificationEnabled = enabled) }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
viewModelScope.launch {
|
||||||
|
appPreferencesStore.routeLocationEnabled.collect { enabled ->
|
||||||
|
_state.update { it.copy(routeLocationEnabled = enabled) }
|
||||||
|
reconcileTrackingServiceFromState()
|
||||||
|
}
|
||||||
|
}
|
||||||
viewModelScope.launch {
|
viewModelScope.launch {
|
||||||
photoUploadOutbox.observeQueuedUploads().collect { uploads ->
|
photoUploadOutbox.observeQueuedUploads().collect { uploads ->
|
||||||
_state.update { it.copy(queuedPhotoUploads = uploads) }
|
_state.update { it.copy(queuedPhotoUploads = uploads) }
|
||||||
@@ -459,6 +499,39 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
|
|||||||
loadRoutes(date = date, showLoading = true, navigateToRoutes = true)
|
loadRoutes(date = date, showLoading = true, navigateToRoutes = true)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fun acknowledgeTachographReminder(taskIds: List<String>) {
|
||||||
|
val snapshot = _state.value
|
||||||
|
if (taskIds.isEmpty() || snapshot.tachographReminderSubmitting) return
|
||||||
|
if (!snapshot.isOnline) {
|
||||||
|
_state.update { it.copy(error = "Potwierdzenie odczytu wymaga połączenia z internetem.") }
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
viewModelScope.launch {
|
||||||
|
_state.update {
|
||||||
|
it.copy(
|
||||||
|
tachographReminderSubmitting = true,
|
||||||
|
error = null,
|
||||||
|
feedback = null,
|
||||||
|
)
|
||||||
|
}
|
||||||
|
runCatching { repository.acknowledgeTachographReminder(taskIds) }
|
||||||
|
.onSuccess { reminder ->
|
||||||
|
_state.update {
|
||||||
|
it.copy(
|
||||||
|
tachographReminder = reminder,
|
||||||
|
feedback = "Zapisano potwierdzenie odczytu.",
|
||||||
|
error = null,
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
.onFailure { throwable ->
|
||||||
|
_state.update { it.withApiError(throwable) }
|
||||||
|
}
|
||||||
|
_state.update { it.copy(tachographReminderSubmitting = false) }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
fun dismissRouteDayLiveUpdate() {
|
fun dismissRouteDayLiveUpdate() {
|
||||||
_state.update { it.copy(routeDayLiveUpdateMessage = null) }
|
_state.update { it.copy(routeDayLiveUpdateMessage = null) }
|
||||||
}
|
}
|
||||||
@@ -469,24 +542,35 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
|
|||||||
navigateToRoutes: Boolean,
|
navigateToRoutes: Boolean,
|
||||||
startupOfflineOnly: Boolean = false,
|
startupOfflineOnly: Boolean = false,
|
||||||
) {
|
) {
|
||||||
|
val requestSnapshot = _state.value
|
||||||
|
if (!shouldStartRoutesLoad(
|
||||||
|
screen = requestSnapshot.screen,
|
||||||
|
navigateToRoutes = navigateToRoutes,
|
||||||
|
startupOfflineOnly = startupOfflineOnly,
|
||||||
|
startupLoadInProgress = startupLoadInProgress,
|
||||||
|
)
|
||||||
|
) {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
val isStartup = requestSnapshot.screen == DriverScreen.Initializing
|
||||||
|
if (isStartup) startupLoadInProgress = true
|
||||||
val generation = ++routesRequestGeneration
|
val generation = ++routesRequestGeneration
|
||||||
routesLoadJob?.cancel()
|
routesLoadJob?.cancel()
|
||||||
routesLoadJob = viewModelScope.launch {
|
val loadJob = viewModelScope.launch {
|
||||||
val isStartup = _state.value.screen == DriverScreen.Initializing
|
|
||||||
_state.update { it.copy(loading = showLoading, refreshing = !showLoading, feedback = null, error = null) }
|
_state.update { it.copy(loading = showLoading, refreshing = !showLoading, feedback = null, error = null) }
|
||||||
|
|
||||||
runCatching {
|
runCatching {
|
||||||
val cached = when {
|
val cached = when {
|
||||||
startupOfflineOnly -> syncRepository.bootstrapFromCache(date)
|
startupOfflineOnly -> syncRepository.bootstrapFromCache(date)
|
||||||
?: throw IOException("Brak zapisanych danych dla wybranego dnia.")
|
?: throw IOException("Brak zapisanych danych dla wybranego dnia.")
|
||||||
!_state.value.isOnline -> syncRepository.bootstrapFromCache(date)
|
|
||||||
?: throw IOException("Brak zapisanych danych dla wybranego dnia.")
|
|
||||||
isStartup -> {
|
isStartup -> {
|
||||||
startupOfflineFallbackLoader.load(
|
startupOfflineFallbackLoader.load(
|
||||||
onlineLoad = { syncRepository.bootstrap(date) },
|
onlineLoad = { syncRepository.bootstrap(date) },
|
||||||
offlineLoad = { syncRepository.bootstrapFromCache(date) },
|
offlineLoad = { syncRepository.bootstrapFromCache(date) },
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
!_state.value.isOnline -> syncRepository.bootstrapFromCache(date)
|
||||||
|
?: throw IOException("Brak zapisanych danych dla wybranego dnia.")
|
||||||
else -> syncRepository.bootstrap(date)
|
else -> syncRepository.bootstrap(date)
|
||||||
}
|
}
|
||||||
val response = cached.value
|
val response = cached.value
|
||||||
@@ -498,6 +582,7 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
|
|||||||
driver = response.session.driver,
|
driver = response.session.driver,
|
||||||
routes = response.routes.today,
|
routes = response.routes.today,
|
||||||
dispatchSheetReminder = response.dispatchSheetReminder,
|
dispatchSheetReminder = response.dispatchSheetReminder,
|
||||||
|
tachographReminder = response.tachographReminder,
|
||||||
appUpdate = response.appUpdate ?: it.appUpdate,
|
appUpdate = response.appUpdate ?: it.appUpdate,
|
||||||
selectedDate = settings?.selectedDate ?: date ?: it.selectedDate,
|
selectedDate = settings?.selectedDate ?: date ?: it.selectedDate,
|
||||||
minRouteDate = settings?.minDate ?: it.minRouteDate,
|
minRouteDate = settings?.minDate ?: it.minRouteDate,
|
||||||
@@ -507,6 +592,7 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
|
|||||||
allowRouteCompletion = settings?.allowRouteCompletion ?: it.allowRouteCompletion,
|
allowRouteCompletion = settings?.allowRouteCompletion ?: it.allowRouteCompletion,
|
||||||
requirePreciseLocationForPhotos = settings?.requirePreciseLocationForPhotos
|
requirePreciseLocationForPhotos = settings?.requirePreciseLocationForPhotos
|
||||||
?: it.requirePreciseLocationForPhotos,
|
?: it.requirePreciseLocationForPhotos,
|
||||||
|
routeLocationMode = normalizeRouteLocationMode(settings?.routeLocationMode),
|
||||||
loadingPhotoRequirement = normalizeRouteStageRequirement(settings?.loadingPhotoRequirement),
|
loadingPhotoRequirement = normalizeRouteStageRequirement(settings?.loadingPhotoRequirement),
|
||||||
loadingWeightRequirement = normalizeRouteStageRequirement(settings?.loadingWeightRequirement),
|
loadingWeightRequirement = normalizeRouteStageRequirement(settings?.loadingWeightRequirement),
|
||||||
unloadingPhotoRequirement = normalizeRouteStageRequirement(settings?.unloadingPhotoRequirement),
|
unloadingPhotoRequirement = normalizeRouteStageRequirement(settings?.unloadingPhotoRequirement),
|
||||||
@@ -514,10 +600,11 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
|
|||||||
leaveRequestsConfig = settings?.leaveRequests?.let { config ->
|
leaveRequestsConfig = settings?.leaveRequests?.let { config ->
|
||||||
LeaveRequestsConfig(enabled = config.enabled, types = config.types)
|
LeaveRequestsConfig(enabled = config.enabled, types = config.types)
|
||||||
},
|
},
|
||||||
screen = if (
|
screen = screenAfterBootstrap(
|
||||||
settings?.leaveRequests?.enabled != true &&
|
currentScreen = it.screen,
|
||||||
it.screen in setOf(DriverScreen.LeaveRequests, DriverScreen.LeaveRequestDetail, DriverScreen.AddLeaveRequest)
|
navigateToRoutes = navigateToRoutes,
|
||||||
) DriverScreen.Routes else if (navigateToRoutes) DriverScreen.Routes else it.screen,
|
leaveRequestsEnabled = settings?.leaveRequests?.enabled == true,
|
||||||
|
),
|
||||||
notifyNewRoutes = response.notificationPreferences?.notifyNewRoutes ?: it.notifyNewRoutes,
|
notifyNewRoutes = response.notificationPreferences?.notifyNewRoutes ?: it.notifyNewRoutes,
|
||||||
imageAuthHeader = repository.imageAuthHeader(),
|
imageAuthHeader = repository.imageAuthHeader(),
|
||||||
isStale = cached.stale || !it.isOnline,
|
isStale = cached.stale || !it.isOnline,
|
||||||
@@ -531,10 +618,20 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
|
|||||||
if (_state.value.isOnline && !cached.stale) registerPushTokenIfAvailable(driverId)
|
if (_state.value.isOnline && !cached.stale) registerPushTokenIfAvailable(driverId)
|
||||||
}
|
}
|
||||||
observeDispatchSheetUploads(response.dispatchSheetReminder?.workDate)
|
observeDispatchSheetUploads(response.dispatchSheetReminder?.workDate)
|
||||||
if (_state.value.isOnline && !cached.stale && settings?.selectedDate == settings?.today) {
|
val trackingSnapshot = _state.value
|
||||||
|
if (
|
||||||
|
!shouldTrackRouteLocation(
|
||||||
|
trackingSnapshot.routeLocationMode,
|
||||||
|
trackingSnapshot.routeLocationEnabled,
|
||||||
|
hasLocationPermission(),
|
||||||
|
)
|
||||||
|
) {
|
||||||
|
ActiveRouteTrackingService.stop(getApplication())
|
||||||
|
} else if (trackingSnapshot.isOnline && !cached.stale && settings?.selectedDate == settings?.today) {
|
||||||
reconcileTrackingService(response.routes.today, response.session.driver)
|
reconcileTrackingService(response.routes.today, response.session.driver)
|
||||||
}
|
}
|
||||||
}.onFailure { throwable ->
|
}.onFailure { throwable ->
|
||||||
|
throwable.rethrowIfCancellation()
|
||||||
if (generation != routesRequestGeneration) return@onFailure
|
if (generation != routesRequestGeneration) return@onFailure
|
||||||
reportHandledException("load_routes", throwable, mapOf("date" to date))
|
reportHandledException("load_routes", throwable, mapOf("date" to date))
|
||||||
if (ApiErrorMapper.map(throwable).kind == ApiErrorKind.Auth) {
|
if (ApiErrorMapper.map(throwable).kind == ApiErrorKind.Auth) {
|
||||||
@@ -552,6 +649,14 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
|
|||||||
it.copy(loading = false, refreshing = false)
|
it.copy(loading = false, refreshing = false)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
routesLoadJob = loadJob
|
||||||
|
if (isStartup) {
|
||||||
|
loadJob.invokeOnCompletion {
|
||||||
|
if (generation == routesRequestGeneration) {
|
||||||
|
startupLoadInProgress = false
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
fun openRoute(routeId: String) = openRouteWithTarget(routeId, DriverScreen.Detail)
|
fun openRoute(routeId: String) = openRouteWithTarget(routeId, DriverScreen.Detail)
|
||||||
@@ -700,6 +805,8 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
|
|||||||
DiagnosticEntry("Galeria", if (runtime.allowGalleryUploads) "włączona" else "wyłączona"),
|
DiagnosticEntry("Galeria", if (runtime.allowGalleryUploads) "włączona" else "wyłączona"),
|
||||||
DiagnosticEntry("Kończenie kursu", if (runtime.allowRouteCompletion) "włączone" else "wyłączone"),
|
DiagnosticEntry("Kończenie kursu", if (runtime.allowRouteCompletion) "włączone" else "wyłączone"),
|
||||||
DiagnosticEntry("Dokładna lokalizacja zdjęć", if (runtime.requirePreciseLocationForPhotos) "wymagana" else "niewymagana"),
|
DiagnosticEntry("Dokładna lokalizacja zdjęć", if (runtime.requirePreciseLocationForPhotos) "wymagana" else "niewymagana"),
|
||||||
|
DiagnosticEntry("Lokalizacja kursu", runtime.routeLocationMode),
|
||||||
|
DiagnosticEntry("Wybór kierowcy", if (runtime.routeLocationEnabled) "włączony" else "wyłączony"),
|
||||||
DiagnosticEntry("Załadunek, zdjęcie", runtime.loadingPhotoRequirement),
|
DiagnosticEntry("Załadunek, zdjęcie", runtime.loadingPhotoRequirement),
|
||||||
DiagnosticEntry("Załadunek, tonaż", runtime.loadingWeightRequirement),
|
DiagnosticEntry("Załadunek, tonaż", runtime.loadingWeightRequirement),
|
||||||
DiagnosticEntry("Rozładunek, zdjęcie", runtime.unloadingPhotoRequirement),
|
DiagnosticEntry("Rozładunek, zdjęcie", runtime.unloadingPhotoRequirement),
|
||||||
@@ -796,6 +903,36 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fun setRouteLocationEnabled(enabled: Boolean) {
|
||||||
|
if (_state.value.routeLocationMode != RouteLocationMode.Optional) return
|
||||||
|
|
||||||
|
_state.update { it.copy(routeLocationEnabled = enabled, error = null) }
|
||||||
|
reconcileTrackingServiceFromState()
|
||||||
|
viewModelScope.launch {
|
||||||
|
runCatching { appPreferencesStore.setRouteLocationEnabled(enabled) }
|
||||||
|
.onFailure { throwable -> _state.update { it.withApiError(throwable) } }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fun onLocationPermissionGranted() {
|
||||||
|
val snapshot = _state.value
|
||||||
|
val driver = snapshot.driver ?: return
|
||||||
|
if (!shouldTrackRouteLocation(snapshot.routeLocationMode, snapshot.routeLocationEnabled, hasLocationPermission())) {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
val activeRoute = snapshot.displaySelectedRoute
|
||||||
|
?.takeIf { it.driverLifecycleStatus() == "W TRAKCIE" }
|
||||||
|
?: snapshot.displayRoutes.firstOrNull { it.driverLifecycleStatus() == "W TRAKCIE" }
|
||||||
|
?: return
|
||||||
|
|
||||||
|
ActiveRouteTrackingService.start(
|
||||||
|
context = getApplication(),
|
||||||
|
route = activeRoute,
|
||||||
|
driver = driver,
|
||||||
|
progressEnabled = snapshot.routeProgressNotificationEnabled,
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
fun openPhotoQueue() {
|
fun openPhotoQueue() {
|
||||||
_state.update { it.copy(screen = DriverScreen.PhotoQueue, error = null) }
|
_state.update { it.copy(screen = DriverScreen.PhotoQueue, error = null) }
|
||||||
}
|
}
|
||||||
@@ -1107,6 +1244,10 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
|
|||||||
fun openStartRoute() {
|
fun openStartRoute() {
|
||||||
val snapshot = _state.value
|
val snapshot = _state.value
|
||||||
val route = snapshot.selectedRoute ?: return
|
val route = snapshot.selectedRoute ?: return
|
||||||
|
if (routeStartRequiresLocationPermission(snapshot.routeLocationMode, hasLocationPermission())) {
|
||||||
|
_state.update { it.copy(error = "Lokalizacja jest wymagana, aby rozpocząć kurs.") }
|
||||||
|
return
|
||||||
|
}
|
||||||
if (!canStartRouteFromDriverApp(route, snapshot.selectedDate)) {
|
if (!canStartRouteFromDriverApp(route, snapshot.selectedDate)) {
|
||||||
_state.update { it.copy(error = "Załadunek nie jest dostępny poza zaplanowanym zakresem kursu.") }
|
_state.update { it.copy(error = "Załadunek nie jest dostępny poza zaplanowanym zakresem kursu.") }
|
||||||
return
|
return
|
||||||
@@ -1211,6 +1352,30 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fun retryConflictedRouteAction() {
|
||||||
|
val snapshot = _state.value
|
||||||
|
val action = (snapshot.visibleRouteActions + snapshot.routeActions)
|
||||||
|
.distinctBy { it.clientActionId }
|
||||||
|
.filter { it.status == RouteActionStatus.FailedConflict }
|
||||||
|
.maxByOrNull { it.createdAtEpochMillis }
|
||||||
|
?: return
|
||||||
|
|
||||||
|
viewModelScope.launch {
|
||||||
|
runCatching {
|
||||||
|
routeActionOutbox.retry(action.clientActionId)
|
||||||
|
}
|
||||||
|
.onSuccess {
|
||||||
|
_state.update {
|
||||||
|
it.copy(
|
||||||
|
feedback = "Ponawiam wysyłanie zapisanych danych.",
|
||||||
|
error = null,
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
.onFailure { throwable -> _state.update { it.withApiError(throwable) } }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
fun submitStartRoute() {
|
fun submitStartRoute() {
|
||||||
submitRouteStage(stage = "loading")
|
submitRouteStage(stage = "loading")
|
||||||
}
|
}
|
||||||
@@ -1222,6 +1387,10 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
|
|||||||
private fun submitRouteStage(stage: String) {
|
private fun submitRouteStage(stage: String) {
|
||||||
val snapshot = _state.value
|
val snapshot = _state.value
|
||||||
val route = snapshot.selectedRoute ?: return
|
val route = snapshot.selectedRoute ?: return
|
||||||
|
if (stage == "loading" && routeStartRequiresLocationPermission(snapshot.routeLocationMode, hasLocationPermission())) {
|
||||||
|
_state.update { it.copy(error = "Lokalizacja jest wymagana, aby rozpocząć kurs.") }
|
||||||
|
return
|
||||||
|
}
|
||||||
val canSubmitStage = if (stage == "loading") {
|
val canSubmitStage = if (stage == "loading") {
|
||||||
canStartRouteFromDriverApp(route, snapshot.selectedDate)
|
canStartRouteFromDriverApp(route, snapshot.selectedDate)
|
||||||
} else {
|
} else {
|
||||||
@@ -1333,7 +1502,15 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
|
|||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
if (stage == "loading" && driver != null) {
|
if (
|
||||||
|
stage == "loading" &&
|
||||||
|
driver != null &&
|
||||||
|
shouldTrackRouteLocation(
|
||||||
|
snapshot.routeLocationMode,
|
||||||
|
snapshot.routeLocationEnabled,
|
||||||
|
hasLocationPermission(),
|
||||||
|
)
|
||||||
|
) {
|
||||||
ActiveRouteTrackingService.start(
|
ActiveRouteTrackingService.start(
|
||||||
context = getApplication(),
|
context = getApplication(),
|
||||||
route = updatedRoute,
|
route = updatedRoute,
|
||||||
@@ -1597,8 +1774,12 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
|
|||||||
}
|
}
|
||||||
|
|
||||||
private fun reconcileTrackingService(routes: List<DriverRouteDto>, driver: DriverDto) {
|
private fun reconcileTrackingService(routes: List<DriverRouteDto>, driver: DriverDto) {
|
||||||
|
val snapshot = _state.value
|
||||||
val activeRoute = routes.firstOrNull { it.driverLifecycleStatus() == "W TRAKCIE" }
|
val activeRoute = routes.firstOrNull { it.driverLifecycleStatus() == "W TRAKCIE" }
|
||||||
if (activeRoute == null) {
|
if (
|
||||||
|
activeRoute == null ||
|
||||||
|
!shouldTrackRouteLocation(snapshot.routeLocationMode, snapshot.routeLocationEnabled, hasLocationPermission())
|
||||||
|
) {
|
||||||
ActiveRouteTrackingService.stop(getApplication())
|
ActiveRouteTrackingService.stop(getApplication())
|
||||||
} else {
|
} else {
|
||||||
ActiveRouteTrackingService.start(
|
ActiveRouteTrackingService.start(
|
||||||
@@ -1611,7 +1792,11 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
|
|||||||
}
|
}
|
||||||
|
|
||||||
private fun reconcileTrackingServiceForRoute(route: DriverRouteDto, driver: DriverDto?) {
|
private fun reconcileTrackingServiceForRoute(route: DriverRouteDto, driver: DriverDto?) {
|
||||||
if (route.driverLifecycleStatus() == "W TRAKCIE") {
|
val snapshot = _state.value
|
||||||
|
if (
|
||||||
|
route.driverLifecycleStatus() == "W TRAKCIE" &&
|
||||||
|
shouldTrackRouteLocation(snapshot.routeLocationMode, snapshot.routeLocationEnabled, hasLocationPermission())
|
||||||
|
) {
|
||||||
if (driver != null) {
|
if (driver != null) {
|
||||||
ActiveRouteTrackingService.start(
|
ActiveRouteTrackingService.start(
|
||||||
context = getApplication(),
|
context = getApplication(),
|
||||||
@@ -1625,6 +1810,20 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private fun reconcileTrackingServiceFromState() {
|
||||||
|
val snapshot = _state.value
|
||||||
|
val driver = snapshot.driver
|
||||||
|
if (driver == null) {
|
||||||
|
ActiveRouteTrackingService.stop(getApplication())
|
||||||
|
return
|
||||||
|
}
|
||||||
|
reconcileTrackingService(snapshot.displayRoutes, driver)
|
||||||
|
}
|
||||||
|
|
||||||
|
private fun hasLocationPermission(): Boolean =
|
||||||
|
ContextCompat.checkSelfPermission(getApplication(), Manifest.permission.ACCESS_FINE_LOCATION) == PackageManager.PERMISSION_GRANTED ||
|
||||||
|
ContextCompat.checkSelfPermission(getApplication(), Manifest.permission.ACCESS_COARSE_LOCATION) == PackageManager.PERMISSION_GRANTED
|
||||||
|
|
||||||
private fun observeRouteActions(routeId: String) {
|
private fun observeRouteActions(routeId: String) {
|
||||||
routeActionsJob?.cancel()
|
routeActionsJob?.cancel()
|
||||||
routeActionsJob = viewModelScope.launch {
|
routeActionsJob = viewModelScope.launch {
|
||||||
@@ -1658,7 +1857,12 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
|
|||||||
}
|
}
|
||||||
|
|
||||||
private suspend fun checkRemoteSyncState() {
|
private suspend fun checkRemoteSyncState() {
|
||||||
if (!_state.value.isOnline) return
|
val initialSnapshot = _state.value
|
||||||
|
if (
|
||||||
|
!initialSnapshot.isOnline ||
|
||||||
|
initialSnapshot.screen == DriverScreen.Initializing ||
|
||||||
|
initialSnapshot.driver == null
|
||||||
|
) return
|
||||||
syncCheckMutex.withLock {
|
syncCheckMutex.withLock {
|
||||||
syncHintMutex.withLock { highestHintVersions.clear() }
|
syncHintMutex.withLock { highestHintVersions.clear() }
|
||||||
val snapshot = _state.value
|
val snapshot = _state.value
|
||||||
@@ -1705,6 +1909,8 @@ class DriverViewModel(application: Application) : AndroidViewModel(application)
|
|||||||
}
|
}
|
||||||
|
|
||||||
private suspend fun handleSyncHint(hint: DriverSyncHint) {
|
private suspend fun handleSyncHint(hint: DriverSyncHint) {
|
||||||
|
val initialSnapshot = _state.value
|
||||||
|
if (initialSnapshot.screen == DriverScreen.Initializing || initialSnapshot.driver == null) return
|
||||||
syncHintMutex.withLock {
|
syncHintMutex.withLock {
|
||||||
val hintKey = listOf(hint.scope, hint.date ?: "-", hint.routeId ?: "-").joinToString(":")
|
val hintKey = listOf(hint.scope, hint.date ?: "-", hint.routeId ?: "-").joinToString(":")
|
||||||
val previousVersion = highestHintVersions[hintKey]
|
val previousVersion = highestHintVersions[hintKey]
|
||||||
|
|||||||
@@ -0,0 +1,97 @@
|
|||||||
|
package pl.firmatpp.kierowca.ui
|
||||||
|
|
||||||
|
import android.Manifest
|
||||||
|
import android.annotation.SuppressLint
|
||||||
|
import android.content.Context
|
||||||
|
import android.content.pm.PackageManager
|
||||||
|
import android.location.Location
|
||||||
|
import android.location.LocationListener
|
||||||
|
import android.location.LocationManager
|
||||||
|
import android.os.Build
|
||||||
|
import android.os.CancellationSignal
|
||||||
|
import android.os.Looper
|
||||||
|
import androidx.core.content.ContextCompat
|
||||||
|
import kotlin.coroutines.resume
|
||||||
|
import kotlinx.coroutines.suspendCancellableCoroutine
|
||||||
|
import kotlinx.coroutines.withTimeoutOrNull
|
||||||
|
|
||||||
|
private const val PHOTO_LOCATION_PROVIDER_TIMEOUT_MILLIS = 5_000L
|
||||||
|
|
||||||
|
internal suspend fun currentPhotoLocation(context: Context): Location? {
|
||||||
|
if (!hasAnyLocationPermission(context)) return null
|
||||||
|
|
||||||
|
val manager = context.getSystemService(Context.LOCATION_SERVICE) as? LocationManager ?: return null
|
||||||
|
val hasFineLocation = ContextCompat.checkSelfPermission(
|
||||||
|
context,
|
||||||
|
Manifest.permission.ACCESS_FINE_LOCATION,
|
||||||
|
) == PackageManager.PERMISSION_GRANTED
|
||||||
|
val providers = buildList {
|
||||||
|
if (hasFineLocation) add(LocationManager.GPS_PROVIDER)
|
||||||
|
add(LocationManager.NETWORK_PROVIDER)
|
||||||
|
}.filter { provider -> runCatching { manager.isProviderEnabled(provider) }.getOrDefault(false) }
|
||||||
|
|
||||||
|
for (provider in providers) {
|
||||||
|
val location = withTimeoutOrNull(PHOTO_LOCATION_PROVIDER_TIMEOUT_MILLIS) {
|
||||||
|
manager.awaitSingleLocation(context, provider)
|
||||||
|
}
|
||||||
|
if (location != null) return location
|
||||||
|
}
|
||||||
|
|
||||||
|
return bestLastKnownLocation(manager)
|
||||||
|
}
|
||||||
|
|
||||||
|
@SuppressLint("MissingPermission")
|
||||||
|
private suspend fun LocationManager.awaitSingleLocation(
|
||||||
|
context: Context,
|
||||||
|
provider: String,
|
||||||
|
): Location? = suspendCancellableCoroutine { continuation ->
|
||||||
|
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.R) {
|
||||||
|
val cancellationSignal = CancellationSignal()
|
||||||
|
continuation.invokeOnCancellation { cancellationSignal.cancel() }
|
||||||
|
runCatching {
|
||||||
|
getCurrentLocation(provider, cancellationSignal, context.mainExecutor) { location ->
|
||||||
|
if (continuation.isActive) continuation.resume(location)
|
||||||
|
}
|
||||||
|
}.onFailure {
|
||||||
|
if (continuation.isActive) continuation.resume(null)
|
||||||
|
}
|
||||||
|
return@suspendCancellableCoroutine
|
||||||
|
}
|
||||||
|
|
||||||
|
val listener = object : LocationListener {
|
||||||
|
override fun onLocationChanged(location: Location) {
|
||||||
|
removeUpdates(this)
|
||||||
|
if (continuation.isActive) continuation.resume(location)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
continuation.invokeOnCancellation { runCatching { removeUpdates(listener) } }
|
||||||
|
runCatching {
|
||||||
|
@Suppress("DEPRECATION")
|
||||||
|
requestSingleUpdate(provider, listener, Looper.getMainLooper())
|
||||||
|
}.onFailure {
|
||||||
|
if (continuation.isActive) continuation.resume(null)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private fun hasAnyLocationPermission(context: Context): Boolean =
|
||||||
|
ContextCompat.checkSelfPermission(context, Manifest.permission.ACCESS_FINE_LOCATION) == PackageManager.PERMISSION_GRANTED ||
|
||||||
|
ContextCompat.checkSelfPermission(context, Manifest.permission.ACCESS_COARSE_LOCATION) == PackageManager.PERMISSION_GRANTED
|
||||||
|
|
||||||
|
@SuppressLint("MissingPermission")
|
||||||
|
private fun bestLastKnownLocation(manager: LocationManager): Location? {
|
||||||
|
val providers = listOf(
|
||||||
|
LocationManager.GPS_PROVIDER,
|
||||||
|
LocationManager.NETWORK_PROVIDER,
|
||||||
|
LocationManager.PASSIVE_PROVIDER,
|
||||||
|
)
|
||||||
|
|
||||||
|
return providers.mapNotNull { provider ->
|
||||||
|
runCatching {
|
||||||
|
if (manager.isProviderEnabled(provider) || provider == LocationManager.PASSIVE_PROVIDER) {
|
||||||
|
manager.getLastKnownLocation(provider)
|
||||||
|
} else {
|
||||||
|
null
|
||||||
|
}
|
||||||
|
}.getOrNull()
|
||||||
|
}.maxByOrNull { it.time }
|
||||||
|
}
|
||||||
@@ -0,0 +1,61 @@
|
|||||||
|
package pl.firmatpp.kierowca.data.upload
|
||||||
|
|
||||||
|
import org.junit.Assert.assertEquals
|
||||||
|
import org.junit.Test
|
||||||
|
|
||||||
|
class RouteActionPrerequisiteTest {
|
||||||
|
@Test
|
||||||
|
fun finishWaitsUntilEarlierStartIsConfirmed() {
|
||||||
|
val finish = action(RouteActionType.Finish, RouteActionStatus.Pending, createdAt = 2_000)
|
||||||
|
val pendingStart = action(RouteActionType.Start, RouteActionStatus.Syncing, createdAt = 1_000)
|
||||||
|
|
||||||
|
assertEquals(
|
||||||
|
RouteActionPrerequisiteState.Waiting,
|
||||||
|
routeActionPrerequisiteState(finish, pendingStart),
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
fun finishRunsAfterEarlierStartIsConfirmed() {
|
||||||
|
val finish = action(RouteActionType.Finish, RouteActionStatus.Pending, createdAt = 2_000)
|
||||||
|
val confirmedStart = action(RouteActionType.Start, RouteActionStatus.Confirmed, createdAt = 1_000)
|
||||||
|
|
||||||
|
assertEquals(
|
||||||
|
RouteActionPrerequisiteState.Ready,
|
||||||
|
routeActionPrerequisiteState(finish, confirmedStart),
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
fun failedStartBlocksFinishInsteadOfSendingItOutOfOrder() {
|
||||||
|
val finish = action(RouteActionType.Finish, RouteActionStatus.Pending, createdAt = 2_000)
|
||||||
|
val failedStart = action(RouteActionType.Start, RouteActionStatus.FailedConflict, createdAt = 1_000)
|
||||||
|
|
||||||
|
assertEquals(
|
||||||
|
RouteActionPrerequisiteState.Failed,
|
||||||
|
routeActionPrerequisiteState(finish, failedStart),
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
fun finishWithoutLocalStartCanUseServerLifecycleState() {
|
||||||
|
val finish = action(RouteActionType.Finish, RouteActionStatus.Pending, createdAt = 2_000)
|
||||||
|
|
||||||
|
assertEquals(
|
||||||
|
RouteActionPrerequisiteState.Ready,
|
||||||
|
routeActionPrerequisiteState(finish, null),
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
private fun action(type: String, status: String, createdAt: Long): RouteActionEntity =
|
||||||
|
RouteActionEntity(
|
||||||
|
clientActionId = "$type-$createdAt",
|
||||||
|
routeId = "route-1",
|
||||||
|
action = type,
|
||||||
|
weight = 12.5,
|
||||||
|
occurredAt = "2026-07-23T10:00:00Z",
|
||||||
|
photoClientRequestIdsJson = "[]",
|
||||||
|
status = status,
|
||||||
|
createdAtEpochMillis = createdAt,
|
||||||
|
)
|
||||||
|
}
|
||||||
+135
@@ -0,0 +1,135 @@
|
|||||||
|
package pl.firmatpp.kierowca.data.upload
|
||||||
|
|
||||||
|
import org.junit.Assert.assertFalse
|
||||||
|
import org.junit.Assert.assertTrue
|
||||||
|
import org.junit.Test
|
||||||
|
import pl.firmatpp.kierowca.data.model.DriverRouteDto
|
||||||
|
import pl.firmatpp.kierowca.data.model.RoutePhotoDto
|
||||||
|
|
||||||
|
class RouteActionServerReconciliationTest {
|
||||||
|
@Test
|
||||||
|
fun matchingFinishedRouteConfirmsDuplicateFinishSafely() {
|
||||||
|
assertTrue(
|
||||||
|
routeActionMatchesServer(
|
||||||
|
action = finish(weight = 11.8, notes = "Uszkodzona plomba."),
|
||||||
|
photoClientRequestIds = listOf("photo-1"),
|
||||||
|
serverRoute = route(
|
||||||
|
status = "ZAKOŃCZONA",
|
||||||
|
weight = 11.8,
|
||||||
|
notes = "Uszkodzona plomba.",
|
||||||
|
photoClientRequestIds = listOf("photo-1"),
|
||||||
|
),
|
||||||
|
),
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
fun differingNotesKeepConflictVisibleAndPreserveLocalData() {
|
||||||
|
assertFalse(
|
||||||
|
routeActionMatchesServer(
|
||||||
|
action = finish(weight = 11.8, notes = "Uwagi z telefonu"),
|
||||||
|
photoClientRequestIds = listOf("photo-1"),
|
||||||
|
serverRoute = route(
|
||||||
|
status = "ZAKOŃCZONA",
|
||||||
|
weight = 11.8,
|
||||||
|
notes = "Inna uwaga na serwerze",
|
||||||
|
photoClientRequestIds = listOf("photo-1"),
|
||||||
|
),
|
||||||
|
),
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
fun missingServerPhotoDoesNotDiscardLocalFinish() {
|
||||||
|
assertFalse(
|
||||||
|
routeActionMatchesServer(
|
||||||
|
action = finish(weight = null, notes = null),
|
||||||
|
photoClientRequestIds = listOf("photo-1"),
|
||||||
|
serverRoute = route(status = "ZAKOŃCZONA", weight = null, notes = null),
|
||||||
|
),
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
fun laterConfirmedFinishSupersedesAnOlderConflictingFinish() {
|
||||||
|
assertTrue(
|
||||||
|
routeActionWasSuperseded(
|
||||||
|
action = finish(weight = 11.8, notes = "Starsza uwaga"),
|
||||||
|
hasConfirmedFinishAfter = true,
|
||||||
|
serverRoute = route(
|
||||||
|
status = "ZAKOŃCZONA",
|
||||||
|
weight = null,
|
||||||
|
notes = null,
|
||||||
|
),
|
||||||
|
),
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
fun completedServerRouteAloneDoesNotDiscardConflictingLocalData() {
|
||||||
|
assertFalse(
|
||||||
|
routeActionWasSuperseded(
|
||||||
|
action = finish(weight = 11.8, notes = "Nadal ważna uwaga"),
|
||||||
|
hasConfirmedFinishAfter = false,
|
||||||
|
serverRoute = route(
|
||||||
|
status = "ZAKOŃCZONA",
|
||||||
|
weight = null,
|
||||||
|
notes = null,
|
||||||
|
),
|
||||||
|
),
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
private fun finish(weight: Double?, notes: String?): RouteActionEntity =
|
||||||
|
RouteActionEntity(
|
||||||
|
clientActionId = "finish-1",
|
||||||
|
routeId = "route-1",
|
||||||
|
action = RouteActionType.Finish,
|
||||||
|
weight = weight,
|
||||||
|
occurredAt = "2026-07-23T10:00:00Z",
|
||||||
|
photoClientRequestIdsJson = """["photo-1"]""",
|
||||||
|
notes = notes,
|
||||||
|
)
|
||||||
|
|
||||||
|
private fun route(
|
||||||
|
status: String,
|
||||||
|
weight: Double?,
|
||||||
|
notes: String?,
|
||||||
|
photoClientRequestIds: List<String> = emptyList(),
|
||||||
|
): DriverRouteDto =
|
||||||
|
DriverRouteDto(
|
||||||
|
id = "route-1",
|
||||||
|
routeDate = "2026-07-23",
|
||||||
|
startsAt = "",
|
||||||
|
originName = "Baza",
|
||||||
|
destinationName = "Cel",
|
||||||
|
contractorName = "TPP",
|
||||||
|
contractName = "Kontrakt",
|
||||||
|
contractCode = "TPP-1",
|
||||||
|
relationLabel = "Baza → Cel",
|
||||||
|
status = status,
|
||||||
|
driverStatus = status,
|
||||||
|
unloadingWeight = weight,
|
||||||
|
unloadingNotes = notes,
|
||||||
|
distanceKm = 1.0,
|
||||||
|
notes = null,
|
||||||
|
truck = null,
|
||||||
|
photos = photoClientRequestIds.mapIndexed { index, requestId ->
|
||||||
|
RoutePhotoDto(
|
||||||
|
id = "photo-$index",
|
||||||
|
routeId = "route-1",
|
||||||
|
clientRequestId = requestId,
|
||||||
|
source = "camera",
|
||||||
|
stage = "unloading",
|
||||||
|
mimeType = "image/jpeg",
|
||||||
|
size = 1,
|
||||||
|
url = "https://example.test/photo-$index",
|
||||||
|
takenAt = null,
|
||||||
|
latitude = null,
|
||||||
|
longitude = null,
|
||||||
|
locationAccuracyMeters = null,
|
||||||
|
createdAt = null,
|
||||||
|
)
|
||||||
|
},
|
||||||
|
)
|
||||||
|
}
|
||||||
@@ -125,16 +125,25 @@ class DriverRouteProjectionTest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
fun conflictKeepsLocalRouteValuesAndMarksStageAsAttention() {
|
fun conflictKeepsLocalRouteValuesButPreservesServerLifecycleStatus() {
|
||||||
val projection = projectDriverRoute(
|
val projection = projectDriverRoute(
|
||||||
route = route(status = "W TRAKCIE", loadingWeight = 12.5),
|
route = route(status = "W TRAKCIE", loadingWeight = 12.5),
|
||||||
actions = listOf(action(RouteActionType.Finish, RouteActionStatus.FailedConflict, weight = 11.8)),
|
actions = listOf(
|
||||||
|
action(
|
||||||
|
RouteActionType.Finish,
|
||||||
|
RouteActionStatus.FailedConflict,
|
||||||
|
weight = 11.8,
|
||||||
|
notes = "Uszkodzona plomba.",
|
||||||
|
),
|
||||||
|
),
|
||||||
)
|
)
|
||||||
val steps = routeFlowSteps(projection.route, projection.visibleActions)
|
val steps = routeFlowSteps(projection.route, projection.visibleActions)
|
||||||
val callout = routeSyncCallout(projection.visibleActions)
|
val callout = routeSyncCallout(projection.visibleActions)
|
||||||
|
|
||||||
assertEquals("ZAKOŃCZONA", projection.route.status)
|
assertEquals("W TRAKCIE", projection.route.status)
|
||||||
assertEquals(11.8, projection.route.unloadingWeight)
|
assertEquals(11.8, projection.route.unloadingWeight)
|
||||||
|
assertEquals("Uszkodzona plomba.", projection.route.unloadingNotes)
|
||||||
|
assertTrue(projection.unloadingWeightPending)
|
||||||
assertEquals(RouteFlowStepState.NeedsAttention, steps[3].state)
|
assertEquals(RouteFlowStepState.NeedsAttention, steps[3].state)
|
||||||
assertEquals("Kurs wymaga obsługi. Dane wpisane w telefonie zostały zachowane.", callout?.text)
|
assertEquals("Kurs wymaga obsługi. Dane wpisane w telefonie zostały zachowane.", callout?.text)
|
||||||
assertTrue(callout?.isConflict ?: false)
|
assertTrue(callout?.isConflict ?: false)
|
||||||
@@ -148,8 +157,9 @@ class DriverRouteProjectionTest {
|
|||||||
)
|
)
|
||||||
val steps = routeFlowSteps(projection.route, projection.visibleActions)
|
val steps = routeFlowSteps(projection.route, projection.visibleActions)
|
||||||
|
|
||||||
assertEquals("W TRAKCIE", projection.route.status)
|
assertEquals("ZAPLANOWANA", projection.route.status)
|
||||||
assertEquals(12.5, projection.route.loadingWeight)
|
assertEquals(12.5, projection.route.loadingWeight)
|
||||||
|
assertTrue(projection.loadingWeightPending)
|
||||||
assertEquals(RouteFlowStepState.NeedsAttention, steps[1].state)
|
assertEquals(RouteFlowStepState.NeedsAttention, steps[1].state)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -8,6 +8,8 @@ import org.junit.Test
|
|||||||
import pl.firmatpp.kierowca.data.model.DriverRouteDto
|
import pl.firmatpp.kierowca.data.model.DriverRouteDto
|
||||||
import pl.firmatpp.kierowca.data.model.DispatchSheetReminderDto
|
import pl.firmatpp.kierowca.data.model.DispatchSheetReminderDto
|
||||||
import pl.firmatpp.kierowca.data.model.RoutePhotoDto
|
import pl.firmatpp.kierowca.data.model.RoutePhotoDto
|
||||||
|
import pl.firmatpp.kierowca.data.model.TachographReminderDto
|
||||||
|
import pl.firmatpp.kierowca.data.model.TachographReminderTaskDto
|
||||||
import pl.firmatpp.kierowca.data.upload.PhotoUploadEntity
|
import pl.firmatpp.kierowca.data.upload.PhotoUploadEntity
|
||||||
import pl.firmatpp.kierowca.data.upload.RouteActionEntity
|
import pl.firmatpp.kierowca.data.upload.RouteActionEntity
|
||||||
import pl.firmatpp.kierowca.data.upload.RouteActionStatus
|
import pl.firmatpp.kierowca.data.upload.RouteActionStatus
|
||||||
@@ -16,6 +18,29 @@ import pl.firmatpp.kierowca.data.upload.RouteActionType
|
|||||||
class DriverUiRulesTest {
|
class DriverUiRulesTest {
|
||||||
private val today = LocalDate.parse("2026-06-30")
|
private val today = LocalDate.parse("2026-06-30")
|
||||||
|
|
||||||
|
@Test
|
||||||
|
fun disabledRouteLocationNeverStartsTracking() {
|
||||||
|
assertFalse(shouldTrackRouteLocation(RouteLocationMode.Disabled, optionalLocationEnabled = true, hasLocationPermission = true))
|
||||||
|
assertFalse(shouldTrackRouteLocation(RouteLocationMode.Disabled, optionalLocationEnabled = false, hasLocationPermission = true))
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
fun optionalRouteLocationFollowsDriverChoiceAndPermission() {
|
||||||
|
assertTrue(shouldTrackRouteLocation(RouteLocationMode.Optional, optionalLocationEnabled = true, hasLocationPermission = true))
|
||||||
|
assertFalse(shouldTrackRouteLocation(RouteLocationMode.Optional, optionalLocationEnabled = false, hasLocationPermission = true))
|
||||||
|
assertFalse(shouldTrackRouteLocation(RouteLocationMode.Optional, optionalLocationEnabled = true, hasLocationPermission = false))
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
fun requiredRouteLocationBlocksStartAndWarnsOnlyWhenNeeded() {
|
||||||
|
assertTrue(routeStartRequiresLocationPermission(RouteLocationMode.Required, hasLocationPermission = false))
|
||||||
|
assertFalse(routeStartRequiresLocationPermission(RouteLocationMode.Required, hasLocationPermission = true))
|
||||||
|
assertFalse(routeStartRequiresLocationPermission(RouteLocationMode.Optional, hasLocationPermission = false))
|
||||||
|
assertTrue(shouldWarnAboutRequiredRouteLocation(RouteLocationMode.Required, hasActiveRoute = true, hasLocationPermission = false))
|
||||||
|
assertFalse(shouldWarnAboutRequiredRouteLocation(RouteLocationMode.Required, hasActiveRoute = false, hasLocationPermission = false))
|
||||||
|
assertFalse(shouldWarnAboutRequiredRouteLocation(RouteLocationMode.Optional, hasActiveRoute = true, hasLocationPermission = false))
|
||||||
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
fun allowsPhotoActionsOnlyForTodayRouteDate() {
|
fun allowsPhotoActionsOnlyForTodayRouteDate() {
|
||||||
assertTrue(canManageRoutePhotos("2026-06-30", today))
|
assertTrue(canManageRoutePhotos("2026-06-30", today))
|
||||||
@@ -387,6 +412,57 @@ class DriverUiRulesTest {
|
|||||||
assertFalse(shouldShowDispatchSheetReminderCard(null))
|
assertFalse(shouldShowDispatchSheetReminderCard(null))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
fun showsTachographCardOnlyForCompleteReminderEnabledByBackend() {
|
||||||
|
assertTrue(
|
||||||
|
shouldShowTachographReminderCard(
|
||||||
|
TachographReminderDto(
|
||||||
|
enabled = true,
|
||||||
|
visible = true,
|
||||||
|
title = "Odczyt tachografu",
|
||||||
|
message = "Pamiętaj o odczycie.",
|
||||||
|
tasks = listOf(tachographTask()),
|
||||||
|
),
|
||||||
|
),
|
||||||
|
)
|
||||||
|
assertFalse(
|
||||||
|
shouldShowTachographReminderCard(
|
||||||
|
TachographReminderDto(
|
||||||
|
enabled = false,
|
||||||
|
visible = true,
|
||||||
|
title = "Odczyt tachografu",
|
||||||
|
message = "Pamiętaj o odczycie.",
|
||||||
|
tasks = listOf(tachographTask()),
|
||||||
|
),
|
||||||
|
),
|
||||||
|
)
|
||||||
|
assertFalse(
|
||||||
|
shouldShowTachographReminderCard(
|
||||||
|
TachographReminderDto(
|
||||||
|
enabled = true,
|
||||||
|
visible = false,
|
||||||
|
title = "Odczyt tachografu",
|
||||||
|
message = "Pamiętaj o odczycie.",
|
||||||
|
tasks = listOf(tachographTask()),
|
||||||
|
),
|
||||||
|
),
|
||||||
|
)
|
||||||
|
assertFalse(shouldShowTachographReminderCard(null))
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
fun preselectsOnlySingleTachographConfirmationTask() {
|
||||||
|
val driverCard = tachographTask()
|
||||||
|
val vehicle = TachographReminderTaskDto(
|
||||||
|
id = "vehicle:12:2026-07-31",
|
||||||
|
type = "vehicle_tachograph",
|
||||||
|
label = "Tachograf pojazdu",
|
||||||
|
)
|
||||||
|
|
||||||
|
assertEquals(setOf(driverCard.id), defaultTachographConfirmationSelection(listOf(driverCard)))
|
||||||
|
assertEquals(emptySet<String>(), defaultTachographConfirmationSelection(listOf(driverCard, vehicle)))
|
||||||
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
fun explainsOfflineStateWithoutCachedSync() {
|
fun explainsOfflineStateWithoutCachedSync() {
|
||||||
assertEquals(
|
assertEquals(
|
||||||
@@ -794,4 +870,11 @@ class DriverUiRulesTest {
|
|||||||
photo = null,
|
photo = null,
|
||||||
canUpload = dueToday,
|
canUpload = dueToday,
|
||||||
)
|
)
|
||||||
|
|
||||||
|
private fun tachographTask(): TachographReminderTaskDto =
|
||||||
|
TachographReminderTaskDto(
|
||||||
|
id = "driver-card:1:2026-07-31",
|
||||||
|
type = "driver_card",
|
||||||
|
label = "Karta kierowcy",
|
||||||
|
)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -43,6 +43,55 @@ class DriverUiStateTest {
|
|||||||
assertEquals(ServerConnectionState.Degraded, failed.serverConnectionState)
|
assertEquals(ServerConnectionState.Degraded, failed.serverConnectionState)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
fun silentRefreshCannotReplaceActiveStartupLoad() {
|
||||||
|
assertFalse(
|
||||||
|
shouldStartRoutesLoad(
|
||||||
|
screen = DriverScreen.Initializing,
|
||||||
|
navigateToRoutes = false,
|
||||||
|
startupOfflineOnly = false,
|
||||||
|
),
|
||||||
|
)
|
||||||
|
assertFalse(
|
||||||
|
shouldStartRoutesLoad(
|
||||||
|
screen = DriverScreen.Routes,
|
||||||
|
navigateToRoutes = false,
|
||||||
|
startupOfflineOnly = false,
|
||||||
|
startupLoadInProgress = true,
|
||||||
|
),
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
fun startupAndManualOfflineLoadsRemainAvailable() {
|
||||||
|
assertTrue(
|
||||||
|
shouldStartRoutesLoad(
|
||||||
|
screen = DriverScreen.Initializing,
|
||||||
|
navigateToRoutes = true,
|
||||||
|
startupOfflineOnly = false,
|
||||||
|
),
|
||||||
|
)
|
||||||
|
assertTrue(
|
||||||
|
shouldStartRoutesLoad(
|
||||||
|
screen = DriverScreen.Initializing,
|
||||||
|
navigateToRoutes = false,
|
||||||
|
startupOfflineOnly = true,
|
||||||
|
),
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
fun successfulBootstrapAlwaysLeavesInitializingScreen() {
|
||||||
|
assertEquals(
|
||||||
|
DriverScreen.Routes,
|
||||||
|
screenAfterBootstrap(
|
||||||
|
currentScreen = DriverScreen.Initializing,
|
||||||
|
navigateToRoutes = false,
|
||||||
|
leaveRequestsEnabled = true,
|
||||||
|
),
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
fun refreshingLeaveRequestsKeepsDetailScreenOpenAndUpdatesSelectedRequest() {
|
fun refreshingLeaveRequestsKeepsDetailScreenOpenAndUpdatesSelectedRequest() {
|
||||||
val state = DriverUiState(
|
val state = DriverUiState(
|
||||||
|
|||||||
@@ -0,0 +1,43 @@
|
|||||||
|
package pl.firmatpp.kierowca.ui
|
||||||
|
|
||||||
|
import java.time.LocalDate
|
||||||
|
import org.junit.Assert.assertEquals
|
||||||
|
import org.junit.Test
|
||||||
|
|
||||||
|
class RouteDatePickerBoundsTest {
|
||||||
|
@Test
|
||||||
|
fun usesTheSameMinAndMaxDatesAsTheRouteSelector() {
|
||||||
|
val bounds = routeDatePickerBounds(
|
||||||
|
selectedDate = "2026-07-24",
|
||||||
|
minDate = "2026-07-17",
|
||||||
|
maxDate = "2026-07-26",
|
||||||
|
)
|
||||||
|
|
||||||
|
assertEquals(LocalDate.parse("2026-07-24"), bounds.selectedDate)
|
||||||
|
assertEquals(LocalDate.parse("2026-07-17"), bounds.minDate)
|
||||||
|
assertEquals(LocalDate.parse("2026-07-26"), bounds.maxDate)
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
fun clampsSelectedDateToAllowedRange() {
|
||||||
|
val bounds = routeDatePickerBounds(
|
||||||
|
selectedDate = "2026-07-30",
|
||||||
|
minDate = "2026-07-17",
|
||||||
|
maxDate = "2026-07-26",
|
||||||
|
)
|
||||||
|
|
||||||
|
assertEquals(LocalDate.parse("2026-07-26"), bounds.selectedDate)
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
fun normalizesAccidentallyReversedServerBounds() {
|
||||||
|
val bounds = routeDatePickerBounds(
|
||||||
|
selectedDate = "2026-07-24",
|
||||||
|
minDate = "2026-07-26",
|
||||||
|
maxDate = "2026-07-17",
|
||||||
|
)
|
||||||
|
|
||||||
|
assertEquals(LocalDate.parse("2026-07-17"), bounds.minDate)
|
||||||
|
assertEquals(LocalDate.parse("2026-07-26"), bounds.maxDate)
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -1,5 +1,5 @@
|
|||||||
[versions]
|
[versions]
|
||||||
agp = "8.7.3"
|
agp = "8.10.1"
|
||||||
kotlin = "2.1.10"
|
kotlin = "2.1.10"
|
||||||
composeBom = "2026.03.00"
|
composeBom = "2026.03.00"
|
||||||
activityCompose = "1.9.3"
|
activityCompose = "1.9.3"
|
||||||
|
|||||||
Reference in New Issue
Block a user