1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
|
package io.crashbox.ci
import java.io.{
BufferedInputStream,
File,
FileInputStream,
FileOutputStream,
InputStream,
OutputStream
}
import java.util.UUID
import slick.driver.H2Driver.api._
trait Storage { self: Core with Parsers with Schedulers =>
type BuildId = UUID
def newBuildId() = UUID.randomUUID()
private val streamsDirectory: File = new File(
config.getString("crashbox.streams.directory"))
private def logFile(buildId: BuildId, task: Int): File = {
def stringifyId(id: BuildId): String = {
val bytes = new Array[Byte](16) // 128 bits
for (i <- 0 until 8) {
bytes(i) = ((id.getLeastSignificantBits >> i) & 0xff).toByte
}
for (i <- 0 until 8) {
bytes(8 + i) = ((id.getMostSignificantBits >> i) & 0xff).toByte
}
bytes.map { byte =>
Integer.toString((byte & 0xff) + 0x100, 16)
}.mkString
}
val (dir1, tail) = stringifyId(buildId).splitAt(2)
val (dir2, dir3) = tail.splitAt(2)
new File(streamsDirectory, s"$dir1/$dir2/$dir3/$task")
}
def saveLog(buildId: BuildId, task: Int): OutputStream = {
val file = logFile(buildId, task)
file.getParentFile.mkdirs()
file.createNewFile()
file.setWritable(true)
new FileOutputStream(file)
}
def readLog(buildId: BuildId, task: Int): InputStream = {
new FileInputStream(logFile(buildId, task))
}
def updateBuildState(buildId: BuildId, state: BuildState) = {
log.info(s"Build $buildId: state update $state")
}
}
|
