mirror/Buran
1
0
Fork 0
mirror of https://github.com/Corewala/Buran synced 2025-03-11 06:33:20 +00:00
Code Issues Releases Wiki Activity

Fixed redirect drop bug

Browse source
This commit is contained in:
Corewala 2023-02-04 19:46:26 -05:00
parent 0fdffee966
commit 73afc7c684
1 changed files with 20 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

37
app/src/main/java/corewala/buran/io/gemini/GeminiDatasource.kt
View file

@ -133,7 +133,7 @@ class GeminiDatasource(private val context: Context, val history: BuranHistory):
val bufferedReader = BufferedReader(headerInputReader) val bufferedReader = BufferedReader(headerInputReader)
val headerLine = bufferedReader.readLine() val headerLine = bufferedReader.readLine()
println("Buran: response header: $headerLine") println("Buran response header: $headerLine")
if(headerLine == null){ if(headerLine == null){
if(currentRequestAddress == uri.toString()){ if(currentRequestAddress == uri.toString()){
@ -144,23 +144,27 @@ class GeminiDatasource(private val context: Context, val history: BuranHistory):
val header = GeminiResponse.parseHeader(headerLine) val header = GeminiResponse.parseHeader(headerLine)
when { if(currentRequestAddress == uri.toString()){
currentRequestAddress != uri.toString() -> {} currentRequestAddress = null
header.code == GeminiResponse.INPUT -> onUpdate(GemState.ResponseInput(uri, header)) when {
header.code == GeminiResponse.REDIRECT -> onUpdate(GemState.Redirect(header.meta)) header.code == GeminiResponse.INPUT -> onUpdate(GemState.ResponseInput(uri, header))
header.code == GeminiResponse.CLIENT_CERTIFICATE_REQUIRED -> onUpdate(GemState.ClientCertRequired(uri, header)) header.code == GeminiResponse.REDIRECT -> onUpdate(GemState.Redirect(header.meta))
header.code != GeminiResponse.SUCCESS -> onUpdate(GemState.ResponseError(header)) header.code == GeminiResponse.CLIENT_CERTIFICATE_REQUIRED -> onUpdate(GemState.ClientCertRequired(uri, header))
header.meta.startsWith("text/gemini") -> getGemtext(bufferedReader, requestEntity.trim().toURI(), header, onUpdate) header.code != GeminiResponse.SUCCESS -> onUpdate(GemState.ResponseError(header))
header.meta.startsWith("text/") -> getString(socket, uri, header, onUpdate) header.meta.startsWith("text/gemini") -> getGemtext(bufferedReader, requestEntity.trim().toURI(), header, onUpdate)
header.meta.startsWith("image/") -> getBinary(socket, uri, header, onUpdate) header.meta.startsWith("text/") -> getString(socket, uri, header, onUpdate)
else -> { header.meta.startsWith("image/") -> getBinary(socket, uri, header, onUpdate)
//File served over Gemini but not handled in-app, eg .pdf else -> {
if(forceDownload){ //File served over Gemini but not handled in-app, eg .pdf
getBinary(socket, uri, header, onUpdate) if(forceDownload){
}else{ getBinary(socket, uri, header, onUpdate)
onUpdate(GemState.ResponseUnknownMime(uri, header)) }else{
onUpdate(GemState.ResponseUnknownMime(uri, header))
}
} }
} }
}else{
println("Buran dropped response from $uri: request cancelled or superseded")
} }
//Close input //Close input
@ -172,7 +176,6 @@ class GeminiDatasource(private val context: Context, val history: BuranHistory):
bufferedWriter.close() bufferedWriter.close()
outWriter.close() outWriter.close()
currentRequestAddress = null
socket.close() socket.close()
} }