Когда я имею дело с чем-то вроде аналитики, у меня обычно есть объект, который прослушивает Notification
s или вызывает методы объекта в бизнес-логике. Это всегда беспокоило меня, но я не смог найти лучшего шаблона. Например, в приведенном ниже коде аналитика разбросана повсюду и загромождает бизнес-логику.
class SomeService {
private let analytics: AnalyticsGateway
func doAllTheThings() {
analytics.trackStart(with: context)
somethingApiClient.doSomething { error
guard error = nil else {
analytics.trackError(error)
analytics.trackFailure("doSomething", with: context)
}
analytics.trackSuccess("doSomething", with: context)
}
do {
try someOtherApiClient.doSomethingElse { [unowned self] mappedObject
guard let mappedObject = mappedObject else {
analytics.trackFailure("doSomethingElse", with: context)
return
}
guard validator.validate(mappedObject) else {
analytics.trackFailure("doSomethingElse", with: context)
return
}
self.notificationCenter.post(name: SomethingElseDidUpdateNotification,
object: self,
userInfo: info)
}
} catch {
analytics.trackError(error)
analytics.trackFailure("doSomethingElse", with: context)
}
}
}
Что является лучшим подходом к решению такого рода проблемы? Мне нравится подход к прослушиванию уведомлений/событий, если они существуют для обновления состояния во всем приложении. Однако добавление уведомлений только для аналитики кажется почти таким же плохим, как прямой вызов объекта аналитики (хотя все же лучше, поскольку нет связи). В вашей бизнес-логике все еще есть код, специфичный для аналитики.
В прошлом я немного занимался аспектно-ориентированным программированием на Java, и, похоже, это решает некоторые из этих проблем. Есть ли способ сделать что-то подобное в быстром? Я нашел пару библиотек AOP для Objective-C, но ни одна из них не поддерживается.
В моем текущем проекте используется RxSwift, и я могу кое-что сделать с событиями (onNext
, onError
и т. д.)... когда я использую Observable
s. Однако я бы предпочел лучший шаблон, который можно использовать везде. Пример:
class SomeService {
func doSomethingElse() -> Observable<SomeObject> {
return Observable.create { observer in
someOtherApiClient.doSomethingElse { mappedObject
guard let mappedObject = mappedObject else {
throw ServiceError.mappedObjectIsNil
}
guard validator.validate(mappedObject) else {
throw ServiceError.validationFailed(mappedObject)
}
observer.onNext(mappedObject)
observer.onCompleted()
}
}
.instrument(for: "doSomethingElse", in: observable)
}
}
extension Observable where E == Mappable {
func instrument(for name: String, in observable: Observable<E>) -> Observable<E> {
return observable.do(onError: { (error) in
analytics.trackError(error)
analytics.trackFailure(name, with: context)
}, onCompleted: {
analytics.trackSuccess(name, with: context)
}, onSubscribed: {
analytics.trackStart(name, with: context)
})
}
}