forked from SPC/spc-site
93 lines
3.0 KiB
Kotlin
93 lines
3.0 KiB
Kotlin
package ru.mipt.spc
|
|
|
|
import io.ktor.server.application.Application
|
|
import io.ktor.server.application.log
|
|
import kotlinx.css.CssBuilder
|
|
import kotlinx.html.CommonAttributeGroupFacade
|
|
import kotlinx.html.style
|
|
import space.kscience.dataforge.context.Context
|
|
import space.kscience.snark.SnarkPlugin
|
|
import java.net.URI
|
|
import java.nio.file.FileSystems
|
|
import java.nio.file.Files
|
|
import java.nio.file.Path
|
|
import java.time.LocalDateTime
|
|
import kotlin.io.path.*
|
|
|
|
fun CommonAttributeGroupFacade.css(block: CssBuilder.() -> Unit) {
|
|
style = CssBuilder().block().toString()
|
|
}
|
|
|
|
private fun Application.resolveData(uri: URI, targetPath: Path): Path {
|
|
if (Files.isDirectory(targetPath)) {
|
|
log.info("Using existing data directory at $targetPath.")
|
|
} else {
|
|
log.info("Copying data from $uri into $targetPath.")
|
|
targetPath.createDirectories()
|
|
//Copy everything into a temporary directory
|
|
FileSystems.newFileSystem(uri, emptyMap<String, Any>()).use { fs ->
|
|
val rootPath: Path = fs.provider().getPath(uri)
|
|
Files.walk(rootPath).forEach { source: Path ->
|
|
if (source.isRegularFile()) {
|
|
val relative = source.relativeTo(rootPath).toString()
|
|
val destination: Path = targetPath.resolve(relative)
|
|
destination.parent.createDirectories()
|
|
Files.copy(source, destination)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
return targetPath
|
|
}
|
|
|
|
const val DEPLOY_DATE_FILE = "deployDate"
|
|
const val BUILD_DATE_FILE = "/buildDate"
|
|
|
|
@Suppress("unused")
|
|
fun Application.spcModule() {
|
|
val context = Context("spc-site") {
|
|
plugin(SnarkPlugin)
|
|
}
|
|
|
|
val dataPath = Path.of("data")
|
|
|
|
// Clear data directory if it is outdated
|
|
val deployDate = dataPath.resolve(DEPLOY_DATE_FILE).takeIf { it.exists() }
|
|
?.readText()?.let { LocalDateTime.parse(it) }
|
|
val buildDate = javaClass.getResource(BUILD_DATE_FILE)?.readText()?.let { LocalDateTime.parse(it) }
|
|
|
|
if (deployDate != null && buildDate != null && buildDate.isAfter(deployDate)) {
|
|
log.info("Outdated data. Resetting data directory.")
|
|
dataPath.deleteIfExists()
|
|
|
|
//Writing deploy date file
|
|
dataPath.createDirectories()
|
|
dataPath.resolve(DEPLOY_DATE_FILE).writeText(LocalDateTime.now().toString())
|
|
} else if (deployDate == null && buildDate != null) {
|
|
|
|
//Writing deploy date in production mode if it does not exist
|
|
dataPath.createDirectories()
|
|
dataPath.resolve(DEPLOY_DATE_FILE).writeText(LocalDateTime.now().toString())
|
|
}
|
|
|
|
|
|
val homeDataPath = resolveData(
|
|
javaClass.getResource("/home")!!.toURI(),
|
|
dataPath / "home"
|
|
)
|
|
|
|
spcHome(context, rootPath = homeDataPath)
|
|
|
|
|
|
val mastersDataPath = resolveData(
|
|
javaClass.getResource("/magprog")!!.toURI(),
|
|
dataPath / "magprog"
|
|
)
|
|
|
|
spcMaster(context, dataPath = mastersDataPath)
|
|
}
|
|
|
|
|
|
fun main(args: Array<String>) = io.ktor.server.netty.EngineMain.main(args)
|
|
|