Database: Init module

database/pom.xml

@@ -1,17 +1,47 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-         xmlns="http://maven.apache.org/POM/4.0.0"
-         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
+         http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <name>Database</name>
+
+    <artifactId>database</artifactId>
+    <version>0.1-SNAPSHOT</version>
+    <packaging>bundle</packaging>
+
     <parent>
         <artifactId>arcadexsystem</artifactId>
         <groupId>eu.arcadex.system</groupId>
         <version>${global.version}</version>
     </parent>
 
-    <modelVersion>4.0.0</modelVersion>
-
-    <artifactId>database</artifactId>
-    <packaging>jar</packaging>
-
+    <dependencies>
+        <dependency>
+            <groupId>org.mapdb</groupId>
+            <artifactId>mapdb</artifactId>
+            <version>0.9.7</version>
+        </dependency>
+    </dependencies>
 
+    <build>
+        <finalName>${groupId}.${artifactId}-${version}</finalName>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.felix</groupId>
+                <artifactId>maven-bundle-plugin</artifactId>
+                <version>2.3.5</version>
+                <extensions>true</extensions>
+                <configuration>
+                    <instructions>
+                        <Bundle-Name>Arcadex System: ${name} ${version}</Bundle-Name>
+                        <Bundle-SymbolicName>${groupId}.${artifactId}</Bundle-SymbolicName>
+                        <Bundle-Activator>eu.arcadex.system.database.Activator</Bundle-Activator>
+                        <Export-Package>eu.arcadex.system.database.api</Export-Package>
+                        <Import-Package>*</Import-Package>
+                    </instructions>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
 </project>

database/src/main/java/eu/arcadex/system/database/Activator.java

@@ -0,0 +1,28 @@
+package eu.arcadex.system.database;
+
+import eu.arcadex.system.database.api.IDatabase;
+import org.osgi.framework.BundleActivator;
+import org.osgi.framework.BundleContext;
+import org.osgi.framework.ServiceRegistration;
+
+/**
+ * @author DmitriyMX <mail@dmitriymx.ru>
+ *         2016
+ */
+public class Activator implements BundleActivator {
+    private Database database;
+    private ServiceRegistration<?> service;
+
+    @Override
+    public void start(BundleContext context) throws Exception {
+        database = new Database();
+        database.init();
+        service = context.registerService(IDatabase.class.getName(), database, null);
+    }
+
+    @Override
+    public void stop(BundleContext context) throws Exception {
+        service.unregister();
+        database.save();
+    }
+}

database/src/main/java/eu/arcadex/system/database/Database.java

@@ -0,0 +1,87 @@
+package eu.arcadex.system.database;
+
+import eu.arcadex.system.database.api.IDatabase;
+import org.mapdb.DB;
+import org.mapdb.DBMaker;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.File;
+import java.util.Map;
+
+/**
+ * @author DmitriyMX <mail@dmitriymx.ru>
+ *         2016
+ */
+class Database implements IDatabase {
+    private Logger logger = LoggerFactory.getLogger(Database.class.getName());
+    private DB database;
+    private Map<String, String> databaseStorage;
+    private AutosaveDBThread autosaveThread;
+
+    void init() {
+        database = DBMaker.newFileDB(new File("database"))
+                .closeOnJvmShutdown()
+                .make();
+        databaseStorage = database.createHashMap("storage").makeOrGet();
+
+        autosaveThread = new AutosaveDBThread(database);
+        autosaveThread.start();
+    }
+
+    @Override
+    public boolean containsKey(String key) {
+        return databaseStorage.containsKey(key);
+    }
+
+    @Override
+    public String get(String key) {
+        return databaseStorage.get(key);
+    }
+
+    @Override
+    public void set(String key, String value) {
+        databaseStorage.put(key, value);
+    }
+
+    @Override
+    public void remove(String key) {
+        databaseStorage.remove(key);
+    }
+
+    void save() {
+        logger.trace("Saving database");
+        autosaveThread.stopThread();
+
+        database.commit();
+        database.close();
+    }
+
+    private class AutosaveDBThread extends Thread {
+        private boolean run = false;
+        private DB database;
+
+        AutosaveDBThread(DB db) {
+            this.database = db;
+        }
+
+        void stopThread() {
+            this.run = false;
+        }
+
+        @Override
+        public void run() {
+            run = true;
+
+            while (run) {
+                try {
+                    // TODO: переместить в конфиг
+                    Thread.sleep(60000);
+                } catch (InterruptedException ignore) {
+                    // ignore
+                }
+                database.commit();
+            }
+        }
+    }
+}

database/src/main/java/eu/arcadex/system/database/api/IDatabase.java

@@ -0,0 +1,12 @@
+package eu.arcadex.system.database.api;
+
+/**
+ * @author DmitriyMX <mail@dmitriymx.ru>
+ *         2016
+ */
+public interface IDatabase {
+    boolean containsKey(String key);
+    String get(String key);
+    void set(String key, String value);
+    void remove(String key);
+}