Skip to content

Commit

Permalink
fix regression adding subscriptions
Browse files Browse the repository at this point in the history
confusingly named argument labels should be fixed: parameters where we need to
use reflection to determine parameter count from field count, paramter where
there is a single parameter
  • Loading branch information
lhoward committed Jul 9, 2023
1 parent b82eab4 commit 80ded32
Show file tree
Hide file tree
Showing 4 changed files with 13 additions and 13 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ public class OcaSubscriptionManager: OcaManager {
notificationDeliveryMode: notificationDeliveryMode,
destinationInformation: destinationInformation
)
try await sendCommandRrq(methodID: OcaMethodID("3.1"), parameter: params)
try await sendCommandRrq(methodID: OcaMethodID("3.1"), parameters: params)
}

func removeSubscription(event: OcaEvent, subscriber: OcaMethod) async throws {
Expand All @@ -64,7 +64,7 @@ public class OcaSubscriptionManager: OcaManager {
}

let params = RemoveSubscriptionParameters(event: event, subscriber: subscriber)
try await sendCommandRrq(methodID: OcaMethodID("3.2"), parameter: params)
try await sendCommandRrq(methodID: OcaMethodID("3.2"), parameters: params)
}

func disableNotifications() async throws {
Expand Down Expand Up @@ -100,7 +100,7 @@ public class OcaSubscriptionManager: OcaManager {
notificationDeliveryMode: notificationDeliveryMode,
destinationInformation: destinationInformation
)
try await sendCommandRrq(methodID: OcaMethodID("3.5"), parameter: params)
try await sendCommandRrq(methodID: OcaMethodID("3.5"), parameters: params)
}

func removePropertyChangeSubscription(
Expand All @@ -119,7 +119,7 @@ public class OcaSubscriptionManager: OcaManager {
property: property,
subscriber: subscriber
)
try await sendCommandRrq(methodID: OcaMethodID("3.6"), parameter: params)
try await sendCommandRrq(methodID: OcaMethodID("3.6"), parameters: params)
}

func getMaximumSubscriberContextLength() async throws -> OcaUint16 {
Expand Down
6 changes: 3 additions & 3 deletions Sources/SwiftOCA/OCC/ControlClasses/Root+Commands.swift
Original file line number Diff line number Diff line change
Expand Up @@ -269,17 +269,17 @@ extension OcaRoot {

func sendCommandRrq<T: Encodable, U: Decodable>(
methodID: OcaMethodID,
parameter: T
parameters: T
) async throws -> U {
var responseParameterData = Data()

try await sendCommandRrq(
methodID: methodID,
parameterCount: OcaUint8(
Mirror(reflecting: parameter).children
Mirror(reflecting: parameters).children
.count
),
parameters: [parameter],
parameters: [parameters],
responseParameterCount: responseParameterCount(U.self),
responseParameters: &responseParameterData
)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -76,14 +76,14 @@ public class OcaBlock: OcaWorker {
func constructMember(factory factoryONo: OcaONo) async throws -> OcaONo {
try await sendCommandRrq(
methodID: OcaMethodID("3.3"),
parameter: factoryONo
parameters: factoryONo
)
}

func delete(member objectNumber: OcaONo) async throws {
try await sendCommandRrq(
methodID: OcaMethodID("3.4"),
parameter: objectNumber
parameters: objectNumber
)
}

Expand All @@ -94,7 +94,7 @@ public class OcaBlock: OcaWorker {
func add(signalPath path: OcaSignalPath) async throws -> OcaUint16 {
try await sendCommandRrq(
methodID: OcaMethodID("3.7"),
parameter: path
parameters: path
)
}

Expand Down Expand Up @@ -147,7 +147,7 @@ public class OcaBlock: OcaWorker {
resultFlags: resultFlags
)

return try await sendCommandRrq(methodID: OcaMethodID("3.17"), parameter: params)
return try await sendCommandRrq(methodID: OcaMethodID("3.17"), parameters: params)
}

func findRecursive(
Expand All @@ -163,7 +163,7 @@ public class OcaBlock: OcaWorker {
resultFlags: resultFlags
)

return try await sendCommandRrq(methodID: OcaMethodID("3.18"), parameter: params)
return try await sendCommandRrq(methodID: OcaMethodID("3.18"), parameters: params)
}

// 3.19
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ public class OcaMatrix: OcaWorker {

func get(x: OcaMatrixCoordinate, y: OcaMatrixCoordinate) async throws -> OcaONo {
let xy = OcaVector2D(x: x, y: y)
return try await sendCommandRrq(methodID: OcaMethodID("3.7"), parameter: xy)
return try await sendCommandRrq(methodID: OcaMethodID("3.7"), parameters: xy)
}

func set(x: OcaMatrixCoordinate, y: OcaMatrixCoordinate, memberONo: OcaONo) async throws {
Expand Down

0 comments on commit 80ded32

Please sign in to comment.