Skip to content

Commit 222f109

Browse files
committed
add event details to alreadySubscribedToEvent error
1 parent ba47ba2 commit 222f109

File tree

6 files changed

+7
-7
lines changed

6 files changed

+7
-7
lines changed

Sources/SwiftOCA/OCC/ControlClasses/Root.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -263,7 +263,7 @@ public extension OcaRoot {
263263
) { [weak self] event, data in
264264
await self?.onPropertyEvent(event: event, eventData: data)
265265
}
266-
} catch Ocp1Error.alreadySubscribedToEvent {
266+
} catch Ocp1Error.alreadySubscribedToEvent(_) {
267267
} catch Ocp1Error.status(.invalidRequest) {
268268
// FIXME: in our device implementation not all properties can be subcribed to
269269
}

Sources/SwiftOCA/OCF/Errors.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ public enum Ocp1Error: Error, Equatable {
1919
case status(OcaStatus)
2020
case exception(Ocp1Notification2ExceptionData)
2121
case alreadyConnected
22-
case alreadySubscribedToEvent
22+
case alreadySubscribedToEvent(OcaEvent)
2323
case arrayOrDataTooBig
2424
case bonjourRegistrationFailed
2525
case connectionAlreadyInProgress

Sources/SwiftOCA/OCP.1/Ocp1Connection+Subscribe.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,7 @@ public extension Ocp1Connection {
8686
if let eventSubscriptions = subscriptions[event] {
8787
precondition(!eventSubscriptions.subscriptions.isEmpty)
8888
if eventSubscriptions.subscriptions.contains(cancellable) {
89-
throw Ocp1Error.alreadySubscribedToEvent
89+
throw Ocp1Error.alreadySubscribedToEvent(event)
9090
}
9191
eventSubscriptions.subscriptions.insert(cancellable)
9292
} else {

Sources/SwiftOCADevice/OCA/ControllerDefaultSubscribing.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ public extension OcaControllerDefaultSubscribing {
9191
_ subscription: OcaSubscriptionManagerSubscription
9292
) async throws {
9393
guard !hasSubscription(subscription) else {
94-
throw Ocp1Error.alreadySubscribedToEvent
94+
throw Ocp1Error.alreadySubscribedToEvent(subscription.event)
9595
}
9696
guard self is OcaControllerLightweightNotifying ||
9797
subscription.notificationDeliveryMode == .normal

Sources/SwiftOCADevice/OCC/ControlClasses/Agents/Grouper.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -756,7 +756,7 @@ private extension OcaGrouper.Enrollment {
756756
try await _forward(event: event, eventData: eventData, grouper: grouper)
757757
}
758758
)
759-
} catch Ocp1Error.alreadySubscribedToEvent {
759+
} catch Ocp1Error.alreadySubscribedToEvent(_) {
760760
} catch Ocp1Error.status(.invalidRequest) {}
761761
}
762762

Sources/SwiftOCADevice/OCC/ControlClasses/Managers/SubscriptionManager.swift

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -145,7 +145,7 @@ public class OcaSubscriptionManager: OcaManager {
145145
)
146146
try await controller.addSubscription(.subscription2(subscription2))
147147
returnedStatus = .ok
148-
} catch Ocp1Error.alreadySubscribedToEvent {
148+
} catch Ocp1Error.alreadySubscribedToEvent(_) {
149149
returnedStatus = .invalidRequest
150150
} catch let Ocp1Error.status(status) {
151151
returnedStatus = status
@@ -200,7 +200,7 @@ public class OcaSubscriptionManager: OcaManager {
200200
try await controller
201201
.addSubscription(.propertyChangeSubscription2(propertyChangeSubscription2))
202202
returnedStatus = .ok
203-
} catch Ocp1Error.alreadySubscribedToEvent {
203+
} catch Ocp1Error.alreadySubscribedToEvent(_) {
204204
returnedStatus = .invalidRequest
205205
} catch let Ocp1Error.status(status) {
206206
returnedStatus = status

0 commit comments

Comments
 (0)