Lab4

src/main/java/com/itmo/java/basics/DatabaseServer.java

@@ -2,7 +2,9 @@
 
 import com.itmo.java.basics.console.*;
 import com.itmo.java.basics.exceptions.DatabaseException;
-import com.itmo.java.basics.initialization.impl.*;
+import com.itmo.java.basics.initialization.InitializationContext;
+import com.itmo.java.basics.initialization.impl.DatabaseServerInitializer;
+import com.itmo.java.basics.initialization.impl.InitializationContextImpl;
 import com.itmo.java.protocol.model.RespArray;
 
 import java.util.concurrent.CompletableFuture;
@@ -11,31 +13,36 @@
 
 public class DatabaseServer {
 
-    private final ExecutorService executorService = Executors.newSingleThreadExecutor();
-    private final ExecutionEnvironment enviroment;
+    private ExecutorService executorService = Executors.newSingleThreadExecutor();
+    private final ExecutionEnvironment environment;
 
     /**
-     * Con structor
+     * Конструктор
      *
-     * @param env         env для инициализации. Далее работа происходит с заполненым объектом
+     * @param env         env для инициализации. Далее работа происходит с заполненным объектом
      * @param initializer готовый чейн инициализации
      * @throws DatabaseException если произошла ошибка инициализации
      */
     public static DatabaseServer initialize(ExecutionEnvironment env, DatabaseServerInitializer initializer) throws DatabaseException {
-        initializer.perform(new InitializationContextImpl(env, null, null, null));
+        InitializationContext context = InitializationContextImpl.builder().executionEnvironment(env).build();
+        initializer.perform(context);
         return new DatabaseServer(env);
     }
 
     private DatabaseServer(ExecutionEnvironment env) {
-        this.enviroment = env;
+        this.environment = env;
     }
 
     public CompletableFuture<DatabaseCommandResult> executeNextCommand(RespArray message) {
-        return CompletableFuture.supplyAsync(() ->
-                        DatabaseCommands.valueOf(message.getObjects().get(DatabaseCommandArgPositions.COMMAND_NAME.getPositionIndex()).asString()).getCommand(enviroment, message.getObjects()).execute(), executorService);
+        return CompletableFuture.supplyAsync(() -> DatabaseCommands.valueOf(message.getObjects().get(DatabaseCommandArgPositions.
+                COMMAND_NAME.getPositionIndex()).asString()).getCommand(environment, message.getObjects()).execute(), executorService);
     }
 
     public CompletableFuture<DatabaseCommandResult> executeNextCommand(DatabaseCommand command) {
         return CompletableFuture.supplyAsync(command::execute, executorService);
     }
+
+    public ExecutionEnvironment getEnv() {
+        return environment;
+    }
 }

src/main/java/com/itmo/java/basics/config/ConfigLoader.java

@@ -0,0 +1,89 @@
+package com.itmo.java.basics.config;
+
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Properties;
+
+/**
+ * Класс, отвечающий за подгрузку данных из конфигурационного файла формата .properties
+ */
+public class ConfigLoader {
+    private static final String DEFAULT_PROPERTY_FILE = "server.properties";
+
+    private InputStream propertyInputStream;
+
+    /**
+     * По умолчанию читает из server.properties
+     */
+    public ConfigLoader() {
+        propertyInputStream = getClass().getClassLoader().getResourceAsStream(DEFAULT_PROPERTY_FILE);
+        if (this.propertyInputStream == null) {
+            try {
+                this.propertyInputStream = new FileInputStream(DEFAULT_PROPERTY_FILE);
+            } catch (FileNotFoundException e) {
+                this.propertyInputStream = null;
+            }
+        }
+    }
+
+    /**
+     * @param name Имя конфикурационного файла, откуда читать
+     */
+    public ConfigLoader(String name) {
+        this.propertyInputStream = getClass().getClassLoader().getResourceAsStream(name);
+        if (this.propertyInputStream == null) {
+            try {
+                this.propertyInputStream = new FileInputStream(name);
+            } catch (FileNotFoundException e) {
+                this.propertyInputStream = null;
+            }
+        }
+    }
+
+    /**
+     * Считывает конфиг из указанного в конструкторе файла.
+     * Если не удалось считать из заданного файла, или какого-то конкретно значения не оказалось,
+     * то используют дефолтные значения из {@link DatabaseConfig} и {@link ServerConfig}
+     * <br/>
+     * Читаются: "kvs.workingPath", "kvs.host", "kvs.port" (но в конфигурационном файле допустимы и другие проперти)
+     */
+    public DatabaseServerConfig readConfig() {
+        Properties properties = new Properties();
+        try {
+            if (propertyInputStream == null) {
+                throw new IOException("Config file not found");
+            }
+            properties.load(propertyInputStream);
+            String workingPath = properties.getProperty("kvs.workingPath");
+            String host = properties.getProperty("kvs.host");
+            String portStr = properties.getProperty("kvs.port");
+            DatabaseConfig databaseConfig;
+            ServerConfig serverConfig;
+            if (workingPath == null) {
+                databaseConfig = new DatabaseConfig();
+            } else {
+                databaseConfig = new DatabaseConfig(workingPath);
+            }
+            if (host == null){
+                host = ServerConfig.DEFAULT_HOST;
+            }
+            try {
+                int port = Integer.parseInt(portStr);
+                serverConfig = new ServerConfig(host, port);
+            } catch (NumberFormatException e) {
+                serverConfig = new ServerConfig(host, ServerConfig.DEFAULT_PORT);
+            }
+            return DatabaseServerConfig.builder()
+                    .dbConfig(databaseConfig)
+                    .serverConfig(serverConfig)
+                    .build();
+        } catch (IOException e) {
+            return DatabaseServerConfig.builder()
+                    .dbConfig(new DatabaseConfig())
+                    .serverConfig(new ServerConfig(ServerConfig.DEFAULT_HOST, ServerConfig.DEFAULT_PORT))
+                    .build();
+        }
+    }
+}

src/main/java/com/itmo/java/basics/config/DatabaseConfig.java

@@ -1,14 +1,18 @@
 package com.itmo.java.basics.config;
 
-public class DatabaseConfig {
 
+public class DatabaseConfig {
     public static final String DEFAULT_WORKING_PATH = "db_files";
     private final String workingPath;
 
     public DatabaseConfig(String workingPath) {
         this.workingPath = workingPath;
     }
 
+    public DatabaseConfig(){
+        this.workingPath = DEFAULT_WORKING_PATH;
+    }
+
     public String getWorkingPath() {
         return workingPath;
     }

src/main/java/com/itmo/java/basics/config/DatabaseServerConfig.java

@@ -0,0 +1,14 @@
+package com.itmo.java.basics.config;
+
+import lombok.Builder;
+import lombok.Getter;
+import lombok.ToString;
+
+@ToString
+@Getter
+@Builder
+public class DatabaseServerConfig {
+    private final ServerConfig serverConfig;
+
+    private final DatabaseConfig dbConfig;
+}

src/main/java/com/itmo/java/basics/config/ServerConfig.java

@@ -0,0 +1,19 @@
+package com.itmo.java.basics.config;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * Какой хост и какой порт будет слушать наш сервер
+ */
+@Getter
+@AllArgsConstructor
+public class ServerConfig {
+
+    public static final String DEFAULT_HOST = "localhost";
+    public static final int DEFAULT_PORT = 8080;
+
+    private final String host;
+    private final int port;
+
+}