🔊 Add debug logging

[xudocci.git] / src / main / java / net / pterodactylus / xdcc / ui / stdin / NetworkAdapter.java

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 (file)
--- 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() {