src/main/java/org/hedgecode/chess/uci/ConsoleAcceptorRunner.java

   1 /*
   2  * Copyright (c) 2018. Developed by Hedgecode.
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  *   http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16
  17 package org.hedgecode.chess.uci;
  18
  19 import java.io.InputStream;
  20 import java.io.OutputStream;
  21
  22 import org.hedgecode.chess.uci.annotation.CommandDirection;
  23 import org.hedgecode.chess.uci.command.CommandParams;
  24
  25 /**
  26  *
  27  *
  28  * @author Dmitry Samoshin aka gotty
  29  */
  30 public final class ConsoleAcceptorRunner implements AcceptorRunner {
  31
  32     private ConsoleAcceptor acceptor;
  33
  34     private boolean isRunning;
  35
  36     ConsoleAcceptorRunner() {
  37         acceptor = new ConsoleAcceptor(
  38                 System.in, System.out
  39         );
  40         isRunning = false;
  41     }
  42
  43     ConsoleAcceptorRunner(InputStream input, OutputStream output) {
  44         acceptor = new ConsoleAcceptor(
  45                 input, output
  46         );
  47         isRunning = false;
  48     }
  49
  50     @Override
  51     public Acceptor init() throws AcceptorException {
  52         if (isRunning)
  53             throw new AcceptorException("uci.acceptor.already.run");
  54         return acceptor;
  55     }
  56
  57     public void run(final CommandExecutor commandExecutor) throws AcceptorException {
  58         if (isRunning)
  59             throw new AcceptorException("uci.acceptor.already.run");
  60
  61         Thread engineThread = new Thread(
  62                 new Runnable() {
  63                     public void run() {
  64                         Transmitter<String> acceptorTransmitter = acceptor.transmitter();
  65                         try {
  66                             while (acceptorTransmitter.isActive()) {
  67                                 if (acceptorTransmitter.hasCommand()) {
  68                                     String command = acceptorTransmitter.transmitCommand();
  69                                     if (command.isEmpty()) continue;
  70                                     CommandParams commandParams = new CommandParams(command);
  71                                     commandExecutor.exec(
  72                                             commandParams.getName(),
  73                                             CommandDirection.TO_ENGINE,
  74                                             commandParams.getParams()
  75                                     );
  76                                     if (UCIConstants.QUIT.equals(commandParams.getName()))
  77                                         acceptorTransmitter.stop();
  78                                 }
  79                             }
  80                         } finally {
  81                             acceptorTransmitter.close();
  82                             isRunning = false;
  83                         }
  84                     }
  85                 }
  86         );
  87         engineThread.start();
  88         isRunning = true;
  89     }
  90
  91 }