status-im
/
status-desktop
mirror of https://github.com/status-im/status-desktop.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

refactor: remove active mailserver disconnection

This commit is contained in:
Richard Ramos 2022-03-17 17:47:25 -04:00 committed by Iuri Matias
parent 2fa620ad92
commit d7fb0af91d
2 changed files with 2 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/app_service/service/mailservers/service.nim
View File

@ -35,8 +35,7 @@ const requestMoreMessagesTask: Task = proc(argEncoded: string) {.gcsafe, nimcall
info "Requesting additional message history for chat", chatId=arg.chatId
discard status_mailservers.syncChatFromSyncedFrom(arg.chatId)
except Exception as e:
warn "Disconnecting active mailserver due to error", errDescription=e.msg
discard status_mailservers.disconnectActiveMailserver()
warn "Could not request additional messages due to error", errDescription=e.msg
const fillGapsTask: Task = proc(argEncoded: string) {.gcsafe, nimcall.} =
let arg = decode[FillGapsTaskArg](argEncoded)
@ -44,8 +43,7 @@ const fillGapsTask: Task = proc(argEncoded: string) {.gcsafe, nimcall.} =
info "Requesting fill gaps", chatId=arg.chatId, messageIds=arg.messageIds
discard status_mailservers.fillGaps(arg.chatId, arg.messageIds)
except Exception as e:
warn "Disconnecting active mailserver due to error", errDescription=e.msg
discard status_mailservers.disconnectActiveMailserver()
warn "Could not fill gaps due to error", errDescription=e.msg
QtObject:
type Service* = ref object of QObject

5
src/backend/mailservers.nim
View File

@ -29,8 +29,3 @@ proc fillGaps*(chatId: string, messageIds: seq[string]): RpcResponse[JsonNode] {
let payload = %*[chatId, messageIds]
result = core.callPrivateRPC("fillGaps".prefix, payload)
info "fillGaps", topics="mailserver-interaction", rpc_method="wakuext_fillGaps", chatId, messageIds, result
proc disconnectActiveMailserver*(): RpcResponse[JsonNode] {.raises: [Exception].} =
let payload = %* []
result = core.callPrivateRPC("disconnectActiveMailserver".prefix, payload)
info "delete", topics="mailserver-interaction", rpc_method="wakuext_disconnectActiveMailserver", result