mirror of
https://github.com/gmbrax/MediaManager-core.git
synced 2026-11-09 22:10:17 +00:00
Compare commits
19
Commits
+9
-1
@@ -39,8 +39,16 @@ build/
|
|||||||
.DS_Store
|
.DS_Store
|
||||||
|
|
||||||
### Application Specific ###
|
### Application Specific ###
|
||||||
application-local.properties
|
config-local.properties
|
||||||
*.db
|
*.db
|
||||||
pipes/
|
pipes/
|
||||||
*.log
|
*.log
|
||||||
/.idea/
|
/.idea/
|
||||||
|
|
||||||
|
Configuration files with sensitive credentials
|
||||||
|
# These files contain database passwords and API keys and should never be committed
|
||||||
|
src/main/resources/config.properties
|
||||||
|
src/main/resources/application.properties
|
||||||
|
|
||||||
|
# Allow example configuration files to be committed
|
||||||
|
!src/main/resources/*.properties.example
|
||||||
@@ -34,7 +34,7 @@ MediaManager-Core/
|
|||||||
│ │ ├── util/ # Utility classes
|
│ │ ├── util/ # Utility classes
|
||||||
│ │ └── MediaManagerApplication.java
|
│ │ └── MediaManagerApplication.java
|
||||||
│ └── resources/
|
│ └── resources/
|
||||||
│ ├── application.properties # App configuration
|
│ ├── config.properties # App configuration
|
||||||
│ ├── log4j2.xml # Logging configuration
|
│ ├── log4j2.xml # Logging configuration
|
||||||
│ └── META-INF/
|
│ └── META-INF/
|
||||||
│ └── persistence.xml # JPA configuration
|
│ └── persistence.xml # JPA configuration
|
||||||
@@ -55,7 +55,7 @@ GRANT ALL PRIVILEGES ON DATABASE mediamanager TO mediamanager;
|
|||||||
|
|
||||||
### 2. Configuration
|
### 2. Configuration
|
||||||
|
|
||||||
Edit `src/main/resources/application.properties` and update the database credentials:
|
Edit `src/main/resources/config.properties` and update the database credentials:
|
||||||
|
|
||||||
```properties
|
```properties
|
||||||
db.url=jdbc:postgresql://localhost:5432/mediamanager
|
db.url=jdbc:postgresql://localhost:5432/mediamanager
|
||||||
@@ -90,7 +90,7 @@ The application creates named pipes for inter-process communication. Default con
|
|||||||
- Pipe name: `mediamanager-pipe`
|
- Pipe name: `mediamanager-pipe`
|
||||||
- Buffer size: 8192 bytes
|
- Buffer size: 8192 bytes
|
||||||
|
|
||||||
You can modify these settings in `application.properties`.
|
You can modify these settings in `config.properties`.
|
||||||
|
|
||||||
## Logging
|
## Logging
|
||||||
|
|
||||||
@@ -116,8 +116,8 @@ mvn test
|
|||||||
|
|
||||||
## Dependencies
|
## Dependencies
|
||||||
|
|
||||||
- PostgreSQL Driver: 42.7.3
|
- PostgreSQL Driver: 42.7.5
|
||||||
- Hibernate ORM: 6.4.4.Final
|
- Hibernate ORM: 7.1.7.Final
|
||||||
- HikariCP: 5.1.0
|
- HikariCP: 5.1.0
|
||||||
- Log4j 2: 2.23.1
|
- Log4j 2: 2.23.1
|
||||||
- Jackson: 2.16.1
|
- Jackson: 2.16.1
|
||||||
|
|||||||
@@ -55,7 +55,7 @@
|
|||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.apache.logging.log4j</groupId>
|
<groupId>org.apache.logging.log4j</groupId>
|
||||||
<artifactId>log4j-slf4j2-impl</artifactId>
|
<artifactId>log4j-slf4j-impl</artifactId>
|
||||||
<version>${log4j.version}</version>
|
<version>${log4j.version}</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
@@ -78,9 +78,27 @@
|
|||||||
<version>${junit.version}</version>
|
<version>${junit.version}</version>
|
||||||
<scope>test</scope>
|
<scope>test</scope>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>com.google.protobuf</groupId>
|
||||||
|
<artifactId>protobuf-java</artifactId>
|
||||||
|
<version>4.32.0</version>
|
||||||
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.xerial</groupId>
|
||||||
|
<artifactId>sqlite-jdbc</artifactId>
|
||||||
|
<version>3.44.1.0</version>
|
||||||
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
<build>
|
<build>
|
||||||
|
<extensions>
|
||||||
|
<extension>
|
||||||
|
<groupId>kr.motd.maven</groupId>
|
||||||
|
<artifactId>os-maven-plugin</artifactId>
|
||||||
|
<version>1.7.1</version>
|
||||||
|
</extension>
|
||||||
|
</extensions>
|
||||||
|
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
<groupId>org.apache.maven.plugins</groupId>
|
<groupId>org.apache.maven.plugins</groupId>
|
||||||
@@ -91,11 +109,75 @@
|
|||||||
<target>17</target>
|
<target>17</target>
|
||||||
</configuration>
|
</configuration>
|
||||||
</plugin>
|
</plugin>
|
||||||
|
|
||||||
<plugin>
|
<plugin>
|
||||||
<groupId>org.apache.maven.plugins</groupId>
|
<groupId>org.apache.maven.plugins</groupId>
|
||||||
<artifactId>maven-surefire-plugin</artifactId>
|
<artifactId>maven-surefire-plugin</artifactId>
|
||||||
<version>3.2.5</version>
|
<version>3.2.5</version>
|
||||||
</plugin>
|
</plugin>
|
||||||
|
|
||||||
|
<!-- Protocol Buffers Plugin -->
|
||||||
|
<plugin>
|
||||||
|
<groupId>org.xolstice.maven.plugins</groupId>
|
||||||
|
<artifactId>protobuf-maven-plugin</artifactId>
|
||||||
|
<version>0.6.1</version>
|
||||||
|
<configuration>
|
||||||
|
<protocExecutable>/usr/bin/protoc</protocExecutable>
|
||||||
|
<protoSourceRoot>${project.basedir}/src/main/proto</protoSourceRoot>
|
||||||
|
<outputDirectory>${project.build.directory}/generated-sources/protobuf/java</outputDirectory>
|
||||||
|
<clearOutputDirectory>false</clearOutputDirectory>
|
||||||
|
</configuration>
|
||||||
|
<executions>
|
||||||
|
<execution>
|
||||||
|
<goals>
|
||||||
|
<goal>compile</goal>
|
||||||
|
</goals>
|
||||||
|
</execution>
|
||||||
|
</executions>
|
||||||
|
</plugin>
|
||||||
|
|
||||||
|
<!-- Build Helper Plugin - Adiciona generated sources ao classpath -->
|
||||||
|
<plugin>
|
||||||
|
<groupId>org.codehaus.mojo</groupId>
|
||||||
|
<artifactId>build-helper-maven-plugin</artifactId>
|
||||||
|
<version>3.5.0</version>
|
||||||
|
<executions>
|
||||||
|
<execution>
|
||||||
|
<id>add-source</id>
|
||||||
|
<phase>generate-sources</phase>
|
||||||
|
<goals>
|
||||||
|
<goal>add-source</goal>
|
||||||
|
</goals>
|
||||||
|
<configuration>
|
||||||
|
<sources>
|
||||||
|
<source>${project.build.directory}/generated-sources/protobuf/java</source>
|
||||||
|
</sources>
|
||||||
|
</configuration>
|
||||||
|
</execution>
|
||||||
|
</executions>
|
||||||
|
</plugin>
|
||||||
|
|
||||||
|
<!-- Maven Shade Plugin - Creates executable JAR with all dependencies -->
|
||||||
|
<plugin>
|
||||||
|
<groupId>org.apache.maven.plugins</groupId>
|
||||||
|
<artifactId>maven-shade-plugin</artifactId>
|
||||||
|
<version>3.5.1</version>
|
||||||
|
<executions>
|
||||||
|
<execution>
|
||||||
|
<phase>package</phase>
|
||||||
|
<goals>
|
||||||
|
<goal>shade</goal>
|
||||||
|
</goals>
|
||||||
|
<configuration>
|
||||||
|
<transformers>
|
||||||
|
<transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
|
||||||
|
<mainClass>com.mediamanager.MediaManagerApplication</mainClass>
|
||||||
|
</transformer>
|
||||||
|
</transformers>
|
||||||
|
</configuration>
|
||||||
|
</execution>
|
||||||
|
</executions>
|
||||||
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,8 @@
|
|||||||
package com.mediamanager;
|
package com.mediamanager;
|
||||||
|
|
||||||
|
import com.mediamanager.service.database.DatabaseManager;
|
||||||
|
import com.mediamanager.service.delegate.DelegateActionManager;
|
||||||
|
import com.mediamanager.service.ipc.IPCManager;
|
||||||
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.LogManager;
|
||||||
import org.apache.logging.log4j.Logger;
|
import org.apache.logging.log4j.Logger;
|
||||||
|
|
||||||
@@ -7,9 +10,25 @@ import java.io.IOException;
|
|||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.util.Properties;
|
import java.util.Properties;
|
||||||
|
|
||||||
|
import com.mediamanager.service.database.SqliteDatabaseManager;
|
||||||
|
|
||||||
public class MediaManagerApplication {
|
public class MediaManagerApplication {
|
||||||
private static final Logger logger = LogManager.getLogger(MediaManagerApplication.class);
|
private static final Logger logger = LogManager.getLogger(MediaManagerApplication.class);
|
||||||
private static Properties config;
|
private static Properties config;
|
||||||
|
private static DatabaseManager databaseManager;
|
||||||
|
private static DelegateActionManager actionManager;
|
||||||
|
private static IPCManager ipcManager;
|
||||||
|
|
||||||
|
public enum ApplicationMode {
|
||||||
|
LOCAL("local"),
|
||||||
|
SERVER("server");
|
||||||
|
|
||||||
|
private final String value;
|
||||||
|
|
||||||
|
ApplicationMode(String value) {
|
||||||
|
this.value = value;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
public static void main(String[] args) {
|
public static void main(String[] args) {
|
||||||
logger.info("Starting MediaManager Core Application...");
|
logger.info("Starting MediaManager Core Application...");
|
||||||
@@ -17,19 +36,85 @@ public class MediaManagerApplication {
|
|||||||
try {
|
try {
|
||||||
// Load configuration
|
// Load configuration
|
||||||
loadConfiguration();
|
loadConfiguration();
|
||||||
|
String runTypeString = config.getProperty("runtype","local");
|
||||||
|
ApplicationMode mode = null;
|
||||||
|
|
||||||
|
for (ApplicationMode am : ApplicationMode.values()) {
|
||||||
|
if (am.value.equalsIgnoreCase(runTypeString)) {
|
||||||
|
mode = am;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if (mode == null) {
|
||||||
|
logger.error("Invalid run type: {}", runTypeString);
|
||||||
|
throw new Exception("Invalid run type: " + runTypeString);
|
||||||
|
}
|
||||||
|
logger.info("Run type: {}", mode);
|
||||||
|
switch (mode) {
|
||||||
|
case LOCAL:
|
||||||
|
logger.info("Starting local database...");
|
||||||
|
databaseManager = new SqliteDatabaseManager(config);
|
||||||
|
break;
|
||||||
|
case SERVER:
|
||||||
|
throw new Exception("Server mode not yet implemented");
|
||||||
|
default:
|
||||||
|
}
|
||||||
|
databaseManager.init();
|
||||||
|
actionManager = new DelegateActionManager();
|
||||||
|
actionManager.start();
|
||||||
|
ipcManager = new IPCManager(config,actionManager);
|
||||||
|
ipcManager.init();
|
||||||
|
|
||||||
// TODO: Initialize database connection
|
|
||||||
// TODO: Initialize IPC server with named pipes
|
|
||||||
// TODO: Start application services
|
// TODO: Start application services
|
||||||
|
|
||||||
logger.info("MediaManager Core started successfully");
|
logger.info("MediaManager Core started successfully");
|
||||||
logger.info("IPC Pipe: {}", config.getProperty("ipc.pipe.path") + "/" + config.getProperty("ipc.pipe.name"));
|
logger.info("IPC Socket: {}", ipcManager.getSocketPath().toAbsolutePath().toString());
|
||||||
|
|
||||||
// Keep application running
|
// Keep application running
|
||||||
Runtime.getRuntime().addShutdownHook(new Thread(() -> {
|
Runtime.getRuntime().addShutdownHook(new Thread(() -> {
|
||||||
|
|
||||||
logger.info("Shutting down MediaManager Core...");
|
logger.info("Shutting down MediaManager Core...");
|
||||||
// TODO: Cleanup resources
|
|
||||||
|
|
||||||
|
if (databaseManager != null) {
|
||||||
|
databaseManager.close();
|
||||||
|
}
|
||||||
|
|
||||||
|
if (ipcManager != null) {
|
||||||
|
try {
|
||||||
|
ipcManager.close();
|
||||||
|
} catch (Exception e) {
|
||||||
|
throw new RuntimeException(e);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (actionManager != null) {
|
||||||
|
actionManager.stop();
|
||||||
|
}
|
||||||
|
|
||||||
|
logger.info("MediaManager Core shutdown successfully");
|
||||||
|
logger.info("Goodbye!");
|
||||||
|
|
||||||
|
|
||||||
|
// Give Log4j2 time to write all pending messages before shutting down
|
||||||
|
try {
|
||||||
|
Thread.sleep(1000);
|
||||||
|
} catch (InterruptedException e) {
|
||||||
|
Thread.currentThread().interrupt();
|
||||||
|
}
|
||||||
|
|
||||||
|
// Now shutdown Log4j2
|
||||||
|
org.apache.logging.log4j.LogManager.shutdown();
|
||||||
}));
|
}));
|
||||||
|
logger.info("Application is running");
|
||||||
|
logger.info("Press Ctrl+C to exit");
|
||||||
|
Thread.currentThread().join();
|
||||||
|
|
||||||
|
} catch (InterruptedException e) {
|
||||||
|
|
||||||
|
logger.info("Application interrupted, initiating shutdown...");
|
||||||
|
|
||||||
|
Thread.currentThread().interrupt();
|
||||||
|
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
logger.error("Failed to start MediaManager Core", e);
|
logger.error("Failed to start MediaManager Core", e);
|
||||||
@@ -39,10 +124,9 @@ public class MediaManagerApplication {
|
|||||||
|
|
||||||
private static void loadConfiguration() throws IOException {
|
private static void loadConfiguration() throws IOException {
|
||||||
config = new Properties();
|
config = new Properties();
|
||||||
try (InputStream input = MediaManagerApplication.class.getClassLoader()
|
try (InputStream input = MediaManagerApplication.class.getClassLoader().getResourceAsStream("config.properties")) {
|
||||||
.getResourceAsStream("application.properties")) {
|
|
||||||
if (input == null) {
|
if (input == null) {
|
||||||
throw new IOException("Unable to find application.properties");
|
throw new IOException("Unable to find config.properties");
|
||||||
}
|
}
|
||||||
config.load(input);
|
config.load(input);
|
||||||
logger.info("Configuration loaded successfully");
|
logger.info("Configuration loaded successfully");
|
||||||
@@ -52,4 +136,4 @@ public class MediaManagerApplication {
|
|||||||
public static Properties getConfig() {
|
public static Properties getConfig() {
|
||||||
return config;
|
return config;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -0,0 +1,62 @@
|
|||||||
|
package com.mediamanager.service.database;
|
||||||
|
|
||||||
|
import org.apache.logging.log4j.LogManager;
|
||||||
|
import org.apache.logging.log4j.Logger;
|
||||||
|
|
||||||
|
import java.sql.Connection;
|
||||||
|
import java.sql.SQLException;
|
||||||
|
import java.sql.Statement;
|
||||||
|
import java.util.Properties;
|
||||||
|
|
||||||
|
public abstract class DatabaseManager {
|
||||||
|
protected final Properties configuration;
|
||||||
|
protected Connection connection;
|
||||||
|
protected static final Logger logger = LogManager.getLogger(DatabaseManager.class);
|
||||||
|
|
||||||
|
public DatabaseManager(Properties config) {
|
||||||
|
this.configuration = config;
|
||||||
|
logger.debug("DatabaseManager created with configuration:");
|
||||||
|
}
|
||||||
|
|
||||||
|
public abstract void init() throws Exception;
|
||||||
|
|
||||||
|
protected abstract Connection createConnection() throws Exception;
|
||||||
|
|
||||||
|
protected void performSanityChecks() throws SQLException {
|
||||||
|
logger.debug("Performing sanity checks...");
|
||||||
|
try (Statement stmt = connection.createStatement()) {
|
||||||
|
stmt.execute("SELECT 1");
|
||||||
|
|
||||||
|
}
|
||||||
|
String databaseProductName = connection.getMetaData().getDatabaseProductName();
|
||||||
|
String databaseProductVersion = connection.getMetaData().getDatabaseProductVersion();
|
||||||
|
logger.info("Connected to database: {} v{}", databaseProductName, databaseProductVersion);
|
||||||
|
}
|
||||||
|
|
||||||
|
public Connection getConnection() {
|
||||||
|
return connection;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void close() {
|
||||||
|
if (connection != null) {
|
||||||
|
try {
|
||||||
|
logger.info("Closing database connection...");
|
||||||
|
connection.close();
|
||||||
|
logger.info("Database connection closed successfully");
|
||||||
|
} catch (SQLException e) {
|
||||||
|
logger.error("Error closing database connection: {}", e.getMessage());
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
logger.debug("No database connection to close");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
protected boolean testConnection() {
|
||||||
|
try (Statement stmt = connection.createStatement()) {
|
||||||
|
stmt.execute("SELECT 1");
|
||||||
|
return true;
|
||||||
|
} catch (SQLException e) {
|
||||||
|
logger.error("Connection test failed", e);
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,97 @@
|
|||||||
|
package com.mediamanager.service.database;
|
||||||
|
|
||||||
|
import org.apache.logging.log4j.LogManager;
|
||||||
|
import org.apache.logging.log4j.Logger;
|
||||||
|
|
||||||
|
import java.nio.file.Files;
|
||||||
|
import java.nio.file.Path;
|
||||||
|
import java.nio.file.Paths;
|
||||||
|
import java.sql.Connection;
|
||||||
|
import java.sql.DriverManager;
|
||||||
|
import java.sql.SQLException;
|
||||||
|
import java.sql.Statement;
|
||||||
|
import java.util.Properties;
|
||||||
|
|
||||||
|
public class SqliteDatabaseManager extends DatabaseManager {
|
||||||
|
private static final Logger logger = LogManager.getLogger(SqliteDatabaseManager.class);
|
||||||
|
|
||||||
|
|
||||||
|
private String connectionUrl;
|
||||||
|
|
||||||
|
public SqliteDatabaseManager(Properties config) {
|
||||||
|
super(config);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void init() throws Exception {
|
||||||
|
|
||||||
|
logger.info("Initializing SQLite database...");
|
||||||
|
String dataDir = configuration.getProperty("database.dir",
|
||||||
|
System.getProperty("user.home") + "/.mediamanager/db");
|
||||||
|
String dbFilename = configuration.getProperty("database.filename", "mediamanager.db");
|
||||||
|
String driverClassName = configuration.getProperty("database.driver", "org.sqlite.JDBC");
|
||||||
|
try {
|
||||||
|
Class.forName(driverClassName);
|
||||||
|
}catch(ClassNotFoundException e) {
|
||||||
|
logger.error("Failed to load SQLite driver", e);
|
||||||
|
throw e;
|
||||||
|
}
|
||||||
|
Path dataPath = Paths.get(dataDir);
|
||||||
|
if (!Files.exists(dataPath)) {
|
||||||
|
Files.createDirectories(dataPath);
|
||||||
|
logger.debug("Created database directory: {}", dataDir);
|
||||||
|
}
|
||||||
|
Path dbFile = dataPath.resolve(dbFilename);
|
||||||
|
this.connectionUrl = "jdbc:sqlite:" + dbFile.toAbsolutePath().toString();
|
||||||
|
logger.info("Database file path: {}", dbFile);
|
||||||
|
logger.info("Connection URL: {}", this.connectionUrl);
|
||||||
|
this.connection = createConnection();
|
||||||
|
configurePerformancePragmas();
|
||||||
|
performSanityChecks();
|
||||||
|
ensureSchemaExists();
|
||||||
|
logger.info("SQLite database initialized successfully");
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
protected Connection createConnection() throws Exception {
|
||||||
|
try {
|
||||||
|
// O driver org.xerial.sqlite-jdbc é carregado automaticamente aqui
|
||||||
|
Connection conn = DriverManager.getConnection(this.connectionUrl);
|
||||||
|
logger.debug("Got connection to SQLite file");
|
||||||
|
return conn;
|
||||||
|
} catch (SQLException e) {
|
||||||
|
logger.error("Failed to create SQLite connection", e);
|
||||||
|
throw new Exception("SQLite connection failed: " + e.getMessage(), e);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
private void configurePerformancePragmas() throws SQLException {
|
||||||
|
try (Statement stmt = connection.createStatement()) {
|
||||||
|
|
||||||
|
stmt.execute("PRAGMA journal_mode=WAL;");
|
||||||
|
|
||||||
|
|
||||||
|
stmt.execute("PRAGMA foreign_keys=ON;");
|
||||||
|
|
||||||
|
|
||||||
|
stmt.execute("PRAGMA synchronous=NORMAL;");
|
||||||
|
|
||||||
|
stmt.execute("PRAGMA busy_timeout=5000;");
|
||||||
|
|
||||||
|
logger.debug("SQLite performance PRAGMAs applied (WAL, Synchronous, ForeignKeys).");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void ensureSchemaExists() throws SQLException {
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void close() {
|
||||||
|
|
||||||
|
super.close();
|
||||||
|
logger.info("SQLite resources released.");
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,11 @@
|
|||||||
|
package com.mediamanager.service.delegate;
|
||||||
|
|
||||||
|
import com.google.protobuf.ByteString;
|
||||||
|
import com.google.protobuf.InvalidProtocolBufferException;
|
||||||
|
import com.mediamanager.protocol.TransportProtocol;
|
||||||
|
|
||||||
|
@FunctionalInterface
|
||||||
|
public interface ActionHandler {
|
||||||
|
TransportProtocol.Response.Builder handle(ByteString requestPayload) throws InvalidProtocolBufferException;
|
||||||
|
}
|
||||||
|
|
||||||
@@ -0,0 +1,60 @@
|
|||||||
|
package com.mediamanager.service.delegate;
|
||||||
|
|
||||||
|
import com.google.protobuf.ByteString;
|
||||||
|
import com.mediamanager.protocol.TransportProtocol;
|
||||||
|
import com.mediamanager.service.delegate.handler.EchoHandler;
|
||||||
|
import org.apache.logging.log4j.LogManager;
|
||||||
|
import org.apache.logging.log4j.Logger;
|
||||||
|
|
||||||
|
import java.util.HashMap;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
|
public class DelegateActionManager {
|
||||||
|
private static final Logger logger = LogManager.getLogger(DelegateActionManager.class);
|
||||||
|
|
||||||
|
private final Map<String, ActionHandler> handlerRegistry;
|
||||||
|
|
||||||
|
public DelegateActionManager() {
|
||||||
|
|
||||||
|
logger.debug("DelegateActionManager created");
|
||||||
|
this.handlerRegistry = new HashMap<>();
|
||||||
|
registerHandlers();
|
||||||
|
}
|
||||||
|
|
||||||
|
private void registerHandlers() {
|
||||||
|
handlerRegistry.put("echo",new EchoHandler());
|
||||||
|
}
|
||||||
|
|
||||||
|
public void start(){
|
||||||
|
logger.info("DelegateActionManager started");
|
||||||
|
}
|
||||||
|
|
||||||
|
public void stop(){
|
||||||
|
logger.info("DelegateActionManager stopped");
|
||||||
|
}
|
||||||
|
|
||||||
|
public TransportProtocol.Response ProcessedRequest(TransportProtocol.Request request){
|
||||||
|
String requestId = request.getRequestId();
|
||||||
|
logger.info("Processing request: {}", requestId);
|
||||||
|
String action = request.getHeadersMap().getOrDefault("action", "unknown");
|
||||||
|
ActionHandler handler = handlerRegistry.get(action);
|
||||||
|
TransportProtocol.Response.Builder responseBuilder;
|
||||||
|
if (handler == null) {
|
||||||
|
logger.warn("No handler found for action: {}", action);
|
||||||
|
responseBuilder = TransportProtocol.Response.newBuilder()
|
||||||
|
.setStatusCode(404) // 404 Not Found
|
||||||
|
.setPayload(ByteString.copyFromUtf8("Error: Action '" + action + "' not found."));
|
||||||
|
} else{
|
||||||
|
try {
|
||||||
|
logger.debug("Delegating action '{}' to handler...", action);
|
||||||
|
responseBuilder = handler.handle(request.getPayload());
|
||||||
|
}catch (Exception e) {
|
||||||
|
logger.error("Handler for action '{}' threw an exception:", action, e);
|
||||||
|
responseBuilder = TransportProtocol.Response.newBuilder()
|
||||||
|
.setStatusCode(500) // 500 Internal Server Error
|
||||||
|
.setPayload(ByteString.copyFromUtf8("Error: " + e.getMessage()));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return responseBuilder.setRequestId(requestId).build();
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,17 @@
|
|||||||
|
package com.mediamanager.service.delegate.handler;
|
||||||
|
|
||||||
|
import com.google.protobuf.ByteString;
|
||||||
|
import com.mediamanager.protocol.TransportProtocol;
|
||||||
|
import com.mediamanager.service.delegate.ActionHandler;
|
||||||
|
|
||||||
|
public class EchoHandler implements ActionHandler {
|
||||||
|
@Override
|
||||||
|
public TransportProtocol.Response.Builder handle(ByteString requestPayload) {
|
||||||
|
String payloadText = requestPayload.toStringUtf8();
|
||||||
|
String responseText = "Server received: " + payloadText;
|
||||||
|
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setPayload(ByteString.copyFromUtf8(responseText))
|
||||||
|
.setStatusCode(200);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,318 @@
|
|||||||
|
package com.mediamanager.service.ipc;
|
||||||
|
|
||||||
|
import com.mediamanager.protocol.TransportProtocol;
|
||||||
|
import com.mediamanager.service.delegate.DelegateActionManager;
|
||||||
|
import org.apache.logging.log4j.LogManager;
|
||||||
|
import org.apache.logging.log4j.Logger;
|
||||||
|
|
||||||
|
|
||||||
|
import java.io.IOException;
|
||||||
|
import java.net.StandardProtocolFamily;
|
||||||
|
import java.net.UnixDomainSocketAddress;
|
||||||
|
import java.nio.channels.ServerSocketChannel;
|
||||||
|
import java.nio.channels.SocketChannel;
|
||||||
|
import java.nio.file.Files;
|
||||||
|
import java.nio.file.Path;
|
||||||
|
import java.nio.file.attribute.PosixFilePermission;
|
||||||
|
import java.nio.file.attribute.PosixFilePermissions;
|
||||||
|
import java.util.Properties;
|
||||||
|
import java.util.Set;
|
||||||
|
import java.util.concurrent.ConcurrentHashMap;
|
||||||
|
import java.util.concurrent.ExecutorService;
|
||||||
|
import java.util.concurrent.Executors;
|
||||||
|
import java.util.concurrent.TimeUnit;
|
||||||
|
import java.util.concurrent.atomic.AtomicBoolean;
|
||||||
|
import java.util.concurrent.atomic.AtomicInteger;
|
||||||
|
|
||||||
|
public class IPCManager {
|
||||||
|
private final Properties configuration;
|
||||||
|
private static final Logger logger = LogManager.getLogger(IPCManager.class);
|
||||||
|
private final DelegateActionManager actionManager;
|
||||||
|
|
||||||
|
private Path socketPath;
|
||||||
|
private UnixDomainSocketAddress socketAddress;
|
||||||
|
private ServerSocketChannel serverChannel;
|
||||||
|
private ExecutorService clientThreadPool;
|
||||||
|
private final AtomicBoolean running = new AtomicBoolean(false);
|
||||||
|
private final ConcurrentHashMap<Integer, ClientHandler> activeClients = new ConcurrentHashMap<>();
|
||||||
|
private final AtomicInteger clientIdCounter = new AtomicInteger(0);
|
||||||
|
|
||||||
|
|
||||||
|
public IPCManager(Properties config, DelegateActionManager actionManager){
|
||||||
|
configuration = config;
|
||||||
|
this.actionManager = actionManager;
|
||||||
|
logger.debug("IPCManager created with configuration:");
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
public void init() throws Exception {
|
||||||
|
logger.info("Initializing IPC connection...");
|
||||||
|
validateConfiguration();
|
||||||
|
socketPath = Path.of(configuration.getProperty("ipc.socket.path")).resolve("mediamanager.sock");
|
||||||
|
|
||||||
|
if (Files.exists(socketPath)) {
|
||||||
|
logger.warn("Socket file already exists at: {}", socketPath);
|
||||||
|
logger.info("Deleting existing socket...");
|
||||||
|
Files.deleteIfExists(socketPath);
|
||||||
|
}
|
||||||
|
|
||||||
|
Path parentDir = socketPath.getParent();
|
||||||
|
if (parentDir != null && !Files.exists(parentDir)) {
|
||||||
|
logger.info("Creating parent directory for socket: {}", parentDir);
|
||||||
|
Files.createDirectories(parentDir);
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
socketAddress = UnixDomainSocketAddress.of(socketPath);
|
||||||
|
logger.debug("Socket address created");
|
||||||
|
|
||||||
|
serverChannel = ServerSocketChannel.open(StandardProtocolFamily.UNIX);
|
||||||
|
serverChannel.bind(socketAddress);
|
||||||
|
logger.info("Server bound to socket - file created at: {}", socketPath);
|
||||||
|
|
||||||
|
// ESTA É A MUDANÇA CRÍTICA
|
||||||
|
// Configura o canal para modo não-bloqueante
|
||||||
|
// Isso faz accept() retornar null imediatamente se não houver cliente
|
||||||
|
// ao invés de bloquear esperando indefinidamente
|
||||||
|
serverChannel.configureBlocking(false);
|
||||||
|
logger.debug("Server channel configured for non-blocking mode");
|
||||||
|
|
||||||
|
Set<PosixFilePermission> perms = PosixFilePermissions.fromString("rw-------");
|
||||||
|
Files.setPosixFilePermissions(socketPath, perms);
|
||||||
|
logger.debug("Socket permissions set to: rw-------");
|
||||||
|
|
||||||
|
clientThreadPool = Executors.newCachedThreadPool(runnable -> {
|
||||||
|
Thread thread = new Thread(runnable);
|
||||||
|
thread.setName("IPC-Client-Handler-" + thread.getId());
|
||||||
|
thread.setDaemon(true);
|
||||||
|
return thread;
|
||||||
|
});
|
||||||
|
logger.debug("Client thread pool created");
|
||||||
|
|
||||||
|
running.set(true);
|
||||||
|
|
||||||
|
Thread serverThread = new Thread(this::acceptConnectionsLoop, "IPC-Server-Accept-Thread");
|
||||||
|
serverThread.setDaemon(true);
|
||||||
|
serverThread.start();
|
||||||
|
logger.info("Server thread started - accepting connections");
|
||||||
|
|
||||||
|
logger.info("IPC server initialized successfully on {}", socketPath.toAbsolutePath());
|
||||||
|
|
||||||
|
} catch (IOException e) {
|
||||||
|
logger.error("Failed to initialize IPC server: {}", e.getMessage());
|
||||||
|
throw new Exception("Failed to initialize IPC server: " + e.getMessage(), e);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
private void validateConfiguration() throws Exception {
|
||||||
|
String[] requiredProperties = {
|
||||||
|
"ipc.socket.path"
|
||||||
|
};
|
||||||
|
for (String property : requiredProperties) {
|
||||||
|
if (configuration.getProperty(property) == null) {
|
||||||
|
throw new Exception("Missing required configuration property: " + property);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
logger.debug("IPC configuration validated successfully");
|
||||||
|
}
|
||||||
|
|
||||||
|
public Path getSocketPath(){
|
||||||
|
return socketPath;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void close() throws Exception {
|
||||||
|
if(!running.get()){
|
||||||
|
logger.warn("IPC connection is already closed");
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
logger.info("Closing IPC connection...");
|
||||||
|
|
||||||
|
running.set(false);
|
||||||
|
if (serverChannel != null && serverChannel.isOpen()) {
|
||||||
|
serverChannel.close();
|
||||||
|
logger.debug("Server channel closed");
|
||||||
|
}
|
||||||
|
|
||||||
|
if (clientThreadPool != null) {
|
||||||
|
clientThreadPool.shutdown();
|
||||||
|
try {
|
||||||
|
if (!clientThreadPool.awaitTermination(30, TimeUnit.SECONDS)) {
|
||||||
|
logger.warn("Some client handlers did not finish in time, forcing shutdown");
|
||||||
|
clientThreadPool.shutdownNow();
|
||||||
|
}
|
||||||
|
} catch (InterruptedException e) {
|
||||||
|
logger.error("Interrupted while waiting for client handlers", e);
|
||||||
|
clientThreadPool.shutdownNow();
|
||||||
|
Thread.currentThread().interrupt();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (socketPath != null && Files.exists(socketPath)) {
|
||||||
|
Files.deleteIfExists(socketPath);
|
||||||
|
logger.info("Socket file deleted successfully");
|
||||||
|
}
|
||||||
|
|
||||||
|
logger.info("IPC server closed successfully");
|
||||||
|
}
|
||||||
|
|
||||||
|
private void acceptConnectionsLoop() {
|
||||||
|
logger.info("Preparing to accept connections...");
|
||||||
|
|
||||||
|
while (running.get()) {
|
||||||
|
try {
|
||||||
|
// Em modo não-bloqueante, accept() retorna imediatamente
|
||||||
|
// Se há um cliente esperando, retorna o SocketChannel
|
||||||
|
// Se não há cliente, retorna null
|
||||||
|
SocketChannel clientChannel = serverChannel.accept();
|
||||||
|
|
||||||
|
if (clientChannel != null) {
|
||||||
|
// Um cliente realmente se conectou!
|
||||||
|
int clientId = clientIdCounter.incrementAndGet();
|
||||||
|
logger.info("Client {} connected", clientId);
|
||||||
|
|
||||||
|
ClientHandler handler = new ClientHandler(clientId, clientChannel);
|
||||||
|
activeClients.put(clientId, handler);
|
||||||
|
|
||||||
|
clientThreadPool.submit(() -> {
|
||||||
|
try {
|
||||||
|
handler.handle();
|
||||||
|
} finally {
|
||||||
|
activeClients.remove(clientId);
|
||||||
|
logger.info("Client {} disconnected", clientId);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
} else {
|
||||||
|
// Nenhum cliente conectado no momento
|
||||||
|
// Dorme por um curto período antes de verificar novamente
|
||||||
|
// Isso evita consumir CPU desnecessariamente em um loop vazio
|
||||||
|
Thread.sleep(100); // 100 milissegundos
|
||||||
|
}
|
||||||
|
|
||||||
|
} catch (InterruptedException e) {
|
||||||
|
// Thread foi interrompida, provavelmente durante shutdown
|
||||||
|
logger.debug("Accept loop interrupted");
|
||||||
|
break;
|
||||||
|
|
||||||
|
} catch (IOException e) {
|
||||||
|
// Erros de I/O reais devem ser logados
|
||||||
|
if (running.get()) {
|
||||||
|
logger.error("Error accepting client connection", e);
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
logger.info("Connection loop stopped gracefully");
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
private class ClientHandler {
|
||||||
|
private final int clientId;
|
||||||
|
private final SocketChannel channel;
|
||||||
|
|
||||||
|
public ClientHandler(int clientId, SocketChannel channel) {
|
||||||
|
this.clientId = clientId;
|
||||||
|
this.channel = channel;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Método principal que processa a comunicação com o cliente.
|
||||||
|
* Aqui é onde vamos ler mensagens JSON, processá-las, e enviar respostas.
|
||||||
|
*/
|
||||||
|
public void handle() {
|
||||||
|
logger.debug("Client {} handler thread started", clientId);
|
||||||
|
|
||||||
|
try {
|
||||||
|
TransportProtocol.Request request = readRequest(channel);
|
||||||
|
|
||||||
|
if (request != null) {
|
||||||
|
logger.info("Client {} sent request {}", clientId, request.getRequestId());
|
||||||
|
|
||||||
|
// Processa usando o DelegateActionManager
|
||||||
|
TransportProtocol.Response response = actionManager.ProcessedRequest(request);
|
||||||
|
|
||||||
|
// Envia resposta de volta
|
||||||
|
writeResponse(channel, response);
|
||||||
|
|
||||||
|
logger.info("Client {} response sent", clientId);
|
||||||
|
} else {
|
||||||
|
logger.warn("Client {} sent null message", clientId);
|
||||||
|
}
|
||||||
|
|
||||||
|
} catch (Exception e) {
|
||||||
|
logger.error("Error handling client {}", clientId, e);
|
||||||
|
} finally {
|
||||||
|
try {
|
||||||
|
channel.close();
|
||||||
|
logger.debug("Client {} channel closed", clientId);
|
||||||
|
} catch (IOException e) {
|
||||||
|
logger.error("Error closing client {} channel", clientId, e);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
private TransportProtocol.Request readRequest(SocketChannel channel) throws IOException {
|
||||||
|
// Primeiro, lê o tamanho da mensagem (4 bytes = int32)
|
||||||
|
java.nio.ByteBuffer sizeBuffer = java.nio.ByteBuffer.allocate(4);
|
||||||
|
int bytesRead = 0;
|
||||||
|
|
||||||
|
while (bytesRead < 4) {
|
||||||
|
int read = channel.read(sizeBuffer);
|
||||||
|
if (read == -1) {
|
||||||
|
logger.debug("Client disconnected before sending size");
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
bytesRead += read;
|
||||||
|
}
|
||||||
|
|
||||||
|
sizeBuffer.flip();
|
||||||
|
int messageSize = sizeBuffer.getInt();
|
||||||
|
logger.debug("Expecting message of {} bytes", messageSize);
|
||||||
|
|
||||||
|
// Validação básica de segurança
|
||||||
|
if (messageSize <= 0 || messageSize > 1024 * 1024) { // Max 1MB
|
||||||
|
throw new IOException("Invalid message size: " + messageSize);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Agora lê a mensagem completa
|
||||||
|
java.nio.ByteBuffer messageBuffer = java.nio.ByteBuffer.allocate(messageSize);
|
||||||
|
bytesRead = 0;
|
||||||
|
|
||||||
|
while (bytesRead < messageSize) {
|
||||||
|
int read = channel.read(messageBuffer);
|
||||||
|
if (read == -1) {
|
||||||
|
throw new IOException("Client disconnected while reading message");
|
||||||
|
}
|
||||||
|
bytesRead += read;
|
||||||
|
}
|
||||||
|
|
||||||
|
messageBuffer.flip();
|
||||||
|
|
||||||
|
// Deserializa o Protocol Buffers
|
||||||
|
byte[] messageBytes = new byte[messageSize];
|
||||||
|
messageBuffer.get(messageBytes);
|
||||||
|
|
||||||
|
return TransportProtocol.Request.parseFrom(messageBytes);
|
||||||
|
}
|
||||||
|
|
||||||
|
private void writeResponse(SocketChannel channel, TransportProtocol.Response response) throws IOException {
|
||||||
|
byte[] messageBytes = response.toByteArray();
|
||||||
|
int messageSize = messageBytes.length;
|
||||||
|
|
||||||
|
logger.debug("Writing response of {} bytes", messageSize);
|
||||||
|
|
||||||
|
java.nio.ByteBuffer buffer = java.nio.ByteBuffer.allocate(4 + messageSize);
|
||||||
|
buffer.putInt(messageSize);
|
||||||
|
buffer.put(messageBytes);
|
||||||
|
buffer.flip();
|
||||||
|
|
||||||
|
while (buffer.hasRemaining()) {
|
||||||
|
channel.write(buffer);
|
||||||
|
}
|
||||||
|
|
||||||
|
logger.debug("Response written successfully");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@@ -0,0 +1,19 @@
|
|||||||
|
syntax = "proto3";
|
||||||
|
|
||||||
|
option java_package = "com.mediamanager.protocol";
|
||||||
|
option java_outer_classname = "TransportProtocol";
|
||||||
|
|
||||||
|
package mediamanager;
|
||||||
|
|
||||||
|
message Request {
|
||||||
|
string request_id = 1;
|
||||||
|
bytes payload = 2;
|
||||||
|
map<string, string> headers = 3;
|
||||||
|
}
|
||||||
|
|
||||||
|
message Response {
|
||||||
|
string request_id = 1;
|
||||||
|
int32 status_code = 2;
|
||||||
|
bytes payload = 3;
|
||||||
|
map<string, string> headers = 4;
|
||||||
|
}
|
||||||
+5
@@ -21,3 +21,8 @@ hibernate.format_sql=true
|
|||||||
ipc.pipe.name=mediamanager-pipe
|
ipc.pipe.name=mediamanager-pipe
|
||||||
ipc.pipe.path=/tmp/mediamanager
|
ipc.pipe.path=/tmp/mediamanager
|
||||||
ipc.buffer.size=8192
|
ipc.buffer.size=8192
|
||||||
|
runtype=local
|
||||||
|
ipc.socket.path=/tmp/mediamanager
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@@ -1,12 +1,13 @@
|
|||||||
<?xml version="1.0" encoding="UTF-8"?>
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
<Configuration status="WARN">
|
<Configuration status="WARN" shutdownHook="disable">
|
||||||
<Appenders>
|
<Appenders>
|
||||||
<Console name="Console" target="SYSTEM_OUT">
|
<Console name="Console" target="SYSTEM_OUT" immediateFlush="true">
|
||||||
<PatternLayout pattern="%d{yyyy-MM-dd HH:mm:ss} [%t] %-5level %logger{36} - %msg%n"/>
|
<PatternLayout pattern="%d{yyyy-MM-dd HH:mm:ss} [%t] %-5level %logger{36} - %msg%n"/>
|
||||||
</Console>
|
</Console>
|
||||||
|
|
||||||
<RollingFile name="FileAppender" fileName="logs/mediamanager.log"
|
<RollingFile name="FileAppender" fileName="logs/mediamanager.log"
|
||||||
filePattern="logs/mediamanager-%d{yyyy-MM-dd}-%i.log">
|
filePattern="logs/mediamanager-%d{yyyy-MM-dd}-%i.log"
|
||||||
|
immediateFlush="true">
|
||||||
<PatternLayout pattern="%d{yyyy-MM-dd HH:mm:ss} [%t] %-5level %logger{36} - %msg%n"/>
|
<PatternLayout pattern="%d{yyyy-MM-dd HH:mm:ss} [%t] %-5level %logger{36} - %msg%n"/>
|
||||||
<Policies>
|
<Policies>
|
||||||
<TimeBasedTriggeringPolicy interval="1"/>
|
<TimeBasedTriggeringPolicy interval="1"/>
|
||||||
|
|||||||
Reference in New Issue
Block a user