1 package net.pterodactylus.sone.main
3 import com.codahale.metrics.*
4 import com.google.common.base.*
5 import com.google.common.eventbus.*
6 import com.google.inject.*
7 import com.google.inject.matcher.*
8 import com.google.inject.name.Names.*
9 import com.google.inject.spi.*
10 import net.pterodactylus.sone.core.SoneUriCreator
11 import net.pterodactylus.sone.database.*
12 import net.pterodactylus.sone.database.memory.*
13 import net.pterodactylus.sone.freenet.*
14 import net.pterodactylus.sone.freenet.wot.*
15 import net.pterodactylus.sone.web.FreenetSessionProvider
16 import net.pterodactylus.sone.web.SessionProvider
17 import net.pterodactylus.util.config.*
18 import net.pterodactylus.util.config.ConfigurationException
19 import net.pterodactylus.util.logging.*
20 import net.pterodactylus.util.version.Version
22 import java.util.concurrent.*
23 import java.util.concurrent.Executors.*
24 import java.util.logging.*
26 import javax.inject.Singleton
28 open class SoneModule(private val sonePlugin: SonePlugin, private val eventBus: EventBus) : AbstractModule() {
30 override fun configure() {
31 val sonePropertiesFile = File("sone.properties")
32 val firstStart = !sonePropertiesFile.exists()
34 val configuration = try {
35 Configuration(MapConfigurationBackend(sonePropertiesFile, false))
36 } catch (ce: ConfigurationException) {
37 sonePropertiesFile.delete()
39 Configuration(MapConfigurationBackend(sonePropertiesFile, true))
41 val context = Context("Sone")
42 val loaders = configuration.getStringValue("Developer.LoadFromFilesystem")
45 configuration.getStringValue("Developer.FilesystemPath")
47 ?.let { DebugLoaders(it) }
50 bind(Configuration::class.java).toInstance(configuration)
51 bind(EventBus::class.java).toInstance(eventBus)
52 bind(Boolean::class.java).annotatedWith(named("FirstStart")).toInstance(firstStart)
53 bind(Boolean::class.java).annotatedWith(named("NewConfig")).toInstance(newConfig)
54 bind(Context::class.java).toInstance(context)
55 bind(object : TypeLiteral<Optional<Context>>() {}).toInstance(Optional.of(context))
56 bind(SonePlugin::class.java).toInstance(sonePlugin)
57 bind(Version::class.java).toInstance(sonePlugin.version.drop(1).parseVersion())
58 bind(PluginVersion::class.java).toInstance(PluginVersion(sonePlugin.version))
59 bind(PluginYear::class.java).toInstance(PluginYear(sonePlugin.year))
60 bind(PluginHomepage::class.java).toInstance(PluginHomepage(sonePlugin.homepage))
61 bind(Database::class.java).to(MemoryDatabase::class.java).`in`(Singleton::class.java)
62 bind(Translation::class.java).toInstance(BaseL10nTranslation(sonePlugin.l10n().base))
63 loaders?.let { bind(Loaders::class.java).toInstance(it) }
64 bind(MetricRegistry::class.java).`in`(Singleton::class.java)
65 bind(WebOfTrustConnector::class.java).to(PluginWebOfTrustConnector::class.java).`in`(Singleton::class.java)
66 bind(TickerShutdown::class.java).`in`(Singleton::class.java)
67 bind(SoneUriCreator::class.java).`in`(Singleton::class.java)
68 bind(SessionProvider::class.java).to(FreenetSessionProvider::class.java).`in`(Singleton::class.java)
70 bindListener(Matchers.any(), object : TypeListener {
71 override fun <I> hear(typeLiteral: TypeLiteral<I>, typeEncounter: TypeEncounter<I>) {
72 typeEncounter.register(InjectionListener { injectee ->
73 logger.fine { "Injecting $injectee..." }
74 eventBus.register(injectee)
82 @Named("notification")
83 fun getNotificationTicker(): ScheduledExecutorService =
84 newSingleThreadScheduledExecutor()
86 private val logger: Logger = Logging.getLogger(javaClass)
90 private fun String.parseVersion(): Version = Version.parse(this)