how to test merge case inside .onApper (thanks advance for helping)

[saroar]

//
//  EventsViewTests.swift
//  
//
//  Created by Saroar Khandoker on 14.09.2021.
//

import XCTest
import ComposableArchitecture
import ComposableCoreLocation
import HTTPRequestKit
import KeychainService
import SharedModels
import PathMonitorClient
import Combine

@testable import EventView
@testable import EventFormView

class EventsView: XCTestCase {
  let scheduler = DispatchQueue.test
  let data = Date(timeIntervalSince1970: 0)

  // swiftlint:disable function_body_length
  func testFlow_Success_GetEvents() {

    let mockLocation = Location(
      altitude: 50,
      coordinate: CLLocationCoordinate2D(latitude: 60.020532228306031, longitude: 30.388014239849944),
      course: 9,
      courseAccuracy: 1,
      horizontalAccuracy: 3,
      speed: 5,
      speedAccuracy: 2,
      timestamp: Date.init(timeIntervalSince1970: 0),
      verticalAccuracy: 6
    )

    let locationManagerSubject = PassthroughSubject<LocationManager.Action, Never>()


    let manager = LocationManager.unimplemented(
      // Override any CLLocationManager endpoints your test invokes:

      authorizationStatus: { .authorizedAlways },
      create: { _ in locationManagerSubject.eraseToEffect() },
      locationServicesEnabled: { true },
      requestLocation: { _ in
        .fireAndForget { locationManagerSubject.send(.didUpdateLocations([mockLocation])) }
      },
      requestWhenInUseAuthorization: { _ in
          .fireAndForget {
            locationManagerSubject.send(.didUpdateLocations([mockLocation]))
          }
      }
    )

//  accuracyAuthorization: @escaping (AnyHashable) -> AccuracyAuthorization? = { _ in
//    _unimplemented("accuracyAuthorization")
//  },
//  authorizationStatus: @escaping () -> CLAuthorizationStatus = {
//    _unimplemented("authorizationStatus")
//  }


    let state = EventsState.placeholderEvents

    let environment = EventsEnvironment(
      pathMonitorClient: .satisfied,
      locationManager: manager,
      eventClient: .happyPath,
      backgroundQueue: scheduler.eraseToAnyScheduler(),
      mainQueue: scheduler.eraseToAnyScheduler(),
      userDefaults: .noop
    )

    let store = TestStore(
      initialState: state,
      reducer: eventReducer,
      environment: environment
    )

    store.send(.onAppear)
    scheduler.advance()
    store.send(.locationManager(.didUpdateLocations([
      Location(coordinate: .init(latitude: 60.020532228306031, longitude: 30.388014239849944))]))) {
        $0.isConnected = true
        $0.location = nil
    }
    scheduler.advance()
    store.send(.eventsResponse(.success(
      EventResponse(
        items: [
          .init(
            id: "5fbfe53675a93bda87c7cb10", name: "Cool :)", categories: "General",
            duration: 14400, isActive: true, conversationsId: "5fbfe5361cdd72e23297914a",
            addressName: "8к1литД улица Вавиловых , Saint Petersburg", type: "Point",
            sponsored: false, overlay: false,
            coordinates: [60.020532228306031, 30.388014239849944], createdAt: data,
            updatedAt: data),
          .init(
            id: "5fbe8a8c8ba94be8a688324c", name: "Awesome 🤩 app", categories: "General",
            duration: 14400, isActive: true, conversationsId: "5fbe8a8c492346f651b57946",
            addressName: "8к1литД улица Вавиловых , Saint Petersburg", type: "Point",
            sponsored: false, overlay: false,
            coordinates: [60.020525506753494, 30.387988546891499], createdAt: data,
            updatedAt: data),
        ],
        metadata: .init(per: 2, total: 4, page: 1)
      )
    ))) {
      $0.waitingForUpdateLocation = false
      $0.canLoadMorePages = $0.events.count < 4
      $0.isLoadingPage = false
//      $0.currentPage += 1

      let events = (
        $0.events +
        [
          .init(
            id: "5fbfe53675a93bda87c7cb10", name: "Cool :)", categories: "General",
            duration: 14400, isActive: true, conversationsId: "5fbfe5361cdd72e23297914a",
            addressName: "8к1литД улица Вавиловых , Saint Petersburg", type: "Point",
            sponsored: false, overlay: false,
            coordinates: [60.020532228306031, 30.388014239849944], createdAt: self.data,
            updatedAt: self.data),
          .init(
            id: "5fbe8a8c8ba94be8a688324c", name: "Awesome 🤩 app", categories: "General",
            duration: 14400, isActive: true, conversationsId: "5fbe8a8c492346f651b57946",
            addressName: "8к1литД улица Вавиловых , Saint Petersburg", type: "Point",
            sponsored: false, overlay: false,
            coordinates: [60.020525506753494, 30.387988546891499], createdAt: self.data,
            updatedAt: self.data),
        ]
      )
      $0.events = .init(uniqueElements: events)
    }
  }

}

here how do I test this case ?
https://github.com/AddaMeSPB/AddaMeIOS/blob/feature/git_workflow/AddameSPM/Sources/EventView/EventsReducer.swift#L103

1st: warning from onApper

An effect returned for this action is still running. It must complete before the end of the test. …

To fix, inspect any effects the reducer returns for this action and ensure that all of them complete by the end of the test. There are a few reasons why an effect may not have completed:

• If an effect uses a scheduler (via "receive(on:)", "delay", "debounce", etc.), make sure that you wait enough time for the scheduler to perform the effect. If you are using a test scheduler, advance the scheduler so that the effects may complete, or consider using an immediate scheduler to immediately perform the effect instead.

• If you are returning a long-living effect (timers, notifications, subjects, etc.), then make sure those effects are torn down by marking the effect ".cancellable" and returning a corresponding cancellation effect ("Effect.cancel") from another action, or, if your effect is driven by a Combine subject, send it a completion.

2nd warning: have 3 warning:

An effect returned for this action is still running. It must complete before the end of the test. …

To fix, inspect any effects the reducer returns for this action and ensure that all of them complete by the end of the test. There are a few reasons why an effect may not have completed:

• If an effect uses a scheduler (via "receive(on:)", "delay", "debounce", etc.), make sure that you wait enough time for the scheduler to perform the effect. If you are using a test scheduler, advance the scheduler so that the effects may complete, or consider using an immediate scheduler to immediately perform the effect instead.

• If you are returning a long-living effect (timers, notifications, subjects, etc.), then make sure those effects are torn down by marking the effect ".cancellable" and returning a corresponding cancellation effect ("Effect.cancel") from another action, or, if your effect is driven by a Combine subject, send it a completion.

Must handle 1 received action before sending an action: …

Unhandled actions: [
[0]: EventsAction.locationManager(
LocationManager.Action.didUpdateLocations(
[
[0]: Location(rawValue: CLLocation())
]
)
)
]

I am using this package kit now https://github.com/pointfreeco/composable-core-location

[ferologics]

Hey @saroar 👋

It looks like your locationManager is sending an action with mock location update when you request authorization from your onAppear action:

requestWhenInUseAuthorization: { _ in
          .fireAndForget {
            locationManagerSubject.send(.didUpdateLocations([mockLocation]))
          }
      }

I think it would help asserting that this is the case, or instead removing this logic and sending location update later on, as you already seem to be doing later on in your test case with store.send(.locationManager(.didUpdateLocations([...]))).