src/main/kotlin/net/pterodactylus/sone/main/SoneModule.kt

   1 package net.pterodactylus.sone.main
   2
   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
  21 import java.io.*
  22 import java.util.concurrent.*
  23 import java.util.concurrent.Executors.*
  24 import java.util.logging.*
  25 import javax.inject.*
  26 import javax.inject.Singleton
  27
  28 open class SoneModule(private val sonePlugin: SonePlugin, private val eventBus: EventBus) : AbstractModule() {
  29
  30         override fun configure() {
  31                 val sonePropertiesFile = File("sone.properties")
  32                 val firstStart = !sonePropertiesFile.exists()
  33                 var newConfig = false
  34                 val configuration = try {
  35                         Configuration(MapConfigurationBackend(sonePropertiesFile, false))
  36                 } catch (ce: ConfigurationException) {
  37                         sonePropertiesFile.delete()
  38                         newConfig = true
  39                         Configuration(MapConfigurationBackend(sonePropertiesFile, true))
  40                 }
  41                 val context = Context("Sone")
  42                 val loaders = configuration.getStringValue("Developer.LoadFromFilesystem")
  43                                 .getValue(null)
  44                                 ?.let {
  45                                         configuration.getStringValue("Developer.FilesystemPath")
  46                                                         .getValue(null)
  47                                                         ?.let { DebugLoaders(it) }
  48                                 }
  49
  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)
  69
  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)
  75                                 })
  76                         }
  77                 })
  78         }
  79
  80         @Provides
  81         @Singleton
  82         @Named("notification")
  83         fun getNotificationTicker(): ScheduledExecutorService =
  84                         newSingleThreadScheduledExecutor()
  85
  86         private val logger: Logger = Logging.getLogger(javaClass)
  87
  88 }
  89
  90 private fun String.parseVersion(): Version = Version.parse(this)