blob: b74e3a63e3579a1a5b45c23ef42a571bedca03f3 (
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
63
64
65
|
package mavigator
import akka.actor._
import akka.stream._
import akka.stream.scaladsl._
import akka.http.scaladsl._
import akka.http.scaladsl.model._
import akka.http.scaladsl.model.ws._
import akka.http.scaladsl.server._
import uav.Uav
import akka.util._
object Router {
import Directives._
def route(implicit system: ActorSystem): Route = (
path("info") {
get {
val f: play.twirl.api.Html = mavigator.views.html.index()
complete(f.body)
}
} ~
path("dashboard" / IntNumber) { id =>
get {
//get dashboard for remote sys id
???
}
} ~
path("mavlink") {
get {
/*extractUpgradeToWebsocket{ upgrade =>
//upgrade.handleMessagesWith(inSink: Sink[Message, _$3], outSource: Source[Message, _$4])
???
}*/
val fromWebSocket = Flow[Message].collect{
case BinaryMessage.Strict(data) => data
}
val toWebSocket = Flow[ByteString].map{bytes =>
//BinaryMessage(bytes)
TextMessage(bytes.decodeString("UTF-8"))
}
val bytes = Uav().connect()
handleWebSocketMessages(fromWebSocket via bytes via toWebSocket)
}
} ~
pathPrefix("assets") {
get {
encodeResponse {
getFromResourceDirectory("assets")
}
}
} ~
pathEndOrSingleSlash {
get {
complete("hello world")
}
}
)
}
|
