Skip to content
Snippets Groups Projects
Commit 0de2eed4 authored by Malte Bauch's avatar Malte Bauch
Browse files

Fix: Application adaption to internal name change of OND to MNE

parent e8213f1c
No related branches found
No related tags found
No related merge requests found
Pipeline #116943 failed
......@@ -6,7 +6,7 @@ import (
"os/signal"
"syscall"
"code.fbi.h-da.de/danet/gosdn/api/go/gosdn/device"
"code.fbi.h-da.de/danet/gosdn/api/go/gosdn/networkelement"
"code.fbi.h-da.de/danet/gosdn/application-framework/event"
"google.golang.org/grpc"
......@@ -61,7 +61,7 @@ func (a *Application) Run(controllerAddress string) {
// DeviceCallback is the callback function for device changes
func (a *Application) DeviceCallback(event *event.Event) {
deviceServer := device.NewDeviceServiceClient(a.grpcClientConn)
deviceServer := networkelement.NewNetworkElementServiceClient(a.grpcClientConn)
changedInterfaces, err := checkIfOperationStateHasChanged(deviceServer, event.EntityID)
if err != nil {
......
......@@ -17,7 +17,7 @@ func main() {
eventServiceDevices, err := event.NewEventService(
queueCredentials,
[]event.Topic{event.Device},
[]event.Topic{event.ManagedNetworkElement},
)
if err != nil {
logrus.Errorf("failed to create event service. %v", err)
......
......@@ -6,7 +6,7 @@ import (
"fmt"
"time"
"code.fbi.h-da.de/danet/gosdn/api/go/gosdn/device"
"code.fbi.h-da.de/danet/gosdn/api/go/gosdn/networkelement"
"code.fbi.h-da.de/danet/gosdn/application-framework/models"
"code.fbi.h-da.de/danet/gosdn/models/generated/arista"
......@@ -62,12 +62,12 @@ type InterfaceStatus struct {
Status string
}
func checkIfOperationStateHasChanged(deviceServer device.DeviceServiceClient, networkElementID uuid.UUID) ([]InterfaceStatus, error) {
func checkIfOperationStateHasChanged(deviceServer networkelement.NetworkElementServiceClient, networkElementID uuid.UUID) ([]InterfaceStatus, error) {
ctx := context.Background()
request := &device.GetDeviceRequest{
Timestamp: time.Now().UnixNano(),
DeviceID: networkElementID.String(),
request := &networkelement.GetNetworkElementRequest{
Timestamp: time.Now().UnixNano(),
NetworkElementId: networkElementID.String(),
}
resp, err := deviceServer.Get(ctx, request)
......@@ -75,7 +75,7 @@ func checkIfOperationStateHasChanged(deviceServer device.DeviceServiceClient, ne
return nil, err
}
networkElement := NewNetworkElement(uuid.MustParse(resp.Device.Id), resp.Device.Name, resp.Device.Model)
networkElement := NewNetworkElement(uuid.MustParse(resp.NetworkElement.Id), resp.NetworkElement.Name, resp.NetworkElement.Model)
storedInterfaces, ok := statusMap[networkElement.Name]
if !ok {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment