blob: 7cb76b0f1c9632975926c931f49f59970baa0510 (
plain) (
blame)
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.net.URL
import java.security.MessageDigest
import akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport._
import akka.http.scaladsl.marshalling.{Marshaller, ToResponseMarshaller}
import akka.http.scaladsl.model.{ContentTypes, HttpEntity}
import akka.http.scaladsl.model.HttpEntity.ChunkStreamPart
import akka.http.scaladsl.model.HttpResponse
import akka.http.scaladsl.server._
import akka.http.scaladsl.server.Directives._
import akka.stream.OverflowStrategy
import akka.stream.scaladsl.{Source => Src}
import spray.json.DefaultJsonProtocol
trait HttpApi { self: Core with Schedulers with StreamStore =>
val endpoint = "api"
case class Request(url: String) {
def buildId: String = {
val bytes = MessageDigest.getInstance("SHA-256").digest(url.getBytes)
bytes.map { byte =>
Integer.toString((byte & 0xff) + 0x100, 16)
}.mkString
}
}
object Protocol extends DefaultJsonProtocol {
implicit val request = jsonFormat1(Request)
}
import Protocol._
implicit val toResponseMarshaller: ToResponseMarshaller[Src[BuildState, Any]] =
Marshaller.opaque { items =>
val data = items.map(item => ChunkStreamPart(item.toString + "\n"))
HttpResponse(
entity = HttpEntity.Chunked(ContentTypes.`text/plain(UTF-8)`, data))
}
def httpApi: Route = pathPrefix(endpoint) {
path("submit") {
entity(as[Request]) { req =>
val source = Src
.queue[BuildState](100, OverflowStrategy.fail)
.mapMaterializedValue { q =>
start(
req.buildId,
new URL(req.url),
() => saveStream(req.buildId),
state => q.offer(state)
)
}
complete(source)
}
}
}
}
|
