Skip to content
Snippets Groups Projects
Select Git revision
  • rewrite
  • master default
2 results

PlayPadServer.scala

Blame
  • PlayPadServer.scala 3.97 KiB
    package de.tobias.playpad.server
    
    import java.nio.file.{Files, Paths}
    import java.sql.DriverManager
    
    import com.j256.ormlite.dao.{Dao, DaoManager}
    import com.j256.ormlite.jdbc.JdbcConnectionSource
    import com.j256.ormlite.table.TableUtils
    import de.thecodelabs.logger.{FileOutputOption, LogLevelFilter, Logger, Slf4JLoggerAdapter}
    import de.thecodelabs.utils.application.ApplicationUtils
    import de.thecodelabs.utils.application.container.PathType
    import de.tobias.playpad.server.account.{Account, Session}
    import de.tobias.playpad.server.plugin.Plugin
    import de.tobias.playpad.server.server.SqlHelper
    import de.tobias.playpad.server.server.account._
    import de.tobias.playpad.server.server.plugin.{PluginGet, PluginList}
    import de.tobias.playpad.server.server.project._
    import de.tobias.playpad.server.server.project.sync.ProjectSyncHandler
    import de.tobias.playpad.server.settings.SettingsHandler
    import de.tobias.playpad.server.transformer.JsonTransformer
    import spark.Spark._
    
    /**
     * Created by tobias on 29.01.17.
     */
    object PlayPadServer extends App {
    
    	val app = ApplicationUtils.registerMainApplication(getClass)
    	ApplicationUtils.addAppListener(_ => {
    		Logger.init(app.getPath(PathType.LOG))
    		Slf4JLoggerAdapter.disableSlf4jDebugPrints()
    		Logger.setLevelFilter(LogLevelFilter.DEBUG)
    		Logger.setFileOutput(FileOutputOption.COMBINED)
    	})
    	app.start(args)
    
    	// Load Config
    	private val settingsLoader = SettingsHandler.loader
    	private val settingsPath = Paths.get("settings.properties")
    
    	if (Files.notExists(settingsPath)) {
    		SettingsHandler.saver.default(settingsPath)
    	}
    
    	private val settings = settingsLoader.load(settingsPath)
    
    	private val databaseUrl = s"jdbc:mysql://${settings.db_host}:${settings.db_port}/${settings.db_database}?" +
    		s"autoReconnect=true&wait_timeout=86400&serverTimezone=Europe/Berlin"
    	var connectionSource = new JdbcConnectionSource(databaseUrl)
    	connectionSource.setUsername(settings.db_username)
    	connectionSource.setPassword(settings.db_password)
    
    	private val databaseConnection = DriverManager.getConnection(databaseUrl, settings.db_username, settings.db_password)
    
    	val pluginDao: Dao[Plugin, Int] = DaoManager.createDao(connectionSource, classOf[Plugin])
    	val accountDao: Dao[Account, Int] = DaoManager.createDao(connectionSource, classOf[Account])
    	val sessionDao: Dao[Session, Int] = DaoManager.createDao(connectionSource, classOf[Session])
    
    	// Management Tables
    	TableUtils.createTableIfNotExists(connectionSource, classOf[Plugin])
    	TableUtils.createTableIfNotExists(connectionSource, classOf[Account])
    	TableUtils.createTableIfNotExists(connectionSource, classOf[Session])
    	SqlHelper.createTables(databaseConnection)
    
    	// Setup Http Server
    	port(8090)
    	threadPool(8, 2, 60 * 60 * 1000)
    
    	private val externalPath = Paths.get(settings.download_folder).toAbsolutePath.toString
    	externalStaticFileLocation(externalPath)
    
    	//secure("deploy/keystore.jks", settings.keystorePassword, null, null)
    
    	// PlayWall Cloud
    	webSocket("/project", new ProjectSyncHandler(sessionDao, databaseConnection))
    
    	// Project
    	private val transformer = new JsonTransformer
    
    	get("/projects/:id", new ProjectGet(databaseConnection, sessionDao), transformer)
    	get("/projects", new ProjectList(databaseConnection, sessionDao), transformer)
    	post("/projects", new ProjectPost(databaseConnection, sessionDao), transformer)
    	delete("/projects", new ProjectDelete(databaseConnection, sessionDao), transformer)
    
    	// Plugins
    	get("/plugins/:id", new PluginGet(pluginDao), transformer)
    	get("/plugins", new PluginList(pluginDao), transformer)
    
    	// Account
    	post("/accounts", new AccountPost(accountDao), transformer)
    	put("/accounts", new AccountPut(accountDao), transformer)
    
    	post("/sessions", new SessionPost(accountDao), transformer)
    	delete("/sessions", new SessionDelete(accountDao), transformer)
    	get("/sessions", new SessionGet(accountDao), transformer)
    
    	SettingsHandler.saver.save(settings, settingsPath)
    
    	Runtime.getRuntime.addShutdownHook(new Thread(() => {
    		databaseConnection.close()
    		connectionSource.close()
    		stop()
    	}))
    }