LogStorageHelperTest.kt

@Mock
lateinit var mockOppiaEventLogsObserver: Observer<AsyncResult<OppiaEventLogs>>

@Captor
lateinit var oppiaEventLogResultCaptor: ArgumentCaptor<AsyncResult<OppiaEventLogs>>

  private val eventLog = EventLog.newBuilder()
    .setActionName(EventLog.EventAction.EVENT_ACTION_UNSPECIFIED)
    .setContext(
      EventLog.Context.newBuilder()
        .setConceptCardContext(
          EventLog.ConceptCardContext.newBuilder()
            .setSkillId(TEST_SKILL_ID)
            .build()
        )
        .build()
    )
    .setTimestamp(TEST_TIMESTAMP)
    .setPriority(EventLog.Priority.ESSENTIAL)
    .build()

  @Before
  @ExperimentalCoroutinesApi
  fun setUp() {
    setUpTestApplicationComponent()
  }

  @Test
  @ExperimentalCoroutinesApi
  @InternalCoroutinesApi
  fun testStorageHelper_addEventLog_addsLogInStore(){
    logReportStorageHelper.addEventLog(eventLog)
    logReportStorageHelper.getEventLogs().observeForever(mockOppiaEventLogsObserver)

    verify(mockOppiaEventLogsObserver, atLeastOnce()).onChanged(oppiaEventLogResultCaptor.capture())

    val eventLogReport = oppiaEventLogResultCaptor.value.transform { it.getEventLog(0) }.getOrThrow()
    assertThat(eventLogReport.priority).isEqualTo(EventLog.Priority.ESSENTIAL)
  }