renun/legado
1
0
Fork 0
mirror of https://github.com/gedoor/legado.git synced 2025-08-10 00:52:30 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/master'

Browse Source
This commit is contained in:
kunfei
2023-03-27 11:43:16 +08:00
parent ae6ccfb200 316ac61e17
commit bf5e90a97f
5 changed files with 112 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
api.md
View File

@@ -59,6 +59,16 @@ URL = http://127.0.0.1:1234/deleteRssSources
Method = POST
```
#### 调试源
key为书源搜索关键词，tag为源链接
```
URL = ws://127.0.0.1:1235/bookSourceDebug
URL = ws://127.0.0.1:1235/rssSourceDebug
Message = { key: [String], tag: [String] }
```
#### 获取替换规则
```
@@ -99,9 +109,8 @@ Body = { rule: [ReplaceRule], text: [String] }
#### 搜索在线书籍
```
URL = http://127.0.0.1:1234/searchBook
Method = POST
Body = { key: [String], page: [Number] }
URL = ws://127.0.0.1:1235/searchBook
Message = { key: [String] }
```
#### 插入书籍

2
app/src/main/java/io/legado/app/api/controller/BookController.kt
View File

@@ -200,7 +200,7 @@ object BookController {
fun saveBook(postData: String?): ReturnData {
val returnData = ReturnData()
GSON.fromJsonObject<Book>(postData).getOrNull()?.let { book ->
appDb.bookDao.update(book)
appDb.bookDao.insert(book)
AppWebDav.uploadBookProgress(book)
return returnData.setData("")
}

9
app/src/main/java/io/legado/app/web/HttpServer.kt
View File

@@ -1,7 +1,6 @@
package io.legado.app.web
import android.graphics.Bitmap
import com.google.gson.Gson
import fi.iki.elonen.NanoHTTPD
import io.legado.app.api.ReturnData
import io.legado.app.api.controller.BookController
@@ -9,13 +8,11 @@ import io.legado.app.api.controller.BookSourceController
import io.legado.app.api.controller.ReplaceRuleController
import io.legado.app.api.controller.RssSourceController
import io.legado.app.service.WebService
import io.legado.app.utils.FileUtils
import io.legado.app.utils.externalFiles
import io.legado.app.utils.*
import io.legado.app.web.utils.AssetsWeb
import splitties.init.appCtx
import java.io.*
class HttpServer(port: Int) : NanoHTTPD(port) {
private val assetsWeb = AssetsWeb("web")
@@ -100,7 +97,7 @@ class HttpServer(port: Int) : NanoHTTPD(port) {
)
} else {
try {
newFixedLengthResponse(Gson().toJson(returnData))
newFixedLengthResponse(GSON.toJson(returnData))
} catch (e: OutOfMemoryError) {
val path = FileUtils.getPath(
appCtx.externalFiles,
@@ -109,7 +106,7 @@ class HttpServer(port: Int) : NanoHTTPD(port) {
)
val file = FileUtils.createFileIfNotExist(path)
BufferedWriter(FileWriter(file)).use {
Gson().toJson(returnData, it)
GSON.toJson(returnData, it)
}
val fis = FileInputStream(file)
newFixedLengthResponse(

6
app/src/main/java/io/legado/app/web/WebSocketServer.kt
View File

@@ -2,8 +2,7 @@ package io.legado.app.web
import fi.iki.elonen.NanoWSD
import io.legado.app.service.WebService
import io.legado.app.web.socket.BookSourceDebugWebSocket
import io.legado.app.web.socket.RssSourceDebugWebSocket
import io.legado.app.web.socket.*
class WebSocketServer(port: Int) : NanoWSD(port) {
@@ -16,6 +15,9 @@ class WebSocketServer(port: Int) : NanoWSD(port) {
"/rssSourceDebug" -> {
RssSourceDebugWebSocket(handshake)
}
"/searchBook" -> {
BookSearchWebSocket(handshake)
}
else -> null
}
}

92
app/src/main/java/io/legado/app/web/socket/BookSearchWebSocket.kt Normal file
View File

@@ -0,0 +1,92 @@
package io.legado.app.web.socket
import fi.iki.elonen.NanoHTTPD
import fi.iki.elonen.NanoWSD
import io.legado.app.R
import io.legado.app.data.entities.SearchBook
import io.legado.app.help.config.AppConfig
import io.legado.app.model.webBook.SearchModel
import io.legado.app.ui.book.search.SearchScope
import io.legado.app.utils.*
import kotlinx.coroutines.*
import kotlinx.coroutines.Dispatchers.IO
import splitties.init.appCtx
import java.io.IOException
class BookSearchWebSocket(handshakeRequest: NanoHTTPD.IHTTPSession) :
NanoWSD.WebSocket(handshakeRequest),
CoroutineScope by MainScope(),
SearchModel.CallBack {
private val normalClosure = NanoWSD.WebSocketFrame.CloseCode.NormalClosure
private val searchModel = SearchModel(this, this)
private val SEARCH_FINISH = "Search finish"
override fun onOpen() {
launch(IO) {
kotlin.runCatching {
while (isOpen) {
ping("ping".toByteArray())
delay(30000)
}
}
}
}
override fun onClose(
code: NanoWSD.WebSocketFrame.CloseCode,
reason: String,
initiatedByRemote: Boolean
) {
cancel()
searchModel.close()
}
override fun onMessage(message: NanoWSD.WebSocketFrame) {
launch(IO) {
kotlin.runCatching {
if (!message.textPayload.isJson()) {
send("数据必须为Json格式")
close(normalClosure, SEARCH_FINISH, false)
return@launch
}
val searchMap =
GSON.fromJsonObject<Map<String, String>>(message.textPayload).getOrNull()
if (searchMap != null) {
val key = searchMap["key"]
if (key.isNullOrBlank()) {
send(appCtx.getString(R.string.cannot_empty))
close(normalClosure, SEARCH_FINISH, false)
return@launch
}
searchModel.search(System.currentTimeMillis(), key)
}
}
}
}
override fun onPong(pong: NanoWSD.WebSocketFrame) {
}
override fun onException(exception: IOException) {
}
override fun getSearchScope(): SearchScope = SearchScope(AppConfig.searchScope)
override fun onSearchStart() {
}
override fun onSearchSuccess(searchBooks: ArrayList<SearchBook>) {
send(GSON.toJson(searchBooks))
}
override fun onSearchFinish(isEmpty: Boolean) = close(normalClosure, SEARCH_FINISH, false)
override fun onSearchCancel(exception: Exception?) = close(normalClosure, exception?.toString() ?: SEARCH_FINISH, false)
}