Add base schema

Author: Madzi

pom.xml

@@ -35,6 +35,16 @@
                 <artifactId>javafx-controls</artifactId>
                 <version>18.0.1</version>
             </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+            <version>2.0.6</version>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-simple</artifactId>
+            <version>2.0.6</version>
+        </dependency>
             <dependency>
                 <groupId>org.jruby</groupId>
                 <artifactId>jruby</artifactId>
@@ -116,6 +126,14 @@
             <groupId>org.openjfx</groupId>
             <artifactId>javafx-controls</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-simple</artifactId>
+        </dependency>
     </dependencies>
 
     <reporting>

src/main/java/ifml3/api/ComponentConnector.java

@@ -0,0 +1,11 @@
+package ifml3.api;
+
+import java.util.concurrent.Flow.Publisher;
+import java.util.concurrent.Flow.Subscriber;
+
+public interface ComponentConnector<IN, OUT> {
+
+    Subscriber<IN> subscriber();
+
+    Publisher<OUT> publisher();
+}

src/main/java/ifml3/api/internal/BaseComponentConnector.java

@@ -0,0 +1,11 @@
+package ifml3.api.internal;
+
+import ifml3.api.ComponentConnector;
+import java.util.concurrent.Flow.Publisher;
+import java.util.concurrent.Flow.Subscriber;
+
+public record BaseComponentConnector<IN, OUT>(
+        Subscriber<IN> subscriber,
+        Publisher<OUT> publisher
+) implements ComponentConnector<IN, OUT> {
+}

src/main/java/ifml3/api/internal/BaseSubscriber.java

@@ -0,0 +1,37 @@
+package ifml3.api.internal;
+
+import java.util.concurrent.Flow.Subscriber;
+import java.util.concurrent.Flow.Subscription;
+import java.util.function.Consumer;
+
+public class BaseSubscriber<T> implements Subscriber<T> {
+
+    private final Consumer<T> consumer;
+
+    private Subscription subscription;
+
+    public BaseSubscriber(final Consumer<T> consumer) {
+        this.consumer = consumer;
+    }
+
+    @Override
+    public void onSubscribe(final Subscription subscription) {
+        this.subscription = subscription;
+        this.subscription.request(1L);
+    }
+
+    @Override
+    public void onNext(final T item) {
+        consumer.accept(item);
+        subscription.request(1L);
+    }
+
+    @Override
+    public void onError(final Throwable throwable) {
+        throw new IllegalStateException(throwable);
+    }
+
+    @Override
+    public void onComplete() {
+    }
+}

src/main/java/ifml3/app/Ifml3App.java

@@ -5,23 +5,54 @@
 import ifml3.app.i18n.Translation;
 import ifml3.app.view.MainView;
 import ifml3.app.view.View;
+import ifml3.app.view.ui.internal.PlayerComponent;
+import ifml3.engine.Engine;
+import ifml3.engine.internal.SimpleEngine;
+import ifml3.lexer.Lexer;
+import ifml3.lexer.internal.SimpleLexer;
 import java.util.ResourceBundle;
 import javafx.application.Application;
 import javafx.stage.Stage;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 public class Ifml3App extends Application {
 
+    private static final Logger logger = LoggerFactory.getLogger(Ifml3App.class);
+
     private Translation translation;
     private View view;
+    private PlayerComponent player;
+    private Lexer lexer;
+    private Engine engine;
 
     @Override
     public void init() {
+        logger.info("Initialization...");
         this.translation = new AppTranslation(ResourceBundle.getBundle("lang/ifml3"));
-        this.view = new MainView(translation);
+        final var mainView = new MainView(translation);
+        this.view = mainView;
+        this.player = mainView.player();
+        this.lexer = new SimpleLexer();
+        this.engine = new SimpleEngine();
+        connectComponents();
+    }
+
+    private void connectComponents() {
+        logger.info("Connect components");
+        final var playerConnector = player.uiConnector();
+        final var uiConnector = lexer.uiConnector();
+        final var engineConnector = lexer.engineConnector();
+        final var lexerConnector = engine.lexerConnector();
+        playerConnector.publisher().subscribe(uiConnector.subscriber());
+        uiConnector.publisher().subscribe(playerConnector.subscriber());
+        lexerConnector.publisher().subscribe(engineConnector.subscriber());
+        engineConnector.publisher().subscribe(lexerConnector.subscriber());
     }
 
     @Override
     public void start(final Stage stage) throws Exception {
+        logger.info("Start application");
         stage.setScene(view.scene());
         stage.setTitle(translation.message(AppMessage.APP_TITLE));
         stage.show();

src/main/java/ifml3/app/view/MainView.java

@@ -1,7 +1,9 @@
 package ifml3.app.view;
 
+import ifml3.api.ComponentConnector;
 import ifml3.app.i18n.AppMessage;
 import ifml3.app.i18n.Translation;
+import ifml3.app.view.ui.internal.PlayerComponent;
 import javafx.scene.Scene;
 import javafx.scene.control.ComboBox;
 import javafx.scene.control.Label;
@@ -14,10 +16,12 @@ public class MainView implements View {
 
     private final Translation translation;
     private final Scene scene;
+    private final PlayerComponent player;
 
     public MainView(final Translation translation) {
         this.translation = translation;
-        final var pane = new BorderPane(label("center"), menuBar(), label("right"), inputLine(), treeView());
+        this.player = new PlayerComponent();
+        final var pane = new BorderPane(player.get(), menuBar(), label("right"), inputLine(), treeView());
         scene = new Scene(pane, 800.0, 600.0);
     }
 
@@ -26,6 +30,10 @@ public Scene scene() {
         return scene;
     }
 
+    public PlayerComponent player() {
+        return player;
+    }
+
     private Label label(final String text) {
         return new Label(text);
     }

src/main/java/ifml3/app/view/ui/UIComponent.java

@@ -0,0 +1,8 @@
+package ifml3.app.view.ui;
+
+import javafx.scene.Parent;
+
+public interface UIComponent {
+
+    Parent get();
+}

src/main/java/ifml3/app/view/ui/internal/PlayerComponent.java

@@ -0,0 +1,72 @@
+package ifml3.app.view.ui.internal;
+
+import ifml3.api.ComponentConnector;
+import ifml3.api.internal.BaseComponentConnector;
+import ifml3.api.internal.BaseSubscriber;
+import ifml3.app.view.ui.UIComponent;
+import ifml3.ui.TextSanitizer;
+import ifml3.ui.UserCommand;
+import ifml3.ui.UserInterface;
+import ifml3.ui.UserMessage;
+import ifml3.ui.internal.UserTextSanitizer;
+import java.util.concurrent.Flow.Subscriber;
+import java.util.concurrent.SubmissionPublisher;
+import javafx.event.ActionEvent;
+import javafx.scene.Parent;
+import javafx.scene.control.TextArea;
+import javafx.scene.control.TextField;
+import javafx.scene.layout.VBox;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class PlayerComponent implements UIComponent, UserInterface {
+
+    private static final Logger logger = LoggerFactory.getLogger(PlayerComponent.class);
+
+    private final SubmissionPublisher<UserCommand> publisher;
+    private final Subscriber<UserMessage> subscriber;
+    private final TextSanitizer sanitizer;
+    private final ComponentConnector<UserMessage, UserCommand> connector;
+    private final VBox vBox;
+    private final TextArea textArea;
+    private final TextField textField;
+
+    public PlayerComponent() {
+        // @todo at least sanitizer should be as dependency
+        this.sanitizer = new UserTextSanitizer();
+        this.publisher = new SubmissionPublisher<>();
+        this.textArea = new TextArea();
+        this.textArea.setEditable(false);
+        this.textArea.setPrefRowCount(1_000);
+        this.textField = new TextField();
+        this.textField.setOnAction(this::processCommand);
+        this.vBox = new VBox(textArea, textField);
+        this.subscriber = new BaseSubscriber<>(this::processMessage);
+        this.connector = new BaseComponentConnector<>(subscriber, publisher);
+    }
+
+    @Override
+    public Parent get() {
+        return vBox;
+    }
+
+    @Override
+    public ComponentConnector<UserMessage, UserCommand> uiConnector() {
+        return connector;
+    }
+
+    private void processCommand(final ActionEvent event) {
+        final var text = textField.getText();
+        logger.info("Input from user: '{}'", text);
+        textField.setText("");
+        textArea.appendText("> " + text + "\n");
+        final var input = sanitizer.sanitize(text);
+        // @todo preprocessing needed
+        publisher.submit(() -> input);
+    }
+
+    private void processMessage(final UserMessage message) {
+        logger.info("Get message for user: {}", message);
+        textArea.appendText("\n" + message.message() + "\n\n");
+    }
+}

src/main/java/ifml3/engine/Engine.java

@@ -0,0 +1,8 @@
+package ifml3.engine;
+
+import ifml3.api.ComponentConnector;
+
+public interface Engine {
+
+    ComponentConnector<EngineCommand, EngineMessage> lexerConnector();
+}

src/main/java/ifml3/engine/EngineCommand.java

@@ -0,0 +1,10 @@
+package ifml3.engine;
+
+import ifml3.lexer.Phrase;
+import java.util.Collection;
+
+@FunctionalInterface
+public interface EngineCommand {
+
+    Collection<Phrase> phrases();
+}