SEBA-749 Added on demand api code for omci test action
Change-Id: I1a52dc5ec78ac61001e434c8c98f0400e034dc50
diff --git a/rw_core/core/device_manager.go b/rw_core/core/device_manager.go
index 0d77429..0f68432 100755
--- a/rw_core/core/device_manager.go
+++ b/rw_core/core/device_manager.go
@@ -1534,3 +1534,16 @@
}
return status.Errorf(codes.NotFound, "%s", curr.Id)
}
+
+func (dMgr *DeviceManager) startOmciTest(ctx context.Context, omcitestrequest *voltha.OmciTestRequest) (*voltha.TestResponse, error) {
+ log.Debugw("Omci_test_Request", log.Fields{"device-id": omcitestrequest.Id, "uuid": omcitestrequest.Uuid})
+ if agent := dMgr.getDeviceAgent(ctx, omcitestrequest.Id); agent != nil {
+ res, err := agent.startOmciTest(ctx, omcitestrequest)
+ if err != nil {
+ return nil, err
+ }
+ log.Debugw("Omci_test_Response_result-device-magnager", log.Fields{"result": res})
+ return res, nil
+ }
+ return nil, status.Errorf(codes.NotFound, "%s", omcitestrequest.Id)
+}