diff --git a/core/src/main/java/io/bitsquare/app/BitsquareAppMain.java b/core/src/main/java/io/bitsquare/app/BitsquareAppMain.java index 5f79d1c83d..1d08eb8510 100644 --- a/core/src/main/java/io/bitsquare/app/BitsquareAppMain.java +++ b/core/src/main/java/io/bitsquare/app/BitsquareAppMain.java @@ -40,7 +40,7 @@ import joptsimple.OptionSet; import static io.bitsquare.app.BitsquareEnvironment.*; import static io.bitsquare.network.Node.*; -import static io.bitsquare.network.tomp2p.TomP2PNetworkModule.*; +import static io.bitsquare.network.tomp2p.TomP2PModule.*; import static java.util.Arrays.asList; public class BitsquareAppMain extends BitsquareExecutable { diff --git a/core/src/main/java/io/bitsquare/app/BitsquareAppModule.java b/core/src/main/java/io/bitsquare/app/BitsquareAppModule.java index fdfc028ba2..90726937e1 100644 --- a/core/src/main/java/io/bitsquare/app/BitsquareAppModule.java +++ b/core/src/main/java/io/bitsquare/app/BitsquareAppModule.java @@ -18,13 +18,13 @@ package io.bitsquare.app; import io.bitsquare.BitsquareModule; -import io.bitsquare.arbitration.ArbitratorMessageModule; -import io.bitsquare.arbitration.tomp2p.TomP2PArbitratorMessageModule; +import io.bitsquare.arbitration.ArbitratorModule; +import io.bitsquare.arbitration.tomp2p.TomP2PArbitratorModule; import io.bitsquare.btc.BitcoinModule; import io.bitsquare.crypto.CryptoModule; import io.bitsquare.gui.GuiModule; import io.bitsquare.network.NetworkModule; -import io.bitsquare.network.tomp2p.TomP2PNetworkModule; +import io.bitsquare.network.tomp2p.TomP2PModule; import io.bitsquare.offer.OfferModule; import io.bitsquare.offer.tomp2p.TomP2POfferModule; import io.bitsquare.persistence.Persistence; @@ -76,12 +76,12 @@ class BitsquareAppModule extends BitsquareModule { install(guiModule()); } - protected ArbitratorMessageModule arbitratorMessageModule() { - return new TomP2PArbitratorMessageModule(env); + protected ArbitratorModule arbitratorMessageModule() { + return new TomP2PArbitratorModule(env); } protected NetworkModule networkModule() { - return new TomP2PNetworkModule(env); + return new TomP2PModule(env); } protected BitcoinModule bitcoinModule() { diff --git a/core/src/main/java/io/bitsquare/arbitration/ArbitratorMessageModule.java b/core/src/main/java/io/bitsquare/arbitration/ArbitratorModule.java similarity index 88% rename from core/src/main/java/io/bitsquare/arbitration/ArbitratorMessageModule.java rename to core/src/main/java/io/bitsquare/arbitration/ArbitratorModule.java index 172464fa76..60d9dfdd58 100644 --- a/core/src/main/java/io/bitsquare/arbitration/ArbitratorMessageModule.java +++ b/core/src/main/java/io/bitsquare/arbitration/ArbitratorModule.java @@ -21,9 +21,9 @@ import io.bitsquare.BitsquareModule; import org.springframework.core.env.Environment; -public abstract class ArbitratorMessageModule extends BitsquareModule { +public abstract class ArbitratorModule extends BitsquareModule { - protected ArbitratorMessageModule(Environment env) { + protected ArbitratorModule(Environment env) { super(env); } diff --git a/core/src/main/java/io/bitsquare/arbitration/ArbitratorService.java b/core/src/main/java/io/bitsquare/arbitration/ArbitratorService.java index 75380eb1e7..917742d1fb 100644 --- a/core/src/main/java/io/bitsquare/arbitration/ArbitratorService.java +++ b/core/src/main/java/io/bitsquare/arbitration/ArbitratorService.java @@ -22,11 +22,8 @@ import io.bitsquare.arbitration.listeners.ArbitratorListener; import io.bitsquare.network.DHTService; import java.util.Locale; -import java.util.concurrent.Executor; public interface ArbitratorService extends DHTService { - void setExecutor(Executor executor); - void addArbitrator(Arbitrator arbitrator); void addArbitratorListener(ArbitratorListener listener); diff --git a/core/src/main/java/io/bitsquare/arbitration/tomp2p/TomP2PArbitratorMessageModule.java b/core/src/main/java/io/bitsquare/arbitration/tomp2p/TomP2PArbitratorModule.java similarity index 84% rename from core/src/main/java/io/bitsquare/arbitration/tomp2p/TomP2PArbitratorMessageModule.java rename to core/src/main/java/io/bitsquare/arbitration/tomp2p/TomP2PArbitratorModule.java index d2d6d3dfcf..b5b29f6386 100644 --- a/core/src/main/java/io/bitsquare/arbitration/tomp2p/TomP2PArbitratorMessageModule.java +++ b/core/src/main/java/io/bitsquare/arbitration/tomp2p/TomP2PArbitratorModule.java @@ -17,16 +17,16 @@ package io.bitsquare.arbitration.tomp2p; -import io.bitsquare.arbitration.ArbitratorMessageModule; +import io.bitsquare.arbitration.ArbitratorModule; import io.bitsquare.arbitration.ArbitratorService; import com.google.inject.Singleton; import org.springframework.core.env.Environment; -public class TomP2PArbitratorMessageModule extends ArbitratorMessageModule { +public class TomP2PArbitratorModule extends ArbitratorModule { - public TomP2PArbitratorMessageModule(Environment env) { + public TomP2PArbitratorModule(Environment env) { super(env); } diff --git a/core/src/main/java/io/bitsquare/network/DHTService.java b/core/src/main/java/io/bitsquare/network/DHTService.java index d5325851b6..811c7337b6 100644 --- a/core/src/main/java/io/bitsquare/network/DHTService.java +++ b/core/src/main/java/io/bitsquare/network/DHTService.java @@ -25,7 +25,7 @@ import net.tomp2p.dht.FutureRemove; import net.tomp2p.peers.Number160; import net.tomp2p.storage.Data; -public interface DHTService extends NetworkService { +public interface DHTService extends P2PService { FuturePut putDomainProtectedData(Number160 locationKey, Data data); diff --git a/core/src/main/java/io/bitsquare/network/MessageService.java b/core/src/main/java/io/bitsquare/network/MessageService.java index 9cae479de1..f9f1619cfe 100644 --- a/core/src/main/java/io/bitsquare/network/MessageService.java +++ b/core/src/main/java/io/bitsquare/network/MessageService.java @@ -20,7 +20,7 @@ package io.bitsquare.network; import io.bitsquare.network.listener.SendMessageListener; -public interface MessageService extends NetworkService, MessageHandler { +public interface MessageService extends P2PService, MessageHandler { void sendMessage(Peer peer, Message message, SendMessageListener listener); diff --git a/core/src/main/java/io/bitsquare/network/NetworkService.java b/core/src/main/java/io/bitsquare/network/P2PService.java similarity index 96% rename from core/src/main/java/io/bitsquare/network/NetworkService.java rename to core/src/main/java/io/bitsquare/network/P2PService.java index f923ad2227..68e78b7a2c 100644 --- a/core/src/main/java/io/bitsquare/network/NetworkService.java +++ b/core/src/main/java/io/bitsquare/network/P2PService.java @@ -19,7 +19,7 @@ package io.bitsquare.network; import java.util.concurrent.Executor; -public interface NetworkService { +public interface P2PService { void setExecutor(Executor executor); void bootstrapCompleted(); diff --git a/core/src/main/java/io/bitsquare/network/tomp2p/TomP2PNetworkModule.java b/core/src/main/java/io/bitsquare/network/tomp2p/TomP2PModule.java similarity index 96% rename from core/src/main/java/io/bitsquare/network/tomp2p/TomP2PNetworkModule.java rename to core/src/main/java/io/bitsquare/network/tomp2p/TomP2PModule.java index c99244d476..7332b529b4 100644 --- a/core/src/main/java/io/bitsquare/network/tomp2p/TomP2PNetworkModule.java +++ b/core/src/main/java/io/bitsquare/network/tomp2p/TomP2PModule.java @@ -32,14 +32,14 @@ import org.springframework.core.env.Environment; import static io.bitsquare.network.tomp2p.BootstrappedPeerBuilder.*; -public class TomP2PNetworkModule extends NetworkModule { +public class TomP2PModule extends NetworkModule { public static final String BOOTSTRAP_NODE_NAME_KEY = "bootstrap.node.name"; public static final String BOOTSTRAP_NODE_IP_KEY = "bootstrap.node.ip"; public static final String BOOTSTRAP_NODE_PORT_KEY = "bootstrap.node.port"; public static final String NETWORK_INTERFACE_KEY = BootstrappedPeerBuilder.NETWORK_INTERFACE_KEY; public static final String USE_MANUAL_PORT_FORWARDING_KEY = BootstrappedPeerBuilder.USE_MANUAL_PORT_FORWARDING_KEY; - public TomP2PNetworkModule(Environment env) { + public TomP2PModule(Environment env) { super(env); } diff --git a/core/src/main/java/io/bitsquare/network/tomp2p/TomP2PService.java b/core/src/main/java/io/bitsquare/network/tomp2p/TomP2PService.java index 7c3619cc8b..c04e62a990 100644 --- a/core/src/main/java/io/bitsquare/network/tomp2p/TomP2PService.java +++ b/core/src/main/java/io/bitsquare/network/tomp2p/TomP2PService.java @@ -18,7 +18,7 @@ package io.bitsquare.network.tomp2p; import io.bitsquare.network.BootstrapState; -import io.bitsquare.network.NetworkService; +import io.bitsquare.network.P2PService; import java.util.concurrent.Executor; @@ -42,7 +42,7 @@ import rx.Subscriber; * That way we limit the dependency of the TomP2P library only to that class (and it's sub components). *

*/ -public class TomP2PService implements NetworkService { +public class TomP2PService implements P2PService { private static final Logger log = LoggerFactory.getLogger(TomP2PService.class); private final Subscriber subscriber; diff --git a/core/src/main/java/io/bitsquare/offer/tomp2p/TomP2POfferModule.java b/core/src/main/java/io/bitsquare/offer/tomp2p/TomP2POfferModule.java index 37d83b52e4..565c6deb1f 100644 --- a/core/src/main/java/io/bitsquare/offer/tomp2p/TomP2POfferModule.java +++ b/core/src/main/java/io/bitsquare/offer/tomp2p/TomP2POfferModule.java @@ -17,17 +17,11 @@ package io.bitsquare.offer.tomp2p; -import io.bitsquare.network.tomp2p.TomP2PNode; import io.bitsquare.offer.OfferBookService; import io.bitsquare.offer.OfferModule; -import com.google.inject.Provider; import com.google.inject.Singleton; -import javax.inject.Inject; - -import javafx.application.Platform; - import org.springframework.core.env.Environment; public class TomP2POfferModule extends OfferModule { @@ -39,20 +33,6 @@ public class TomP2POfferModule extends OfferModule { @Override protected void configure() { super.configure(); - bind(OfferBookService.class).toProvider(OfferBookServiceProvider.class).in(Singleton.class); - } -} - -class OfferBookServiceProvider implements Provider { - private final OfferBookService offerBookService; - - @Inject - public OfferBookServiceProvider(TomP2PNode tomP2PNode) { - offerBookService = new TomP2POfferBookService(tomP2PNode); - offerBookService.setExecutor(Platform::runLater); - } - - public OfferBookService get() { - return offerBookService; + bind(OfferBookService.class).to(TomP2POfferBookService.class).in(Singleton.class); } } \ No newline at end of file