Skip to content

Commit f012559

Browse files
committed
Linking NativeServicesCoordinator with PermissionsRequestor
1 parent 2a61981 commit f012559

File tree

2 files changed

+6
-3
lines changed

2 files changed

+6
-3
lines changed

IFTTT SDK/ConnectionsSynchronizer.swift

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -106,7 +106,7 @@ final class ConnectionsSynchronizer {
106106
eventPublisher: eventPublisher)
107107

108108
let connectionsMonitor = ConnectionsMonitor(connectionsRegistry: connectionsRegistry)
109-
let nativeServicesCoordinator = NativeServicesCoordinator(locationService: location)
109+
let nativeServicesCoordinator = NativeServicesCoordinator(locationService: location, permissionsRequestor: permissionsRequestor)
110110

111111
self.subscribers = [
112112
connectionsMonitor,
@@ -263,15 +263,18 @@ final class ConnectionsSynchronizer {
263263
/// Handles coordination of native services with a set of connections
264264
private class NativeServicesCoordinator {
265265
private let locationService: LocationService
266+
private let permissionsRequestor: PermissionsRequestor
266267
private let operationQueue: OperationQueue
267268

268-
init(locationService: LocationService) {
269+
init(locationService: LocationService, permissionsRequestor: PermissionsRequestor) {
269270
self.locationService = locationService
271+
self.permissionsRequestor = permissionsRequestor
270272
self.operationQueue = OperationQueue.main
271273
}
272274

273275
func processConnectionUpdate(_ updates: Set<Connection.ConnectionStorage>) {
274276
operationQueue.addOperation {
277+
self.permissionsRequestor.processUpdate(with: updates)
275278
self.locationService.updateRegions(from: updates)
276279
}
277280
}

IFTTT SDK/PermissionsRequestor.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ final class PermissionsRequestor: SynchronizationSubscriber {
2424
self.registry = registry
2525
}
2626

27-
private func processUpdate(with connections: Set<Connection.ConnectionStorage>) {
27+
func processUpdate(with connections: Set<Connection.ConnectionStorage>) {
2828
let operations = connections.reduce(.init()) { (currSet, connections) -> Set<Trigger> in
2929
return currSet.union(connections.allTriggers)
3030
}

0 commit comments

Comments
 (0)