akka/akka-core

PersistenceTestKitReadJournal should implement EventsByTagQuery

Aperta

#29.803 aperta il 10 nov 2020

Vedi su GitHubGuida contributor
 (3 commenti) (1 reazione) (0 assegnatari)Scala (3547 fork)batch import
1 - triagedhelp wantedt:persistencet:testing

Metriche repository

Star
 (13.277 stelle)
Metriche merge PR
 (Merge medio 8g 19h) (10 PR mergiate in 30 g)

Descrizione

The Java + Scala PersistenceTestKitReadJournal implementations implement CurrentEventsByTagQuery but not EventsByTagQuery which prevent them to be used together when testing Akka Projections.

When trying to use the journal in a test, I receive the following runtime exception:

class akka.persistence.testkit.query.scaladsl.PersistenceTestKitReadJournal cannot be cast to class akka.persistence.query.scaladsl.EventsByTagQuery (akka.persistence.testkit.query.scaladsl.PersistenceTestKitReadJournal and akka.persistence.query.scaladsl.EventsByTagQuery are in unnamed module of loader 'app')
java.lang.ClassCastException: class akka.persistence.testkit.query.scaladsl.PersistenceTestKitReadJournal cannot be cast to class akka.persistence.query.scaladsl.EventsByTagQuery (akka.persistence.testkit.query.scaladsl.PersistenceTestKitReadJournal and akka.persistence.query.scaladsl.EventsByTagQuery are in unnamed module of loader 'app')
	at akka.projection.eventsourced.scaladsl.EventSourcedProvider$.eventsByTag(EventSourcedProvider.scala:30)

Guida contributor

Direzione di ricerca
La richiesta richiede l'implementazione dell'interfaccia EventsByTagQuery nelle classi PersistenceTestKitReadJournal sia in Java che in Scala. L'implementazione attuale supporta solo CurrentEventsByTagQuery. Per risolvere, aggiungere il metodo eventsByTag alle classi del journal di lettura Scaladsl e Javadsl, probabilmente nei file come `persistence testkit/src/main/scala/akka/persistence/testkit/query/scaladsl/PersistenceTestKitReadJournal.scala` e il corrispondente file Java. L'implementazione dovrebbe seguire lo stesso schema di currentByTag ma con un offset e una sorgente che trasmette eventi in streaming. Rivedere le implementazioni esistenti come `PersistenceTestKitReadJournal.currentEventsByTag` per orientamento.
Tech stack
scala
Dominio
backendapi
Tipo issue
Funzionalità
DifficoltàQuanto dovrebbe essere impegnativa per un nuovo contributor.
3
Tempo stimatoTempo stimato per completare e verificare uno scope piccolo.
Mezza giornata
Stato attivitàQuanto è probabile che la issue sia ancora attiva e reviewable.
Attiva
ChiarezzaQuanto chiaramente la issue descrive problema, scope e risultato atteso.
Chiara
Prerequisiti
ScalaAkka Persistence
Adatta ai principiantiQuanto la issue è adatta a contributor alla prima esperienza.
60