45 lines
1.6 KiB
Swift
45 lines
1.6 KiB
Swift
|
import Combine
|
||
|
|
|
||
|
|
final class AccountsMiddleware {
|
||
|
|
static let shared = AccountsMiddleware()
|
||
|
|
|
||
|
|
func middleware(state: AppState, action: AppAction) -> AnyPublisher<AppAction, Never> {
|
||
|
|
switch action {
|
||
|
|
case .databaseAction(.storedAccountsLoaded(let accounts)):
|
||
|
|
return Just(.accountsAction(.accountsListUpdated(accounts: accounts)))
|
||
|
|
.eraseToAnyPublisher()
|
||
|
|
|
||
|
|
case .xmppAction(.clientConnectionChanged(let jid, let connectionStatus)):
|
||
|
|
return Future<AppAction, Never> { promise in
|
||
|
|
guard let account = state.accountsState.accounts.first(where: { $0.bareJid == jid }) else {
|
||
|
|
promise(.success(.empty))
|
||
|
|
return
|
||
|
|
}
|
||
|
|
if account.isTemp {
|
||
|
|
switch connectionStatus {
|
||
|
|
case .connected:
|
||
|
|
promise(.success(.accountsAction(.makeAccountPermanent(account: account))))
|
||
|
|
|
||
|
|
case .disconnected(let reason):
|
||
|
|
if reason != "No error!" {
|
||
|
|
promise(.success(.accountsAction(.addAccountError(jid: jid, reason: reason))))
|
||
|
|
} else {
|
||
|
|
promise(.success(.empty))
|
||
|
|
}
|
||
|
|
|
||
|
|
default:
|
||
|
|
promise(.success(.empty))
|
||
|
|
}
|
||
|
|
|
||
|
|
} else {
|
||
|
|
promise(.success(.empty))
|
||
|
|
}
|
||
|
|
}
|
||
|
|
.eraseToAnyPublisher()
|
||
|
|
|
||
|
|
default:
|
||
|
|
return Empty().eraseToAnyPublisher()
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|