X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsone%2Fmain%2FSonePlugin.java;h=25c6dac609746355fc1ab1a2e8ae8f9075fb5f9d;hb=2b7b9baa754ba9d4a41b0abfaf946bd9146a10c9;hp=18a9a52f891007aba62843d889f2fe8566d5de11;hpb=9a29a82abbb4f5ae89004bf755ca8cf085daa7bd;p=Sone.git
diff --git a/src/main/java/net/pterodactylus/sone/main/SonePlugin.java b/src/main/java/net/pterodactylus/sone/main/SonePlugin.java
index 18a9a52..25c6dac 100644
--- a/src/main/java/net/pterodactylus/sone/main/SonePlugin.java
+++ b/src/main/java/net/pterodactylus/sone/main/SonePlugin.java
@@ -1,5 +1,5 @@
/*
- * FreenetSone - SonePlugin.java - Copyright © 2010 David Roden
+ * Sone - SonePlugin.java - Copyright © 2010â2020 David Roden
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
@@ -17,72 +17,92 @@
package net.pterodactylus.sone.main;
-import java.io.File;
-import java.util.logging.Level;
-import java.util.logging.LogRecord;
-import java.util.logging.Logger;
+import static java.util.logging.Logger.*;
-import net.pterodactylus.sone.core.Core;
-import net.pterodactylus.sone.core.FreenetInterface;
-import net.pterodactylus.sone.freenet.PluginStoreConfigurationBackend;
-import net.pterodactylus.sone.freenet.wot.IdentityManager;
-import net.pterodactylus.sone.freenet.wot.PluginConnector;
-import net.pterodactylus.sone.freenet.wot.WebOfTrustConnector;
-import net.pterodactylus.sone.web.WebInterface;
-import net.pterodactylus.util.config.Configuration;
-import net.pterodactylus.util.config.ConfigurationException;
-import net.pterodactylus.util.config.MapConfigurationBackend;
-import net.pterodactylus.util.logging.Logging;
-import net.pterodactylus.util.logging.LoggingListener;
-import net.pterodactylus.util.version.Version;
-import freenet.client.async.DatabaseDisabledException;
-import freenet.l10n.BaseL10n.LANGUAGE;
-import freenet.l10n.PluginL10n;
-import freenet.pluginmanager.FredPlugin;
-import freenet.pluginmanager.FredPluginBaseL10n;
-import freenet.pluginmanager.FredPluginL10n;
-import freenet.pluginmanager.FredPluginThreadless;
-import freenet.pluginmanager.FredPluginVersioned;
-import freenet.pluginmanager.PluginRespirator;
-import freenet.pluginmanager.PluginStore;
+import java.util.logging.Logger;
+import java.util.logging.*;
+
+import javax.annotation.Nonnull;
+
+import net.pterodactylus.sone.core.*;
+import net.pterodactylus.sone.core.event.*;
+import net.pterodactylus.sone.fcp.*;
+import net.pterodactylus.sone.freenet.wot.*;
+import net.pterodactylus.sone.web.*;
+import net.pterodactylus.sone.web.notification.NotificationHandler;
+import net.pterodactylus.sone.web.notification.NotificationHandlerModule;
+
+import freenet.l10n.BaseL10n.*;
+import freenet.l10n.*;
+import freenet.pluginmanager.*;
+import freenet.support.*;
+import freenet.support.api.*;
+
+import com.google.common.annotations.*;
+import com.google.common.eventbus.*;
+import com.google.common.cache.*;
+import com.google.inject.*;
+import com.google.inject.Module;
+import com.google.inject.name.*;
+import kotlin.jvm.functions.*;
/**
* This class interfaces with Freenet. It is the class that is loaded by the
* node and starts up the whole Sone system.
- *
- * @author David âBombeâ Roden
*/
-public class SonePlugin implements FredPlugin, FredPluginL10n, FredPluginBaseL10n, FredPluginThreadless, FredPluginVersioned {
+public class SonePlugin implements FredPlugin, FredPluginFCP, FredPluginL10n, FredPluginBaseL10n, FredPluginThreadless, FredPluginVersioned {
+
+ private static final Logger soneLogger = getLogger("net.pterodactylus.sone");
static {
/* initialize logging. */
- Logging.setup("sone");
- Logging.addLoggingListener(new LoggingListener() {
+ soneLogger.setUseParentHandlers(false);
+ soneLogger.setLevel(Level.ALL);
+ soneLogger.addHandler(new Handler() {
+ private final LoadingCache> classCache = CacheBuilder.newBuilder()
+ .build(new CacheLoader>() {
+ @Override
+ public Class> load(@Nonnull String key) throws Exception {
+ return SonePlugin.class.getClassLoader().loadClass(key);
+ }
+ });
@Override
- public void logged(LogRecord logRecord) {
- Class> loggerClass = Logging.getLoggerClass(logRecord.getLoggerName());
+ public void publish(LogRecord logRecord) {
int recordLevel = logRecord.getLevel().intValue();
+ Class> loggingClass = classCache.getUnchecked(logRecord.getLoggerName());
if (recordLevel < Level.FINE.intValue()) {
- freenet.support.Logger.debug(loggerClass, String.format(logRecord.getMessage(), logRecord.getParameters()), logRecord.getThrown());
+ freenet.support.Logger.debug(loggingClass, logRecord.getMessage(), logRecord.getThrown());
} else if (recordLevel < Level.INFO.intValue()) {
- freenet.support.Logger.minor(loggerClass, String.format(logRecord.getMessage(), logRecord.getParameters()), logRecord.getThrown());
+ freenet.support.Logger.minor(loggingClass, logRecord.getMessage(), logRecord.getThrown());
} else if (recordLevel < Level.WARNING.intValue()) {
- freenet.support.Logger.normal(loggerClass, String.format(logRecord.getMessage(), logRecord.getParameters()), logRecord.getThrown());
+ freenet.support.Logger.normal(loggingClass, logRecord.getMessage(), logRecord.getThrown());
} else if (recordLevel < Level.SEVERE.intValue()) {
- freenet.support.Logger.warning(loggerClass, String.format(logRecord.getMessage(), logRecord.getParameters()), logRecord.getThrown());
+ freenet.support.Logger.warning(loggingClass, logRecord.getMessage(), logRecord.getThrown());
} else {
- freenet.support.Logger.error(loggerClass, String.format(logRecord.getMessage(), logRecord.getParameters()), logRecord.getThrown());
+ freenet.support.Logger.error(loggingClass, logRecord.getMessage(), logRecord.getThrown());
}
}
+
+ @Override
+ public void flush() {
+ }
+
+ @Override
+ public void close() {
+ }
});
}
- /** The version. */
- public static final Version VERSION = new Version(0, 3);
+ /** The current year at time of release. */
+ private static final int YEAR = 2020;
+ private static final String SONE_HOMEPAGE = "USK@nwa8lHa271k2QvJ8aa0Ov7IHAV-DFOCFgmDt3X6BpCI,DuQSUZiI~agF8c-6tjsFFGuZ8eICrzWCILB60nT8KKo,AQACAAE/sone/";
+ private static final int LATEST_EDITION = 80;
/** The logger. */
- private static final Logger logger = Logging.getLogger(SonePlugin.class);
+ private static final Logger logger = getLogger(SonePlugin.class.getName());
+
+ private final Function1 injectorCreator;
/** The plugin respirator. */
private PluginRespirator pluginRespirator;
@@ -90,17 +110,29 @@ public class SonePlugin implements FredPlugin, FredPluginL10n, FredPluginBaseL10
/** The core. */
private Core core;
+ /** The event bus. */
+ private EventBus eventBus;
+
/** The web interface. */
private WebInterface webInterface;
+ /** The FCP interface. */
+ private FcpInterface fcpInterface;
+
/** The l10n helper. */
private PluginL10n l10n;
- /** The plugin store. */
- private PluginStore pluginStore;
+ /** The web of trust connector. */
+ private WebOfTrustConnector webOfTrustConnector;
- /** The identity manager. */
- private IdentityManager identityManager;
+ public SonePlugin() {
+ this(Guice::createInjector);
+ }
+
+ @VisibleForTesting
+ public SonePlugin(Function1 injectorCreator) {
+ this.injectorCreator = injectorCreator;
+ }
//
// ACCESSORS
@@ -133,6 +165,23 @@ public class SonePlugin implements FredPlugin, FredPluginL10n, FredPluginBaseL10
return l10n;
}
+ public static String getPluginVersion() {
+ net.pterodactylus.sone.main.Version version = VersionParserKt.getParsedVersion();
+ return (version == null) ? "unknown" : version.getNice();
+ }
+
+ public int getYear() {
+ return YEAR;
+ }
+
+ public String getHomepage() {
+ return SONE_HOMEPAGE + LATEST_EDITION;
+ }
+
+ public static long getLatestEdition() {
+ return LATEST_EDITION;
+ }
+
//
// FREDPLUGIN METHODS
//
@@ -144,65 +193,59 @@ public class SonePlugin implements FredPlugin, FredPluginL10n, FredPluginBaseL10
public void runPlugin(PluginRespirator pluginRespirator) {
this.pluginRespirator = pluginRespirator;
- /* create a configuration. */
- Configuration configuration;
- Configuration xmlConfiguration = null;
- try {
- configuration = new Configuration(new MapConfigurationBackend(new File("sone.xml"), false));
- xmlConfiguration = configuration;
- } catch (ConfigurationException ce1) {
- try {
- xmlConfiguration = new Configuration(new MapConfigurationBackend(new File("sone.xml"), true));
- } catch (ConfigurationException ce2) {
- logger.log(Level.SEVERE, "Could not create XML file, using Plugin Store!");
- }
- try {
- configuration = new Configuration(new PluginStoreConfigurationBackend(pluginRespirator));
- } catch (DatabaseDisabledException dde1) {
- logger.log(Level.SEVERE, "Could not load any configuration, using in-memory configuration!");
- configuration = new Configuration(new MapConfigurationBackend());
- }
- }
-
- /* create freenet interface. */
- FreenetInterface freenetInterface = new FreenetInterface(pluginRespirator.getNode(), pluginRespirator.getHLSimpleClient());
+ Injector injector = createInjector();
+ core = injector.getInstance(Core.class);
/* create web of trust connector. */
- PluginConnector pluginConnector = new PluginConnector(pluginRespirator);
- WebOfTrustConnector webOfTrustConnector = new WebOfTrustConnector(pluginConnector);
- identityManager = new IdentityManager(webOfTrustConnector);
- identityManager.setContext("Sone");
+ webOfTrustConnector = injector.getInstance(WebOfTrustConnector.class);
- /* create core. */
- core = new Core(configuration, freenetInterface, identityManager);
+ /* create FCP interface. */
+ fcpInterface = injector.getInstance(FcpInterface.class);
/* create the web interface. */
- webInterface = new WebInterface(this);
- core.addCoreListener(webInterface);
+ webInterface = injector.getInstance(WebInterface.class);
- /* create the identity manager. */
- identityManager.addIdentityListener(core);
+ /* we need to request this to install all notification handlers. */
+ injector.getInstance(NotificationHandler.class);
+
+ /* and this is required to shutdown all tickers. */
+ injector.getInstance(TickerShutdown.class);
/* start core! */
- boolean startupFailed = true;
- try {
- core.start();
- if ((xmlConfiguration != null) && (configuration != xmlConfiguration)) {
- core.setConfiguration(xmlConfiguration);
- }
- webInterface.start();
- identityManager.start();
- startupFailed = false;
- } finally {
- if (startupFailed) {
- /*
- * we let the exception bubble up but shut the logging down so
- * that the logfile is not swamped by the installed logging
- * handlers of the failed instances.
- */
- Logging.shutdown();
+ core.start();
+
+ /* start the web interface! */
+ webInterface.start();
+
+ /* send some events on startup */
+ eventBus = injector.getInstance(EventBus.class);
+
+ /* first start? */
+ if (injector.getInstance(Key.get(Boolean.class, Names.named("FirstStart")))) {
+ eventBus.post(new FirstStart());
+ } else {
+ /* new config? */
+ if (injector.getInstance(Key.get(Boolean.class, Names.named("NewConfig")))) {
+ eventBus.post(new ConfigNotRead());
}
}
+
+ eventBus.post(new Startup());
+ }
+
+ @VisibleForTesting
+ protected Injector createInjector() {
+ FreenetModule freenetModule = new FreenetModule(pluginRespirator);
+ AbstractModule soneModule = new SoneModule(this, new EventBus());
+ Module webInterfaceModule = new WebInterfaceModule();
+ Module notificationHandlerModule = new NotificationHandlerModule();
+
+ return createInjector(freenetModule, soneModule, webInterfaceModule, notificationHandlerModule);
+ }
+
+ @VisibleForTesting
+ protected Injector createInjector(Module... modules) {
+ return injectorCreator.invoke(modules);
}
/**
@@ -210,6 +253,9 @@ public class SonePlugin implements FredPlugin, FredPluginL10n, FredPluginBaseL10
*/
@Override
public void terminate() {
+ /* send shutdown event. */
+ eventBus.post(new Shutdown());
+
try {
/* stop the web interface. */
webInterface.stop();
@@ -217,22 +263,33 @@ public class SonePlugin implements FredPlugin, FredPluginL10n, FredPluginBaseL10
/* stop the core. */
core.stop();
- /* stop the identity manager. */
- identityManager.stop();
-
- /* TODO wait for core to stop? */
- try {
- pluginRespirator.putStore(pluginStore);
- } catch (DatabaseDisabledException dde1) {
- logger.log(Level.WARNING, "Could not store plugin store, database is disabled.", dde1);
- }
-
+ /* stop the web of trust connector. */
+ webOfTrustConnector.stop();
+ } catch (Throwable t1) {
+ logger.log(Level.SEVERE, "Error while shutting down!", t1);
} finally {
- /* shutdown logger. */
- Logging.shutdown();
+ deregisterLoggerHandlers();
}
}
+ private void deregisterLoggerHandlers() {
+ for (Handler handler : soneLogger.getHandlers()) {
+ soneLogger.removeHandler(handler);
+ }
+ }
+
+ //
+ // INTERFACE FredPluginFCP
+ //
+
+ /**
+ * {@inheritDoc}
+ */
+ @Override
+ public void handle(PluginReplySender pluginReplySender, SimpleFieldSet parameters, Bucket data, int accessType) {
+ fcpInterface.handle(pluginReplySender, parameters, data, accessType);
+ }
+
//
// INTERFACE FredPluginL10n
//
@@ -298,7 +355,7 @@ public class SonePlugin implements FredPlugin, FredPluginL10n, FredPluginBaseL10
*/
@Override
public String getVersion() {
- return VERSION.toString();
+ return getPluginVersion();
}
}