neutrino_sync.scala

import java.net.InetSocketAddress

import akka.actor.ActorSystem
import org.bitcoins.node.models.Peer
import org.bitcoins.node.{NeutrinoNode, SpvNodeCallbacks}
import org.bitcoins.server.BitcoinSAppConfig

object neutrino_sync extends App {
  val system = ActorSystem()

  implicit val executionContext = system.dispatcher

  val conf = BitcoinSAppConfig.fromDefaultDatadir()

  val peer = Peer.fromSocket(
    new InetSocketAddress(conf.nodeConf.peers.head, conf.nodeConf.network.port))

  val node =
    NeutrinoNode(peer,
                 SpvNodeCallbacks.empty,
                 conf.nodeConf,
                 conf.chainConf,
                 system)

  for {
    startedNode <- node.start()
    _ <- startedNode.sync()
  } yield ()
}