wulkanowy/sdk
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

cs fix

Browse source
This commit is contained in:
Mikołaj Pich 2019-02-22 20:35:56 +01:00
parent 8e4138e873
commit d2ef844b4f
No known key found for this signature in database
GPG key ID: F62B26E36D4C4BAA
1 changed files with 33 additions and 33 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

66
src/main/kotlin/io/github/wulkanowy/api/repository/RegisterRepository.kt
View file

@ -34,28 +34,28 @@ class RegisterRepository(
fun getStudents(): Single<List<Student>> {
return getSymbols().flatMapObservable { Observable.fromIterable(it) }.flatMap { symbol ->
loginHelper.sendCertificate(symbol.second, symbol.second.action.replace(startSymbol, symbol.first))
.onErrorResumeNext { t ->
if (t is AccountPermissionException) Single.just(SendCertificateResponse())
else Single.error(t)
}
.flatMapObservable { Observable.fromIterable(if (useNewStudent) it.studentSchools else it.oldStudentSchools) }
.flatMapSingle { schoolUrl ->
getLoginType(symbol.first).flatMap { loginType ->
getStudents(symbol.first, schoolUrl).map {
it.map { student ->
Student(
email = email,
symbol = symbol.first,
studentId = student.id,
studentName = student.name,
schoolSymbol = getExtractedSchoolSymbolFromUrl(schoolUrl),
schoolName = student.description,
loginType = loginType
)
}
.onErrorResumeNext { t ->
if (t is AccountPermissionException) Single.just(SendCertificateResponse())
else Single.error(t)
}
.flatMapObservable { Observable.fromIterable(if (useNewStudent) it.studentSchools else it.oldStudentSchools) }
.flatMapSingle { schoolUrl ->
getLoginType(symbol.first).flatMap { loginType ->
getStudents(symbol.first, schoolUrl).map {
it.map { student ->
Student(
email = email,
symbol = symbol.first,
studentId = student.id,
studentName = student.name,
schoolSymbol = getExtractedSchoolSymbolFromUrl(schoolUrl),
schoolName = student.description,
loginType = loginType
)
}
}
}
}
}.toList().map { it.flatten().distinctBy { pupil -> pupil.studentId to pupil.schoolSymbol } }
}
@ -69,18 +69,18 @@ class RegisterRepository(
}
}
} else student.getSchoolInfo(url.generate(ServiceManager.UrlGenerator.Site.STUDENT) + "UczenDziennik.mvc/Get")
.map { diary -> diary.data?.distinctBy { it.studentId } }
.flatMap { diaries ->
student.getStart(url.generate(ServiceManager.UrlGenerator.Site.STUDENT) + "Start").map { startPage ->
diaries.map {
StudentAndParentResponse.Student().apply {
id = it.studentId
name = "${it.studentName} ${it.studentSurname}"
description = getScriptParam("organizationName", startPage, it.symbol + " " + (it.year - it.level + 1))
}
.map { diary -> diary.data?.distinctBy { it.studentId } }
.flatMap { diaries ->
student.getStart(url.generate(ServiceManager.UrlGenerator.Site.STUDENT) + "Start").map { startPage ->
diaries.map {
StudentAndParentResponse.Student().apply {
id = it.studentId
name = "${it.studentName} ${it.studentSurname}"
description = getScriptParam("organizationName", startPage, it.symbol + " " + (it.year - it.level + 1))
}
}
}
}
}
private fun getSymbols(): Single<List<Pair<String, CertificateResponse>>> {
@ -89,11 +89,11 @@ class RegisterRepository(
}.flatMap { login ->
login.sendCredentials(email, password).flatMap { Single.just(it) }.flatMap { cert ->
Single.just(Jsoup.parse(cert.wresult.replace(":", ""), "", Parser.xmlParser())
.select("[AttributeName$=\"Instance\"] samlAttributeValue")
.map { it.text().trim() }
.filter { it.matches("[a-zA-Z]*".toRegex()) } // early filter invalid symbols
.ifEmpty { listOf("opole", "gdansk", "tarnow", "rzeszow") } // fallback
.map { Pair(it, cert) }
.select("[AttributeName$=\"Instance\"] samlAttributeValue")
.map { it.text().trim() }
.filter { it.matches("[a-zA-Z]*".toRegex()) } // early filter invalid symbols
.ifEmpty { listOf("opole", "gdansk", "tarnow", "rzeszow") } // fallback
.map { Pair(it, cert) }
)
}
}