birbnetes/output-service-rdb
birbnetes/output-service-rdb
4
0
Fork 0
Code Pull Requests Releases Wiki Activity

pajeet nation
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Torma Kristóf 2021-08-17 15:34:49 +02:00
parent 9c432ae60d
commit 5f2d88d3d2
Signed by: tormakris
GPG Key ID: DC83C4F2C41B1047
1 changed files with 38 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
src/api/route/OutputServiceRDBServer.kt
View File

@ -9,36 +9,62 @@ import io.ktor.routing.get
import org.koin.ktor.ext.inject
import java.time.LocalDate
import java.time.format.DateTimeFormatter
import kotlin.math.ceil
import kotlin.math.roundToInt
/**
* Output Service - RDB
*
*
* This is the output interface of the Birbnetes system.
*/
class OutputServiceRDBServer {
/**
* output
*/
fun Routing.registerOutput() {
val resultObjectService:IResultObjectService by inject()
get("/output"){
val resultObjectService: IResultObjectService by inject()
get("/output") {
call.respond(resultObjectService.getAllResultObjects())
}
get("/output/count") {
call.respond(resultObjectService.getAllResultObjects().size)
}
get("/output/page/{page}") {
val page = call.parameters["page"] ?: error(HttpStatusCode.NotAcceptable)
val pageNum = page.toInt()
val results = resultObjectService.getAllResultObjects()
val maxPageNum = ceil(results.size / 10.0).roundToInt() - 1
if (pageNum == 0) {
call.respond(results.subList(0, 10))
} else {
if (pageNum == maxPageNum) {
call.respond(results.subList((pageNum * 10) + 1, results.size))
} else {
call.respond(results.subList((pageNum * 10) + 1, (pageNum * 10) + 10))
}
}
}
get("/output/filter/negative") {
val resultList = resultObjectService.getResultObjecLessthanProbability(0.5) ?: call.respond(HttpStatusCode.NotFound)
val resultList =
resultObjectService.getResultObjecLessthanProbability(0.5) ?: call.respond(HttpStatusCode.NotFound)
call.respond(resultList)
}
get("/output/filter/positive") {
val resultList = resultObjectService.getResultObjecGreaterthanProbability(0.5) ?: call.respond(HttpStatusCode.NotFound)
val resultList =
resultObjectService.getResultObjecGreaterthanProbability(0.5) ?: call.respond(HttpStatusCode.NotFound)
call.respond(resultList)
}
get("/output/filter/undecided") {
val resultList = resultObjectService.getResultObjecEqualsProbability(0.5) ?: call.respond(HttpStatusCode.NotFound)
val resultList =
resultObjectService.getResultObjecEqualsProbability(0.5) ?: call.respond(HttpStatusCode.NotFound)
call.respond(resultList)
}
@ -46,8 +72,9 @@ class OutputServiceRDBServer {
get("/output/after/{dateAfter}") {
val dateAfter = call.parameters["dateAfter"] ?: error(HttpStatusCode.NotAcceptable)
val dateTimeFormatter: DateTimeFormatter = DateTimeFormatter.ISO_LOCAL_DATE
val localDateAfter : LocalDate = LocalDate.parse(dateAfter,dateTimeFormatter)
val resultList = resultObjectService.getResultObjectafterDate(localDateAfter) ?: call.respond(HttpStatusCode.NotFound)
val localDateAfter: LocalDate = LocalDate.parse(dateAfter, dateTimeFormatter)
val resultList =
resultObjectService.getResultObjectafterDate(localDateAfter) ?: call.respond(HttpStatusCode.NotFound)
call.respond(resultList)
}
@ -55,8 +82,9 @@ class OutputServiceRDBServer {
get("/output/before/{dateBefore}") {
val dateAfter = call.parameters["dateBefore"] ?: error(HttpStatusCode.NotAcceptable)
val dateTimeFormatter: DateTimeFormatter = DateTimeFormatter.ISO_LOCAL_DATE
val localDateBefore : LocalDate = LocalDate.parse(dateAfter,dateTimeFormatter)
val resultList = resultObjectService.getResultObjectbeforeDate(localDateBefore) ?: call.respond(HttpStatusCode.NotFound)
val localDateBefore: LocalDate = LocalDate.parse(dateAfter, dateTimeFormatter)
val resultList =
resultObjectService.getResultObjectbeforeDate(localDateBefore) ?: call.respond(HttpStatusCode.NotFound)
call.respond(resultList)
}