diff --git a/node/src/main/scala/org/bitcoins/node/Node.scala b/node/src/main/scala/org/bitcoins/node/Node.scala index aa14e0756a..b2697fdf4f 100644 --- a/node/src/main/scala/org/bitcoins/node/Node.scala +++ b/node/src/main/scala/org/bitcoins/node/Node.scala @@ -1,7 +1,7 @@ package org.bitcoins.node import org.apache.pekko.actor.ActorSystem -import org.bitcoins.chain.blockchain.ChainHandlerCached +import org.bitcoins.chain.blockchain.{ChainHandler} import org.bitcoins.chain.config.ChainAppConfig import org.bitcoins.chain.models.{ BlockHeaderDAO, @@ -48,11 +48,12 @@ trait Node * our [[org.bitcoins.chain.blockchain.Blockchain Blockchain]] */ def chainApiFromDb()(implicit - executionContext: ExecutionContext): Future[ChainHandlerCached] = { - ChainHandlerCached.fromDatabase(BlockHeaderDAO(), - CompactFilterHeaderDAO(), - CompactFilterDAO(), - ChainStateDescriptorDAO()) + executionContext: ExecutionContext): Future[ChainApi] = { + val c = ChainHandler.fromDatabase(BlockHeaderDAO(), + CompactFilterHeaderDAO(), + CompactFilterDAO(), + ChainStateDescriptorDAO()) + Future.successful(c) } /** Starts our node */ diff --git a/node/src/main/scala/org/bitcoins/node/PeerManager.scala b/node/src/main/scala/org/bitcoins/node/PeerManager.scala index 8adcc666d6..2306a87ae8 100644 --- a/node/src/main/scala/org/bitcoins/node/PeerManager.scala +++ b/node/src/main/scala/org/bitcoins/node/PeerManager.scala @@ -608,7 +608,7 @@ case class PeerManager( .map(_._2) peerDataOpt match { case None => - logger.warn( + logger.debug( s"Ignoring received msg=${payload.commandName} from peer=$peer because it was disconnected, peers=$peers state=${state}") Future.successful(state) case Some(peerData) => diff --git a/node/src/main/scala/org/bitcoins/node/networking/peer/DataMessageHandler.scala b/node/src/main/scala/org/bitcoins/node/networking/peer/DataMessageHandler.scala index acc9faa04e..48b3cd9122 100644 --- a/node/src/main/scala/org/bitcoins/node/networking/peer/DataMessageHandler.scala +++ b/node/src/main/scala/org/bitcoins/node/networking/peer/DataMessageHandler.scala @@ -58,7 +58,7 @@ case class DataMessageHandler( val isQueryTimedOut = state.isQueryTimedOut(appConfig.queryWaitTime) if (peerData.peer != syncPeer && !isQueryTimedOut) { //ignore message from peers that we aren't syncing with during IBD - logger.info( + logger.debug( s"Ignoring message ${payload.commandName} from peer=${peerData.peer} in state=$state because we are syncing with this peer currently. syncPeer=$syncPeer") Future.successful(this) } else {