Newer
Older
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
import AppCore
import ComposableArchitecture
import Foundation
import XCTestDynamicOverlay
import XXClient
import XXMessengerClient
import XXModels
public struct ConfirmRequestState: Equatable {
public enum Result: Equatable {
case success
case failure(String)
}
public init(
contact: XXClient.Contact,
isConfirming: Bool = false,
result: Result? = nil
) {
self.contact = contact
self.isConfirming = isConfirming
self.result = result
}
public var contact: XXClient.Contact
public var isConfirming: Bool
public var result: Result?
}
public enum ConfirmRequestAction: Equatable {
case confirmTapped
case didConfirm(ConfirmRequestState.Result)
}
public struct ConfirmRequestEnvironment {
public init(
messenger: Messenger,
db: DBManagerGetDB,
mainQueue: AnySchedulerOf<DispatchQueue>,
bgQueue: AnySchedulerOf<DispatchQueue>
) {
self.messenger = messenger
self.db = db
self.mainQueue = mainQueue
self.bgQueue = bgQueue
}
public var messenger: Messenger
public var db: DBManagerGetDB
public var mainQueue: AnySchedulerOf<DispatchQueue>
public var bgQueue: AnySchedulerOf<DispatchQueue>
}
#if DEBUG
extension ConfirmRequestEnvironment {
public static let unimplemented = ConfirmRequestEnvironment(
messenger: .unimplemented,
db: .unimplemented,
mainQueue: .unimplemented,
bgQueue: .unimplemented
)
}
#endif
public let confirmRequestReducer = Reducer<ConfirmRequestState, ConfirmRequestAction, ConfirmRequestEnvironment>
{ state, action, env in
switch action {
case .confirmTapped:
state.isConfirming = true
state.result = nil
return Effect.result { [state] in
do {
let e2e = try env.messenger.e2e.tryGet()
_ = try e2e.confirmReceivedRequest(partner: state.contact)
let contactId = try state.contact.getId()
try env.db().bulkUpdateContacts.callAsFunction(
.init(id: [contactId]),
.init(authStatus: .friend)
)
return .success(.didConfirm(.success))
} catch {
return .success(.didConfirm(.failure(error.localizedDescription)))
}
}
.subscribe(on: env.bgQueue)
.receive(on: env.mainQueue)
.eraseToEffect()
case .didConfirm(let result):
state.isConfirming = false
state.result = result
return .none
}
}