refactor: Add logging to service actions

This commit is contained in:
Minecon724 2025-02-16 09:19:43 +01:00
parent c0edab2142
commit ed4457274f
Signed by: Minecon724
GPG key ID: 3CCC4D267742C8E8
3 changed files with 21 additions and 3 deletions

View file

@ -1,6 +1,7 @@
package eu.m724.mstats.api.service; package eu.m724.mstats.api.service;
import eu.m724.mstats.orm.Plugin; import eu.m724.mstats.orm.Plugin;
import io.quarkus.logging.Log;
import jakarta.enterprise.context.ApplicationScoped; import jakarta.enterprise.context.ApplicationScoped;
import jakarta.transaction.Transactional; import jakarta.transaction.Transactional;
@ -9,5 +10,7 @@ public class AdminService {
@Transactional @Transactional
public void deletePlugin(Plugin plugin) { public void deletePlugin(Plugin plugin) {
plugin.delete(); plugin.delete();
Log.infof("Deleted plugin: #%d %s", plugin.id, plugin.name);
} }
} }

View file

@ -1,6 +1,7 @@
package eu.m724.mstats.api.service; package eu.m724.mstats.api.service;
import eu.m724.mstats.orm.Plugin; import eu.m724.mstats.orm.Plugin;
import io.quarkus.logging.Log;
import jakarta.enterprise.context.ApplicationScoped; import jakarta.enterprise.context.ApplicationScoped;
import jakarta.transaction.Transactional; import jakarta.transaction.Transactional;
@ -8,7 +9,10 @@ import jakarta.transaction.Transactional;
public class PluginService { public class PluginService {
@Transactional @Transactional
public Plugin createPlugin(String name) { public Plugin createPlugin(String name) {
return Plugin.createPlugin(name); Plugin plugin = Plugin.createPlugin(name);
Log.infof("Created plugin: #%d %s", plugin.id, plugin.name);
return plugin;
} }
@ -26,6 +30,7 @@ public class PluginService {
plugin.delete(); plugin.delete();
Log.infof("Deleted plugin: #%d %s", id, plugin.name);
return plugin; return plugin;
} }
@ -40,6 +45,8 @@ public class PluginService {
plugin.name = name; plugin.name = name;
plugin.persistAndFlush(); plugin.persistAndFlush();
Log.infof("Edited plugin: #%d %s", id, name);
return plugin; return plugin;
} }
} }

View file

@ -3,6 +3,7 @@ package eu.m724.mstats.api.service;
import eu.m724.mstats.api.resource.ServerApiResource; import eu.m724.mstats.api.resource.ServerApiResource;
import eu.m724.mstats.orm.Plugin; import eu.m724.mstats.orm.Plugin;
import eu.m724.mstats.orm.Server; import eu.m724.mstats.orm.Server;
import io.quarkus.logging.Log;
import jakarta.enterprise.context.ApplicationScoped; import jakarta.enterprise.context.ApplicationScoped;
import jakarta.transaction.Transactional; import jakarta.transaction.Transactional;
@ -14,17 +15,22 @@ import java.util.Set;
public class ServerService { public class ServerService {
@Transactional @Transactional
public Server createServer() { public Server createServer() {
return Server.createServer(); Server server = Server.createServer();
Log.infof("Created server: #%d", server.id);
return server;
} }
@Transactional @Transactional
public void modifyServer(Server server) { public void modifyServer(Server server) {
server.persistAndFlush(); server.persistAndFlush();
Log.infof("Modified server: #%d", server.id);
} }
@Transactional @Transactional
public void removeServer(Server server) { public void removeServer(Server server) {
server.delete(); server.delete();
Log.infof("Deleted server: #%d", server.id);
} }
@Transactional @Transactional
@ -43,10 +49,12 @@ public class ServerService {
server.serverVersion = heartbeatRequest.serverVersion; server.serverVersion = heartbeatRequest.serverVersion;
if (!unknownPlugins.isEmpty()) { if (!unknownPlugins.isEmpty()) {
// TODO // TODO tell plugin to stop monitoring or log?
} }
server.lastHeartbeat = LocalDateTime.now(); server.lastHeartbeat = LocalDateTime.now();
server.persistAndFlush(); server.persistAndFlush();
Log.infof("Heartbeat from server: #%d", server.id);
} }
} }