SEBA-749 Added on demand api code for omci test action
Change-Id: I1a52dc5ec78ac61001e434c8c98f0400e034dc50
diff --git a/rw_core/core/adapter_proxy.go b/rw_core/core/adapter_proxy.go
index e3c362e..d0a2e3f 100755
--- a/rw_core/core/adapter_proxy.go
+++ b/rw_core/core/adapter_proxy.go
@@ -342,3 +342,14 @@
replyToTopic := ap.getCoreTopic()
return ap.sendRPC(ctx, rpc, &toTopic, &replyToTopic, true, pDeviceID, args...)
}
+
+func (ap *AdapterProxy) startOmciTest(ctx context.Context, device *voltha.Device, omcitestrequest *voltha.OmciTestRequest) (chan *kafka.RpcResponse, error) {
+ log.Debugw("Omci_test_Request_adapter_proxy", log.Fields{"device": device, "omciTestRequest": omcitestrequest})
+ rpc := "start_omci_test"
+ toTopic := ap.getAdapterTopic(device.Adapter)
+ // Use a device specific topic as we are the only core handling requests for this device
+ replyToTopic := ap.getCoreTopic()
+ return ap.sendRPC(ctx, rpc, &toTopic, &replyToTopic, true, device.Id,
+ &kafka.KVArg{Key: "device", Value: device},
+ &kafka.KVArg{Key: "omcitestrequest", Value: omcitestrequest})
+}