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()
	}))
}