X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fxdcc%2Fui%2Fstdin%2FNetworkAdapter.java;h=bfbaee5d172d934aa4bd4d13429a26ace88f3b8a;hb=d0e924c1f40b388082313173ea5f653a0dc66e2e;hp=cff376a3d3887c8764386d2f60c583f2ef727dc4;hpb=cbb2c04b71b9a923068449823caaad686a038d8c;p=xudocci.git

diff --git a/src/main/java/net/pterodactylus/xdcc/ui/stdin/NetworkAdapter.java b/src/main/java/net/pterodactylus/xdcc/ui/stdin/NetworkAdapter.java
index cff376a..bfbaee5 100644
--- a/src/main/java/net/pterodactylus/xdcc/ui/stdin/NetworkAdapter.java
+++ b/src/main/java/net/pterodactylus/xdcc/ui/stdin/NetworkAdapter.java
@@ -42,23 +42,24 @@ public class NetworkAdapter extends AbstractExecutionThreadService {
 	/** The event bus. */
 	private final EventBus eventBus;
 
-	/** The core being controlled. */
-	private final Core core;
+	private final CommandReaderFactory commandReaderFactory;
+	private final int port;
 
 	/**
 	 * Creates a new network acceptor.
 	 *
 	 * @param eventBus
-	 * @param core
+	 * @param commandReaderFactory
 	 */
-	public NetworkAdapter(EventBus eventBus, Core core) {
+	public NetworkAdapter(EventBus eventBus, CommandReaderFactory commandReaderFactory, int port) {
 		this.eventBus = eventBus;
-		this.core = core;
+		this.commandReaderFactory = commandReaderFactory;
+		this.port = port;
 	}
 
 	@Override
 	protected void run() throws Exception {
-		ServerSocket serverSocket = new ServerSocket(45678);
+		ServerSocket serverSocket = new ServerSocket(port);
 		serverSocket.setSoTimeout((int) TimeUnit.SECONDS.toMillis(1));
 		while (isRunning()) {
 			try {
@@ -67,7 +68,7 @@ public class NetworkAdapter extends AbstractExecutionThreadService {
 				OutputStream socketOutputStream = clientSocket.getOutputStream();
 				final InputStreamReader socketInputStreamReader = new InputStreamReader(socketInputStream, "UTF-8");
 				final OutputStreamWriter socketOutputStreamWriter = new OutputStreamWriter(socketOutputStream, "UTF-8");
-				final CommandReader commandReader = new CommandReader(core, socketInputStreamReader, socketOutputStreamWriter);
+				final CommandReader commandReader = commandReaderFactory.create(socketInputStreamReader, socketOutputStreamWriter);
 				eventBus.register(commandReader);
 				commandReader.addListener(new Listener() {