Приложение погоды — тестовое задание

Что не так. Ключ погодного сервиса записан значением по умолчанию в интерфейсе Retrofit и попал в коммиты.

Почему это важно. Поиск секретов в репозитории — одна из первых проверок. Удаление строки не поможет: ключ останется в истории и его можно достать.

interface WeatherApi {
    @GET("forecast")
    suspend fun forecast(
        @Query("q") city: String,
        @Query("appid") key: String = "3f9a1c7e5b2d4f6a8c0e1b3d5f7a9c2e",
    ): ForecastDto
}

Как исправить. Отзовите этот ключ в кабинете сервиса и получите новый. Новый положите в local.properties (он уже в .gitignore), передайте через BuildConfig и добавляйте к запросам интерцептором:

val localProps = Properties().apply {
    rootProject.file("local.properties").takeIf { it.exists() }?.inputStream()?.use(::load)
}

android {
    buildFeatures { buildConfig = true }
    defaultConfig {
        buildConfigField("String", "WEATHER_API_KEY", "\"${localProps.getProperty("weather.apiKey", "")}\"")
    }
}

class ApiKeyInterceptor @Inject constructor() : Interceptor {
    override fun intercept(chain: Interceptor.Chain): Response {
        val url = chain.request().url.newBuilder()
            .addQueryParameter("appid", BuildConfig.WEATHER_API_KEY)
            .build()
        return chain.proceed(chain.request().newBuilder().url(url).build())
    }
}

Из собранного APK ключ всё равно можно извлечь. Для тестового этого достаточно, но одна строка в README «в продакшене запросы шли бы через свой бэкенд» покажет, что вы это понимаете.

HttpLoggingInterceptor всегда включён на уровне BODY. В релизе адрес запроса с ключом и ответы попадут в Logcat.

@Provides @Singleton
fun okHttp(apiKey: ApiKeyInterceptor): OkHttpClient = OkHttpClient.Builder()
    .addInterceptor(apiKey)
    .addInterceptor(HttpLoggingInterceptor().apply { level = HttpLoggingInterceptor.Level.BODY })
    .build()

@Provides @Singleton
fun okHttp(apiKey: ApiKeyInterceptor): OkHttpClient = OkHttpClient.Builder()
    .addInterceptor(apiKey)
    .apply {
        if (BuildConfig.DEBUG) addInterceptor(HttpLoggingInterceptor().apply { level = HttpLoggingInterceptor.Level.BASIC })
    }
    .connectTimeout(10, TimeUnit.SECONDS)
    .readTimeout(15, TimeUnit.SECONDS)
    .build()

Что не так. Репозиторий сначала идёт в сеть. Если запрос упал, он возвращает пустой список, а кэш читает только после удачного запроса. Требование «офлайн-кэш» выполнено формально: данные сохраняются, но не показываются.

Ещё одна проблема здесь же. catch (e: Exception) ловит и CancellationException. Если пользователь ушёл с экрана, корутина не отменится как положено.

suspend fun getForecast(city: String): List<DayForecast> {
    return try {
        val dto = api.forecast(city)
        dao.insert(dto.toEntities(city))
        dao.getForecast(city).map { it.toDomain() }
    } catch (e: Exception) {
        emptyList()
    }
}

Как исправить. Разделите чтение и обновление. Экран подписан на базу, сеть только обновляет её. Ловите конкретные ошибки сети, а не все подряд:

fun forecast(city: String): Flow<List<DayForecast>> =
    dao.observeForecast(city).map { rows -> rows.map { it.toDomain() } }

suspend fun refresh(city: String): RefreshResult = try {
    val dto = api.forecast(city)
    dao.replaceForecast(city, dto.toEntities(city, fetchedAt = clock.now()))
    RefreshResult.Ok
} catch (e: IOException) {
    RefreshResult.Offline
} catch (e: HttpException) {
    RefreshResult.Error(e.code())
}

replaceForecast сделайте @Transaction: удалить старый прогноз города и вставить новый. Тогда экран не мигнёт пустым списком между двумя операциями.

Composable-функции принимают ForecastDto.Item и читают поля вроде main.temp_max и dt_txt. Любое изменение API сломает UI, а превью и тесты приходится собирать из сетевых классов.

@Composable
fun ForecastRow(item: ForecastDto.Item) {
    Text(item.dt_txt.substringBefore(' '))
    Text("${item.main.temp_min.roundToInt()}° / ${item.main.temp_max.roundToInt()}°")
}

data class DayForecast(
    val date: LocalDate,
    val minTemp: Int,
    val maxTemp: Int,
    val condition: Condition,
    val windMs: Double,
)

Маппинг ForecastDto → Entity → DayForecast держите в слое data. Экран знает только DayForecast.

Что не так. Каждый введённый символ запускает новый запрос, и предыдущие не отменяются. Ответы приходят в произвольном порядке. Ответ на «Мос» может прийти позже ответа на «Москва» и затереть его. Заодно лишние запросы расходуют лимит API.

fun onQueryChange(query: String) {
    _query.value = query
    viewModelScope.launch {
        _results.value = repository.searchCities(query)
    }
}

Как исправить. Опишите поиск потоком: пауза 300 мс, без повторов, и flatMapLatest, который отменяет устаревший запрос:

private val _query = MutableStateFlow("")
val query: StateFlow<String> = _query.asStateFlow()

@OptIn(FlowPreview::class, ExperimentalCoroutinesApi::class)
val results: StateFlow<SearchState> = _query
    .debounce(300)
    .map { it.trim() }
    .distinctUntilChanged()
    .flatMapLatest { q ->
        if (q.length < 2) flowOf(SearchState.Idle)
        else flow {
            emit(SearchState.Loading)
            emit(repository.searchCities(q).toSearchState())
        }
    }
    .stateIn(viewModelScope, SharingStarted.WhileSubscribed(5_000), SearchState.Idle)

fun onQueryChange(value: String) { _query.value = value }

Текст поиска хранится в remember { mutableStateOf("") }. При повороте экрана он сбрасывается, а результаты во ViewModel остаются — экран рассинхронизируется. Повернуть телефон — стандартная проверка.

@Composable
fun SearchScreen(vm: SearchViewModel = hiltViewModel()) {
    var query by remember { mutableStateOf("") }
    OutlinedTextField(
        value = query,
        onValueChange = { query = it; vm.onQueryChange(it) },
    )
    // …
}

@Composable
fun SearchScreen(vm: SearchViewModel = hiltViewModel()) {
    val query by vm.query.collectAsStateWithLifecycle()
    val state by vm.results.collectAsStateWithLifecycle()
    SearchContent(query = query, state = state, onQueryChange = vm::onQueryChange)
}

Один источник правды для запроса — ViewModel из P1-3. collectAsStateWithLifecycle перестаёт собирать поток, когда приложение свёрнуто.

При ошибке экран показывает одно слово «Ошибка». Добавьте кнопку «Повторить» и pull-to-refresh, которые вызывают refresh() из P1-2. Тексты ошибок сделайте разными для «нет сети» и «город не найден».

when (val state = uiState) {
    is ForecastUiState.Loading -> CircularProgressIndicator()
    is ForecastUiState.Error -> Text("Ошибка")
    is ForecastUiState.Ready -> ForecastList(state.days)
}

is ForecastUiState.Error -> ErrorState(
    message = stringResource(if (state.offline) R.string.error_offline else R.string.error_city_not_found),
    onRetry = viewModel::refresh,
)
is ForecastUiState.Ready -> PullToRefreshBox(isRefreshing = state.refreshing, onRefresh = viewModel::refresh) {
    ForecastList(state.days)
}

Что не так. Тест создаёт настоящий Retrofit и ждёт две секунды. Без интернета или при исчерпанном лимите API он падает, а при медленной сети — через раз.

Почему это важно. Тесты прямо указаны в требованиях. Проверяющий запустит ./gradlew test, и красный тест заметно испортит впечатление.

@Test
fun loadsForecast() {
    val vm = ForecastViewModel(WeatherRepository(RetrofitModule.api(), FakeDao()))
    vm.load("Moscow")
    Thread.sleep(2000)
    assertTrue(vm.state.value.days.isNotEmpty())
}

Как исправить. Выделите интерфейс репозитория, в тестах используйте фейк. Время управляйте через тестовый диспетчер: правило MainDispatcherRule и runTest.

class ForecastViewModelTest {
    @get:Rule val mainRule = MainDispatcherRule()
    private val repo = FakeWeatherRepository()

    @Test
    fun `shows cached forecast and offline banner when refresh fails`() = runTest {
        repo.cached = listOf(day(maxTemp = 12))
        repo.refreshResult = RefreshResult.Offline
        val vm = ForecastViewModel(repo)

        vm.selectCity("Москва")
        advanceUntilIdle()

        val state = vm.state.value
        assertEquals(12, state.days.first().maxTemp)
        assertTrue(state.isOffline)
    }
}

Хватит трёх тестов: успешная загрузка, офлайн с кэшем и ошибка без кэша. Они проверяют ровно то, что просили в задании.

SimpleDateFormat создаётся прямо в composable-функции и парсит строку dt_txt при каждой рекомпозиции. Форматируйте один раз при маппинге в DayForecast, через java.time:

@Composable
fun ForecastRow(item: ForecastDto.Item) {
    val parsed = SimpleDateFormat("yyyy-MM-dd HH:mm:ss", Locale.getDefault()).parse(item.dt_txt)
    Text(SimpleDateFormat("EEE, d MMM", Locale("ru")).format(parsed!!))
}

private val dayFormatter = DateTimeFormatter.ofPattern("EEE, d MMM", Locale("ru"))

fun LocalDate.toDayLabel(): String = format(dayFormatter)

Без key Compose сопоставляет строки по позиции. При обновлении данных строки перерисовываются целиком, а состояние внутри них может «переехать» на соседнюю.

LazyColumn {
    items(days) { day -> ForecastRow(day) }
}

LazyColumn {
    items(days, key = { it.date.toEpochDay() }) { day -> ForecastRow(day) }
}

«Ветер», «м/с», «°C» записаны строками в коде. Вынесите их в strings.xml и stringResource(), а для «1 день / 2 дня / 5 дней» используйте pluralStringResource. Мелочь, но проверяющие на неё смотрят.

Text("Ветер ${weather.windMs} м/с")
Text("${weather.temp}°C")

Text(stringResource(R.string.wind_speed, weather.windMs))
Text(stringResource(R.string.temperature_celsius, weather.temp))

<string name="wind_speed">Ветер %1$.1f м/с</string>
<string name="temperature_celsius">%1$d °C</string>

Подключите detekt и ktlint и простой GitHub Actions, который собирает проект и запускает тесты на каждый push. Зелёная галочка у коммитов производит хорошее впечатление ещё до открытия кода.

Тест на createComposeRule «ввёл город → увидел прогноз» с фейковым репозиторием. Это показывает, что вы умеете тестировать не только ViewModel.

Gson молча оставляет null в не-nullable полях Kotlin, и такие ошибки всплывают далеко от места причины. kotlinx.serialization проверяет модель при разборе ответа.