mirrors/bitcoin-s
1
0
Fork 0
mirror of https://github.com/bitcoin-s/bitcoin-s.git synced 2025-03-26 21:42:48 +01:00
Code Issues Projects Releases Packages Wiki Activity

Fix Promise already completed errors in chainTest (#5440)

Browse source
This commit is contained in:
Chris Stewart 2024-02-29 14:53:55 -06:00 • committed by GitHub
parent 8fb62ad21c
commit 8f812c644f
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 15 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
testkit/src/main/scala/org/bitcoins/testkit/chain/ChainUnitTest.scala
View file

@ -155,50 +155,50 @@ trait ChainUnitTest
*/
def withBlockHeaderDAO(test: OneArgAsyncTest): FutureOutcome = {
makeFixture(build = () => ChainUnitTest.createBlockHeaderDAO(),
destroy = () => ChainUnitTest.destroyAllTables())(test)
destroy = () => ChainUnitTest.destroyChainApi())(test)
}
/** Creates a compact filter DAO with zero rows in it */
def withCompactFilterHeaderDAO(test: OneArgAsyncTest): FutureOutcome = {
makeFixture(build = () => ChainUnitTest.createFilterHeaderDAO(),
destroy = () => ChainUnitTest.destroyAllTables())(test)
destroy = () => ChainUnitTest.destroyChainApi())(test)
}
/** Creates a compact filter DAO with zero rows in it */
def withCompactFilterDAO(test: OneArgAsyncTest): FutureOutcome = {
makeFixture(build = () => ChainUnitTest.createFilterDAO(),
destroy = () => ChainUnitTest.destroyAllTables())(test)
destroy = () => ChainUnitTest.destroyChainApi())(test)
}
def withPopulatedBlockHeaderDAO(test: OneArgAsyncTest): FutureOutcome = {
makeFixture(build = () => ChainUnitTest.createPopulatedBlockHeaderDAO(),
destroy = () => ChainUnitTest.destroyAllTables())(test)
destroy = () => ChainUnitTest.destroyChainApi())(test)
}
def withChainStateDescriptorDAO(test: OneArgAsyncTest): FutureOutcome = {
makeFixture(build = () => ChainUnitTest.createChainStateDescriptorDAO(),
destroy = () => ChainUnitTest.destroyAllTables())(test)
destroy = () => ChainUnitTest.destroyChainApi())(test)
}
def withChainHandler(test: OneArgAsyncTest): FutureOutcome = {
makeFixture(() => ChainUnitTest.createChainHandler(),
() => ChainUnitTest.destroyAllTables())(test)
() => ChainUnitTest.destroyChainApi())(test)
}
def withChainHandlerCached(test: OneArgAsyncTest): FutureOutcome = {
makeFixture(() => ChainUnitTest.createChainHandlerCached(),
() => ChainUnitTest.destroyAllTables())(test)
() => ChainUnitTest.destroyChainApi())(test)
}
def withChainHandlerGenesisFilter(test: OneArgAsyncTest): FutureOutcome = {
makeFixture(() => createChainHandlerWithGenesisFilter(),
() => ChainUnitTest.destroyAllTables())(test)
() => ChainUnitTest.destroyChainApi())(test)
}
def withChainHandlerCachedGenesisFilter(
test: OneArgAsyncTest): FutureOutcome = {
makeFixture(build = () => createChainHandlerCachedWithGenesisFilter(),
destroy = () => ChainUnitTest.destroyAllTables())(test)
destroy = () => ChainUnitTest.destroyChainApi())(test)
}
/** Creates and populates BlockHeaderTable with block headers 562375 to 571375 */
@ -742,7 +742,12 @@ object ChainUnitTest extends ChainVerificationLogger {
def destroyChainApi()(implicit
system: ActorSystem,
chainAppConfig: ChainAppConfig): Future[Unit] = {
ChainUnitTest.destroyAllTables()(chainAppConfig, system.dispatcher)
import system.dispatcher
for {
_ <- ChainUnitTest.destroyAllTables()
_ = chainAppConfig.clearCallbacks()
} yield ()
}
def buildNHeaders(chainHandler: ChainHandler, target: Int)(implicit