Update mock generation and add new mocks

controller/Makefile

@@ -66,4 +66,4 @@ integration-test-api:
 	go test -race -v -run TestApiIntegration
 
 generate-mocks: install-tools
-	./$(TOOLS_DIR)/mockery --all --dir "./interfaces/"
+	./$(TOOLS_DIR)/mockery --all --dir "./nucleus/domain/"

controller/mocks/EventService.go

+// Code generated by mockery v2.20.0. DO NOT EDIT.
+
+package mocks
+
+import (
+	event "code.fbi.h-da.de/danet/gosdn/controller/event"
+	mock "github.com/stretchr/testify/mock"
+)
+
+// EventService is an autogenerated mock type for the EventService type
+type EventService struct {
+	mock.Mock
+}
+
+// CloseConnection provides a mock function with given fields:
+func (_m *EventService) CloseConnection() {
+	_m.Called()
+}
+
+// PublishEvent provides a mock function with given fields: topic, _a1
+func (_m *EventService) PublishEvent(topic string, _a1 event.Event) error {
+	ret := _m.Called(topic, _a1)
+
+	var r0 error
+	if rf, ok := ret.Get(0).(func(string, event.Event) error); ok {
+		r0 = rf(topic, _a1)
+	} else {
+		r0 = ret.Error(0)
+	}
+
+	return r0
+}
+
+// Reconnect provides a mock function with given fields:
+func (_m *EventService) Reconnect() {
+	_m.Called()
+}
+
+// RetryPublish provides a mock function with given fields: topic, _a1
+func (_m *EventService) RetryPublish(topic string, _a1 event.Event) error {
+	ret := _m.Called(topic, _a1)
+
+	var r0 error
+	if rf, ok := ret.Get(0).(func(string, event.Event) error); ok {
+		r0 = rf(topic, _a1)
+	} else {
+		r0 = ret.Error(0)
+	}
+
+	return r0
+}
+
+type mockConstructorTestingTNewEventService interface {
+	mock.TestingT
+	Cleanup(func())
+}
+
+// NewEventService creates a new instance of EventService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
+func NewEventService(t mockConstructorTestingTNewEventService) *EventService {
+	mock := &EventService{}
+	mock.Mock.Test(t)
+
+	t.Cleanup(func() { mock.AssertExpectations(t) })
+
+	return mock
+}

controller/mocks/HandleSubscribeResponse.go

@@ -6,7 +6,7 @@ import (
 	gnmi "github.com/openconfig/gnmi/proto/gnmi"
 	mock "github.com/stretchr/testify/mock"
 
-	transport "code.fbi.h-da.de/danet/gosdn/controller/interfaces/transport"
+	model "code.fbi.h-da.de/danet/gosdn/controller/nucleus/domain/model"
 )
 
 // HandleSubscribeResponse is an autogenerated mock type for the HandleSubscribeResponse type
@@ -15,7 +15,7 @@ type HandleSubscribeResponse struct {
 }
 
 // Execute provides a mock function with given fields: _a0, _a1
-func (_m *HandleSubscribeResponse) Execute(_a0 *gnmi.SubscribeResponse, _a1 *transport.SubscriptionInformation) {
+func (_m *HandleSubscribeResponse) Execute(_a0 *gnmi.SubscribeResponse, _a1 *model.SubscriptionInformation) {
 	_m.Called(_a0, _a1)
 }
 

controller/mocks/NetworkElement.go

@@ -6,12 +6,10 @@ import (
 	conflict "code.fbi.h-da.de/danet/gosdn/controller/conflict"
 	mock "github.com/stretchr/testify/mock"
 
-	plugin "code.fbi.h-da.de/danet/gosdn/controller/interfaces/plugin"
+	model "code.fbi.h-da.de/danet/gosdn/controller/nucleus/domain/model"
 
 	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
 
-	transport "code.fbi.h-da.de/danet/gosdn/controller/interfaces/transport"
-
 	uuid "github.com/google/uuid"
 )
 
@@ -111,15 +109,15 @@ func (_m *NetworkElement) GetModelAsString() (string, error) {
 }
 
 // GetPlugin provides a mock function with given fields:
-func (_m *NetworkElement) GetPlugin() plugin.Plugin {
+func (_m *NetworkElement) GetPlugin() model.PluginIface {
 	ret := _m.Called()
 
-	var r0 plugin.Plugin
-	if rf, ok := ret.Get(0).(func() plugin.Plugin); ok {
+	var r0 model.PluginIface
+	if rf, ok := ret.Get(0).(func() model.PluginIface); ok {
 		r0 = rf()
 	} else {
 		if ret.Get(0) != nil {
-			r0 = ret.Get(0).(plugin.Plugin)
+			r0 = ret.Get(0).(model.PluginIface)
 		}
 	}
 
@@ -201,15 +199,15 @@ func (_m *NetworkElement) ProcessResponse(_a0 protoreflect.ProtoMessage) error {
 }
 
 // Transport provides a mock function with given fields:
-func (_m *NetworkElement) Transport() transport.Transport {
+func (_m *NetworkElement) Transport() model.Transport {
 	ret := _m.Called()
 
-	var r0 transport.Transport
-	if rf, ok := ret.Get(0).(func() transport.Transport); ok {
+	var r0 model.Transport
+	if rf, ok := ret.Get(0).(func() model.Transport); ok {
 		r0 = rf()
 	} else {
 		if ret.Get(0) != nil {
-			r0 = ret.Get(0).(transport.Transport)
+			r0 = ret.Get(0).(model.Transport)
 		}
 	}
 

controller/mocks/NetworkElementService.go

+// Code generated by mockery v2.20.0. DO NOT EDIT.
+
+package mocks
+
+import (
+	model "code.fbi.h-da.de/danet/gosdn/controller/nucleus/domain/model"
+	mock "github.com/stretchr/testify/mock"
+
+	uuid "github.com/google/uuid"
+)
+
+// NetworkElementService is an autogenerated mock type for the NetworkElementService type
+type NetworkElementService struct {
+	mock.Mock
+}
+
+// Add provides a mock function with given fields: _a0
+func (_m *NetworkElementService) Add(_a0 model.NetworkElement) error {
+	ret := _m.Called(_a0)
+
+	var r0 error
+	if rf, ok := ret.Get(0).(func(model.NetworkElement) error); ok {
+		r0 = rf(_a0)
+	} else {
+		r0 = ret.Error(0)
+	}
+
+	return r0
+}
+
+// Delete provides a mock function with given fields: _a0
+func (_m *NetworkElementService) Delete(_a0 model.NetworkElement) error {
+	ret := _m.Called(_a0)
+
+	var r0 error
+	if rf, ok := ret.Get(0).(func(model.NetworkElement) error); ok {
+		r0 = rf(_a0)
+	} else {
+		r0 = ret.Error(0)
+	}
+
+	return r0
+}
+
+// Get provides a mock function with given fields: _a0
+func (_m *NetworkElementService) Get(_a0 model.Query) (model.NetworkElement, error) {
+	ret := _m.Called(_a0)
+
+	var r0 model.NetworkElement
+	var r1 error
+	if rf, ok := ret.Get(0).(func(model.Query) (model.NetworkElement, error)); ok {
+		return rf(_a0)
+	}
+	if rf, ok := ret.Get(0).(func(model.Query) model.NetworkElement); ok {
+		r0 = rf(_a0)
+	} else {
+		if ret.Get(0) != nil {
+			r0 = ret.Get(0).(model.NetworkElement)
+		}
+	}
+
+	if rf, ok := ret.Get(1).(func(model.Query) error); ok {
+		r1 = rf(_a0)
+	} else {
+		r1 = ret.Error(1)
+	}
+
+	return r0, r1
+}
+
+// GetAll provides a mock function with given fields:
+func (_m *NetworkElementService) GetAll() ([]model.NetworkElement, error) {
+	ret := _m.Called()
+
+	var r0 []model.NetworkElement
+	var r1 error
+	if rf, ok := ret.Get(0).(func() ([]model.NetworkElement, error)); ok {
+		return rf()
+	}
+	if rf, ok := ret.Get(0).(func() []model.NetworkElement); ok {
+		r0 = rf()
+	} else {
+		if ret.Get(0) != nil {
+			r0 = ret.Get(0).([]model.NetworkElement)
+		}
+	}
+
+	if rf, ok := ret.Get(1).(func() error); ok {
+		r1 = rf()
+	} else {
+		r1 = ret.Error(1)
+	}
+
+	return r0, r1
+}
+
+// GetAllAsLoaded provides a mock function with given fields:
+func (_m *NetworkElementService) GetAllAsLoaded() ([]model.LoadedNetworkElement, error) {
+	ret := _m.Called()
+
+	var r0 []model.LoadedNetworkElement
+	var r1 error
+	if rf, ok := ret.Get(0).(func() ([]model.LoadedNetworkElement, error)); ok {
+		return rf()
+	}
+	if rf, ok := ret.Get(0).(func() []model.LoadedNetworkElement); ok {
+		r0 = rf()
+	} else {
+		if ret.Get(0) != nil {
+			r0 = ret.Get(0).([]model.LoadedNetworkElement)
+		}
+	}
+
+	if rf, ok := ret.Get(1).(func() error); ok {
+		r1 = rf()
+	} else {
+		r1 = ret.Error(1)
+	}
+
+	return r0, r1
+}
+
+// Update provides a mock function with given fields: _a0
+func (_m *NetworkElementService) Update(_a0 model.NetworkElement) error {
+	ret := _m.Called(_a0)
+
+	var r0 error
+	if rf, ok := ret.Get(0).(func(model.NetworkElement) error); ok {
+		r0 = rf(_a0)
+	} else {
+		r0 = ret.Error(0)
+	}
+
+	return r0
+}
+
+// UpdateModel provides a mock function with given fields: _a0, _a1
+func (_m *NetworkElementService) UpdateModel(_a0 uuid.UUID, _a1 string) error {
+	ret := _m.Called(_a0, _a1)
+
+	var r0 error
+	if rf, ok := ret.Get(0).(func(uuid.UUID, string) error); ok {
+		r0 = rf(_a0, _a1)
+	} else {
+		r0 = ret.Error(0)
+	}
+
+	return r0
+}
+
+type mockConstructorTestingTNewNetworkElementService interface {
+	mock.TestingT
+	Cleanup(func())
+}
+
+// NewNetworkElementService creates a new instance of NetworkElementService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
+func NewNetworkElementService(t mockConstructorTestingTNewNetworkElementService) *NetworkElementService {
+	mock := &NetworkElementService{}
+	mock.Mock.Test(t)
+
+	t.Cleanup(func() { mock.AssertExpectations(t) })
+
+	return mock
+}

controller/mocks/NetworkElementStore.go

+// Code generated by mockery v2.20.0. DO NOT EDIT.
+
+package mocks
+
+import (
+	model "code.fbi.h-da.de/danet/gosdn/controller/nucleus/domain/model"
+	mock "github.com/stretchr/testify/mock"
+)
+
+// NetworkElementStore is an autogenerated mock type for the NetworkElementStore type
+type NetworkElementStore struct {
+	mock.Mock
+}
+
+// Add provides a mock function with given fields: _a0
+func (_m *NetworkElementStore) Add(_a0 model.NetworkElement) error {
+	ret := _m.Called(_a0)
+
+	var r0 error
+	if rf, ok := ret.Get(0).(func(model.NetworkElement) error); ok {
+		r0 = rf(_a0)
+	} else {
+		r0 = ret.Error(0)
+	}
+
+	return r0
+}
+
+// Delete provides a mock function with given fields: _a0
+func (_m *NetworkElementStore) Delete(_a0 model.NetworkElement) error {
+	ret := _m.Called(_a0)
+
+	var r0 error
+	if rf, ok := ret.Get(0).(func(model.NetworkElement) error); ok {
+		r0 = rf(_a0)
+	} else {
+		r0 = ret.Error(0)
+	}
+
+	return r0
+}
+
+// Get provides a mock function with given fields: _a0
+func (_m *NetworkElementStore) Get(_a0 model.Query) (model.LoadedNetworkElement, error) {
+	ret := _m.Called(_a0)
+
+	var r0 model.LoadedNetworkElement
+	var r1 error
+	if rf, ok := ret.Get(0).(func(model.Query) (model.LoadedNetworkElement, error)); ok {
+		return rf(_a0)
+	}
+	if rf, ok := ret.Get(0).(func(model.Query) model.LoadedNetworkElement); ok {
+		r0 = rf(_a0)
+	} else {
+		r0 = ret.Get(0).(model.LoadedNetworkElement)
+	}
+
+	if rf, ok := ret.Get(1).(func(model.Query) error); ok {
+		r1 = rf(_a0)
+	} else {
+		r1 = ret.Error(1)
+	}
+
+	return r0, r1
+}
+
+// GetAll provides a mock function with given fields:
+func (_m *NetworkElementStore) GetAll() ([]model.LoadedNetworkElement, error) {
+	ret := _m.Called()
+
+	var r0 []model.LoadedNetworkElement
+	var r1 error
+	if rf, ok := ret.Get(0).(func() ([]model.LoadedNetworkElement, error)); ok {
+		return rf()
+	}
+	if rf, ok := ret.Get(0).(func() []model.LoadedNetworkElement); ok {
+		r0 = rf()
+	} else {
+		if ret.Get(0) != nil {
+			r0 = ret.Get(0).([]model.LoadedNetworkElement)
+		}
+	}
+
+	if rf, ok := ret.Get(1).(func() error); ok {
+		r1 = rf()
+	} else {
+		r1 = ret.Error(1)
+	}
+
+	return r0, r1
+}
+
+// Update provides a mock function with given fields: _a0
+func (_m *NetworkElementStore) Update(_a0 model.NetworkElement) error {
+	ret := _m.Called(_a0)
+
+	var r0 error
+	if rf, ok := ret.Get(0).(func(model.NetworkElement) error); ok {
+		r0 = rf(_a0)
+	} else {
+		r0 = ret.Error(0)
+	}
+
+	return r0
+}
+
+type mockConstructorTestingTNewNetworkElementStore interface {
+	mock.TestingT
+	Cleanup(func())
+}
+
+// NewNetworkElementStore creates a new instance of NetworkElementStore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
+func NewNetworkElementStore(t mockConstructorTestingTNewNetworkElementStore) *NetworkElementStore {
+	mock := &NetworkElementStore{}
+	mock.Mock.Test(t)
+
+	t.Cleanup(func() { mock.AssertExpectations(t) })
+
+	return mock
+}

controller/mocks/Plugin.go → controller/mocks/PluginIface.go

@@ -3,30 +3,30 @@
 package mocks
 
 import (
-	go_plugin "github.com/hashicorp/go-plugin"
 	gnmi "github.com/openconfig/gnmi/proto/gnmi"
-
 	mock "github.com/stretchr/testify/mock"
 
+	model "code.fbi.h-da.de/danet/gosdn/controller/nucleus/domain/model"
+
 	networkelement "code.fbi.h-da.de/danet/gosdn/api/go/gosdn/networkelement"
 
-	plugin "code.fbi.h-da.de/danet/gosdn/controller/interfaces/plugin"
+	plugin "github.com/hashicorp/go-plugin"
 
 	uuid "github.com/google/uuid"
 )
 
-// Plugin is an autogenerated mock type for the Plugin type
-type Plugin struct {
+// PluginIface is an autogenerated mock type for the PluginIface type
+type PluginIface struct {
 	mock.Mock
 }
 
 // Close provides a mock function with given fields:
-func (_m *Plugin) Close() {
+func (_m *PluginIface) Close() {
 	_m.Called()
 }
 
 // DeleteNode provides a mock function with given fields: path
-func (_m *Plugin) DeleteNode(path *gnmi.Path) error {
+func (_m *PluginIface) DeleteNode(path *gnmi.Path) error {
 	ret := _m.Called(path)
 
 	var r0 error
@@ -40,7 +40,7 @@ func (_m *Plugin) DeleteNode(path *gnmi.Path) error {
 }
 
 // Diff provides a mock function with given fields: original, modified
-func (_m *Plugin) Diff(original []byte, modified []byte) (*gnmi.Notification, error) {
+func (_m *PluginIface) Diff(original []byte, modified []byte) (*gnmi.Notification, error) {
 	ret := _m.Called(original, modified)
 
 	var r0 *gnmi.Notification
@@ -66,7 +66,7 @@ func (_m *Plugin) Diff(original []byte, modified []byte) (*gnmi.Notification, er
 }
 
 // ExecPath provides a mock function with given fields:
-func (_m *Plugin) ExecPath() string {
+func (_m *PluginIface) ExecPath() string {
 	ret := _m.Called()
 
 	var r0 string
@@ -80,15 +80,15 @@ func (_m *Plugin) ExecPath() string {
 }
 
 // GetClient provides a mock function with given fields:
-func (_m *Plugin) GetClient() *go_plugin.Client {
+func (_m *PluginIface) GetClient() *plugin.Client {
 	ret := _m.Called()
 
-	var r0 *go_plugin.Client
-	if rf, ok := ret.Get(0).(func() *go_plugin.Client); ok {
+	var r0 *plugin.Client
+	if rf, ok := ret.Get(0).(func() *plugin.Client); ok {
 		r0 = rf()
 	} else {
 		if ret.Get(0) != nil {
-			r0 = ret.Get(0).(*go_plugin.Client)
+			r0 = ret.Get(0).(*plugin.Client)
 		}
 	}
 
@@ -96,7 +96,7 @@ func (_m *Plugin) GetClient() *go_plugin.Client {
 }
 
 // GetNode provides a mock function with given fields: path, requestForIntendedState
-func (_m *Plugin) GetNode(path *gnmi.Path, requestForIntendedState bool) ([]*gnmi.Notification, error) {
+func (_m *PluginIface) GetNode(path *gnmi.Path, requestForIntendedState bool) ([]*gnmi.Notification, error) {
 	ret := _m.Called(path, requestForIntendedState)
 
 	var r0 []*gnmi.Notification
@@ -122,7 +122,7 @@ func (_m *Plugin) GetNode(path *gnmi.Path, requestForIntendedState bool) ([]*gnm
 }
 
 // ID provides a mock function with given fields:
-func (_m *Plugin) ID() uuid.UUID {
+func (_m *PluginIface) ID() uuid.UUID {
 	ret := _m.Called()
 
 	var r0 uuid.UUID
@@ -138,15 +138,15 @@ func (_m *Plugin) ID() uuid.UUID {
 }
 
 // Manifest provides a mock function with given fields:
-func (_m *Plugin) Manifest() *plugin.Manifest {
+func (_m *PluginIface) Manifest() *model.Manifest {
 	ret := _m.Called()
 
-	var r0 *plugin.Manifest
-	if rf, ok := ret.Get(0).(func() *plugin.Manifest); ok {
+	var r0 *model.Manifest
+	if rf, ok := ret.Get(0).(func() *model.Manifest); ok {
 		r0 = rf()
 	} else {
 		if ret.Get(0) != nil {
-			r0 = ret.Get(0).(*plugin.Manifest)
+			r0 = ret.Get(0).(*model.Manifest)
 		}
 	}
 
@@ -154,7 +154,7 @@ func (_m *Plugin) Manifest() *plugin.Manifest {
 }
 
 // Model provides a mock function with given fields: filterReadOnly
-func (_m *Plugin) Model(filterReadOnly bool) ([]byte, error) {
+func (_m *PluginIface) Model(filterReadOnly bool) ([]byte, error) {
 	ret := _m.Called(filterReadOnly)
 
 	var r0 []byte
@@ -180,7 +180,7 @@ func (_m *Plugin) Model(filterReadOnly bool) ([]byte, error) {
 }
 
 // Ping provides a mock function with given fields:
-func (_m *Plugin) Ping() error {
+func (_m *PluginIface) Ping() error {
 	ret := _m.Called()
 
 	var r0 error
@@ -194,7 +194,7 @@ func (_m *Plugin) Ping() error {
 }
 
 // PruneConfigFalse provides a mock function with given fields: value
-func (_m *Plugin) PruneConfigFalse(value []byte) ([]byte, error) {
+func (_m *PluginIface) PruneConfigFalse(value []byte) ([]byte, error) {
 	ret := _m.Called(value)
 
 	var r0 []byte
@@ -220,7 +220,7 @@ func (_m *Plugin) PruneConfigFalse(value []byte) ([]byte, error) {
 }
 
 // Restart provides a mock function with given fields:
-func (_m *Plugin) Restart() error {
+func (_m *PluginIface) Restart() error {
 	ret := _m.Called()
 
 	var r0 error
@@ -234,7 +234,7 @@ func (_m *Plugin) Restart() error {
 }
 
 // SchemaTreeGzip provides a mock function with given fields:
-func (_m *Plugin) SchemaTreeGzip() ([]byte, error) {
+func (_m *PluginIface) SchemaTreeGzip() ([]byte, error) {
 	ret := _m.Called()
 
 	var r0 []byte
@@ -260,7 +260,7 @@ func (_m *Plugin) SchemaTreeGzip() ([]byte, error) {
 }
 
 // SetNode provides a mock function with given fields: path, value
-func (_m *Plugin) SetNode(path *gnmi.Path, value *gnmi.TypedValue) error {
+func (_m *PluginIface) SetNode(path *gnmi.Path, value *gnmi.TypedValue) error {
 	ret := _m.Called(path, value)
 
 	var r0 error
@@ -274,21 +274,21 @@ func (_m *Plugin) SetNode(path *gnmi.Path, value *gnmi.TypedValue) error {
 }
 
 // State provides a mock function with given fields:
-func (_m *Plugin) State() plugin.State {
+func (_m *PluginIface) State() model.State {
 	ret := _m.Called()
 
-	var r0 plugin.State
-	if rf, ok := ret.Get(0).(func() plugin.State); ok {
+	var r0 model.State
+	if rf, ok := ret.Get(0).(func() model.State); ok {
 		r0 = rf()
 	} else {
-		r0 = ret.Get(0).(plugin.State)
+		r0 = ret.Get(0).(model.State)
 	}
 
 	return r0
 }
 
 // Unmarshal provides a mock function with given fields: json, path
-func (_m *Plugin) Unmarshal(json []byte, path *gnmi.Path) error {
+func (_m *PluginIface) Unmarshal(json []byte, path *gnmi.Path) error {
 	ret := _m.Called(json, path)
 
 	var r0 error
@@ -302,7 +302,7 @@ func (_m *Plugin) Unmarshal(json []byte, path *gnmi.Path) error {
 }
 
 // Update provides a mock function with given fields:
-func (_m *Plugin) Update() error {
+func (_m *PluginIface) Update() error {
 	ret := _m.Called()
 
 	var r0 error
@@ -316,7 +316,7 @@ func (_m *Plugin) Update() error {
 }
 
 // ValidateChange provides a mock function with given fields: operation, path, value
-func (_m *Plugin) ValidateChange(operation networkelement.ApiOperation, path *gnmi.Path, value *gnmi.TypedValue) ([]byte, error) {
+func (_m *PluginIface) ValidateChange(operation networkelement.ApiOperation, path *gnmi.Path, value *gnmi.TypedValue) ([]byte, error) {
 	ret := _m.Called(operation, path, value)
 
 	var r0 []byte
@@ -341,14 +341,14 @@ func (_m *Plugin) ValidateChange(operation networkelement.ApiOperation, path *gn
 	return r0, r1
 }
 
-type mockConstructorTestingTNewPlugin interface {
+type mockConstructorTestingTNewPluginIface interface {
 	mock.TestingT
 	Cleanup(func())
 }
 
-// NewPlugin creates a new instance of Plugin. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
-func NewPlugin(t mockConstructorTestingTNewPlugin) *Plugin {
-	mock := &Plugin{}
+// NewPluginIface creates a new instance of PluginIface. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
+func NewPluginIface(t mockConstructorTestingTNewPluginIface) *PluginIface {
+	mock := &PluginIface{}
 	mock.Mock.Test(t)
 
 	t.Cleanup(func() { mock.AssertExpectations(t) })

controller/mocks/PluginService.go

+// Code generated by mockery v2.20.0. DO NOT EDIT.
+
+package mocks
+
+import (
+	model "code.fbi.h-da.de/danet/gosdn/controller/nucleus/domain/model"
+	mock "github.com/stretchr/testify/mock"
+
+	uuid "github.com/google/uuid"
+)
+
+// PluginService is an autogenerated mock type for the PluginService type
+type PluginService struct {
+	mock.Mock
+}
+
+// Add provides a mock function with given fields: _a0
+func (_m *PluginService) Add(_a0 *model.Plugin) error {
+	ret := _m.Called(_a0)
+
+	var r0 error
+	if rf, ok := ret.Get(0).(func(*model.Plugin) error); ok {
+		r0 = rf(_a0)
+	} else {
+		r0 = ret.Error(0)
+	}
+
+	return r0
+}
+
+// Delete provides a mock function with given fields: _a0
+func (_m *PluginService) Delete(_a0 *model.Plugin) error {
+	ret := _m.Called(_a0)
+
+	var r0 error
+	if rf, ok := ret.Get(0).(func(*model.Plugin) error); ok {
+		r0 = rf(_a0)
+	} else {
+		r0 = ret.Error(0)
+	}
+
+	return r0
+}
+
+// Get provides a mock function with given fields: _a0
+func (_m *PluginService) Get(_a0 model.Query) (*model.Plugin, error) {
+	ret := _m.Called(_a0)
+
+	var r0 *model.Plugin
+	var r1 error
+	if rf, ok := ret.Get(0).(func(model.Query) (*model.Plugin, error)); ok {
+		return rf(_a0)
+	}
+	if rf, ok := ret.Get(0).(func(model.Query) *model.Plugin); ok {
+		r0 = rf(_a0)
+	} else {
+		if ret.Get(0) != nil {
+			r0 = ret.Get(0).(*model.Plugin)
+		}
+	}
+
+	if rf, ok := ret.Get(1).(func(model.Query) error); ok {
+		r1 = rf(_a0)
+	} else {
+		r1 = ret.Error(1)
+	}
+
+	return r0, r1
+}
+
+// GetAll provides a mock function with given fields:
+func (_m *PluginService) GetAll() ([]*model.Plugin, error) {
+	ret := _m.Called()
+
+	var r0 []*model.Plugin
+	var r1 error
+	if rf, ok := ret.Get(0).(func() ([]*model.Plugin, error)); ok {
+		return rf()
+	}
+	if rf, ok := ret.Get(0).(func() []*model.Plugin); ok {
+		r0 = rf()
+	} else {
+		if ret.Get(0) != nil {
+			r0 = ret.Get(0).([]*model.Plugin)
+		}
+	}
+
+	if rf, ok := ret.Get(1).(func() error); ok {
+		r1 = rf()
+	} else {
+		r1 = ret.Error(1)
+	}
+
+	return r0, r1
+}
+
+// RequestPlugin provides a mock function with given fields: _a0
+func (_m *PluginService) RequestPlugin(_a0 uuid.UUID) (*model.Plugin, error) {
+	ret := _m.Called(_a0)
+
+	var r0 *model.Plugin
+	var r1 error
+	if rf, ok := ret.Get(0).(func(uuid.UUID) (*model.Plugin, error)); ok {
+		return rf(_a0)
+	}
+	if rf, ok := ret.Get(0).(func(uuid.UUID) *model.Plugin); ok {
+		r0 = rf(_a0)
+	} else {
+		if ret.Get(0) != nil {
+			r0 = ret.Get(0).(*model.Plugin)
+		}
+	}
+
+	if rf, ok := ret.Get(1).(func(uuid.UUID) error); ok {
+		r1 = rf(_a0)
+	} else {
+		r1 = ret.Error(1)
+	}
+
+	return r0, r1
+}
+
+type mockConstructorTestingTNewPluginService interface {
+	mock.TestingT
+	Cleanup(func())
+}
+
+// NewPluginService creates a new instance of PluginService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
+func NewPluginService(t mockConstructorTestingTNewPluginService) *PluginService {
+	mock := &PluginService{}
+	mock.Mock.Test(t)
+
+	t.Cleanup(func() { mock.AssertExpectations(t) })
+
+	return mock
+}

controller/mocks/PluginStore.go

+// Code generated by mockery v2.20.0. DO NOT EDIT.
+
+package mocks
+
+import (
+	model "code.fbi.h-da.de/danet/gosdn/controller/nucleus/domain/model"
+	mock "github.com/stretchr/testify/mock"
+)
+
+// PluginStore is an autogenerated mock type for the PluginStore type
+type PluginStore struct {
+	mock.Mock
+}
+
+// Add provides a mock function with given fields: _a0
+func (_m *PluginStore) Add(_a0 *model.Plugin) error {
+	ret := _m.Called(_a0)
+
+	var r0 error
+	if rf, ok := ret.Get(0).(func(*model.Plugin) error); ok {
+		r0 = rf(_a0)
+	} else {
+		r0 = ret.Error(0)
+	}
+
+	return r0
+}
+
+// Delete provides a mock function with given fields: _a0
+func (_m *PluginStore) Delete(_a0 *model.Plugin) error {
+	ret := _m.Called(_a0)
+
+	var r0 error
+	if rf, ok := ret.Get(0).(func(*model.Plugin) error); ok {
+		r0 = rf(_a0)
+	} else {
+		r0 = ret.Error(0)
+	}
+
+	return r0
+}
+
+// Get provides a mock function with given fields: _a0
+func (_m *PluginStore) Get(_a0 model.Query) (model.LoadedPlugin, error) {
+	ret := _m.Called(_a0)
+
+	var r0 model.LoadedPlugin
+	var r1 error
+	if rf, ok := ret.Get(0).(func(model.Query) (model.LoadedPlugin, error)); ok {
+		return rf(_a0)
+	}
+	if rf, ok := ret.Get(0).(func(model.Query) model.LoadedPlugin); ok {
+		r0 = rf(_a0)
+	} else {
+		r0 = ret.Get(0).(model.LoadedPlugin)
+	}
+
+	if rf, ok := ret.Get(1).(func(model.Query) error); ok {
+		r1 = rf(_a0)
+	} else {
+		r1 = ret.Error(1)
+	}
+
+	return r0, r1
+}
+
+// GetAll provides a mock function with given fields:
+func (_m *PluginStore) GetAll() ([]model.LoadedPlugin, error) {
+	ret := _m.Called()
+
+	var r0 []model.LoadedPlugin
+	var r1 error
+	if rf, ok := ret.Get(0).(func() ([]model.LoadedPlugin, error)); ok {
+		return rf()
+	}
+	if rf, ok := ret.Get(0).(func() []model.LoadedPlugin); ok {
+		r0 = rf()
+	} else {
+		if ret.Get(0) != nil {
+			r0 = ret.Get(0).([]model.LoadedPlugin)
+		}
+	}
+
+	if rf, ok := ret.Get(1).(func() error); ok {
+		r1 = rf()
+	} else {
+		r1 = ret.Error(1)
+	}
+
+	return r0, r1
+}
+
+// Update provides a mock function with given fields: _a0
+func (_m *PluginStore) Update(_a0 *model.Plugin) error {
+	ret := _m.Called(_a0)
+
+	var r0 error
+	if rf, ok := ret.Get(0).(func(*model.Plugin) error); ok {
+		r0 = rf(_a0)
+	} else {
+		r0 = ret.Error(0)
+	}
+
+	return r0
+}
+
+type mockConstructorTestingTNewPluginStore interface {
+	mock.TestingT
+	Cleanup(func())
+}
+
+// NewPluginStore creates a new instance of PluginStore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
+func NewPluginStore(t mockConstructorTestingTNewPluginStore) *PluginStore {
+	mock := &PluginStore{}
+	mock.Mock.Test(t)
+
+	t.Cleanup(func() { mock.AssertExpectations(t) })
+
+	return mock
+}

controller/mocks/PndService.go

-// Code generated by mockery v2.14.0. DO NOT EDIT.
+// Code generated by mockery v2.20.0. DO NOT EDIT.
 
 package mocks
 
 import (
-	networkdomain "code.fbi.h-da.de/danet/gosdn/controller/interfaces/networkdomain"
-	store "code.fbi.h-da.de/danet/gosdn/controller/store"
+	model "code.fbi.h-da.de/danet/gosdn/controller/nucleus/domain/model"
 	mock "github.com/stretchr/testify/mock"
 )
 
@@ -14,11 +13,11 @@ type PndService struct {
 }
 
 // Add provides a mock function with given fields: _a0
-func (_m *PndService) Add(_a0 networkdomain.NetworkDomain) error {
+func (_m *PndService) Add(_a0 model.NetworkDomain) error {
 	ret := _m.Called(_a0)
 
 	var r0 error
-	if rf, ok := ret.Get(0).(func(networkdomain.NetworkDomain) error); ok {
+	if rf, ok := ret.Get(0).(func(model.NetworkDomain) error); ok {
 		r0 = rf(_a0)
 	} else {
 		r0 = ret.Error(0)
@@ -28,11 +27,11 @@ func (_m *PndService) Add(_a0 networkdomain.NetworkDomain) error {
 }
 
 // Delete provides a mock function with given fields: _a0
-func (_m *PndService) Delete(_a0 networkdomain.NetworkDomain) error {
+func (_m *PndService) Delete(_a0 model.NetworkDomain) error {
 	ret := _m.Called(_a0)
 
 	var r0 error
-	if rf, ok := ret.Get(0).(func(networkdomain.NetworkDomain) error); ok {
+	if rf, ok := ret.Get(0).(func(model.NetworkDomain) error); ok {
 		r0 = rf(_a0)
 	} else {
 		r0 = ret.Error(0)
@@ -42,19 +41,22 @@ func (_m *PndService) Delete(_a0 networkdomain.NetworkDomain) error {
 }
 
 // Get provides a mock function with given fields: _a0
-func (_m *PndService) Get(_a0 model.Query) (networkdomain.NetworkDomain, error) {
+func (_m *PndService) Get(_a0 model.Query) (model.NetworkDomain, error) {
 	ret := _m.Called(_a0)
 
-	var r0 networkdomain.NetworkDomain
-	if rf, ok := ret.Get(0).(func(model.Query) networkdomain.NetworkDomain); ok {
+	var r0 model.NetworkDomain
+	var r1 error
+	if rf, ok := ret.Get(0).(func(model.Query) (model.NetworkDomain, error)); ok {
+		return rf(_a0)
+	}
+	if rf, ok := ret.Get(0).(func(model.Query) model.NetworkDomain); ok {
 		r0 = rf(_a0)
 	} else {
 		if ret.Get(0) != nil {
-			r0 = ret.Get(0).(networkdomain.NetworkDomain)
+			r0 = ret.Get(0).(model.NetworkDomain)
 		}
 	}
 
-	var r1 error
 	if rf, ok := ret.Get(1).(func(model.Query) error); ok {
 		r1 = rf(_a0)
 	} else {
@@ -65,19 +67,22 @@ func (_m *PndService) Get(_a0 model.Query) (networkdomain.NetworkDomain, error)
 }
 
 // GetAll provides a mock function with given fields:
-func (_m *PndService) GetAll() ([]networkdomain.NetworkDomain, error) {
+func (_m *PndService) GetAll() ([]model.NetworkDomain, error) {
 	ret := _m.Called()
 
-	var r0 []networkdomain.NetworkDomain
-	if rf, ok := ret.Get(0).(func() []networkdomain.NetworkDomain); ok {
+	var r0 []model.NetworkDomain
+	var r1 error
+	if rf, ok := ret.Get(0).(func() ([]model.NetworkDomain, error)); ok {
+		return rf()
+	}
+	if rf, ok := ret.Get(0).(func() []model.NetworkDomain); ok {
 		r0 = rf()
 	} else {
 		if ret.Get(0) != nil {
-			r0 = ret.Get(0).([]networkdomain.NetworkDomain)
+			r0 = ret.Get(0).([]model.NetworkDomain)
 		}
 	}
 
-	var r1 error
 	if rf, ok := ret.Get(1).(func() error); ok {
 		r1 = rf()
 	} else {

controller/mocks/PndStore.go

@@ -3,12 +3,9 @@
 package mocks
 
 import (
-	networkdomain "code.fbi.h-da.de/danet/gosdn/controller/interfaces/networkdomain"
-	networkelement "code.fbi.h-da.de/danet/gosdn/controller/interfaces/networkelement"
+	model "code.fbi.h-da.de/danet/gosdn/controller/nucleus/domain/model"
 	mock "github.com/stretchr/testify/mock"
 
-	store "code.fbi.h-da.de/danet/gosdn/controller/store"
-
 	uuid "github.com/google/uuid"
 )
 
@@ -18,11 +15,11 @@ type PndStore struct {
 }
 
 // Add provides a mock function with given fields: _a0
-func (_m *PndStore) Add(_a0 networkdomain.NetworkDomain) error {
+func (_m *PndStore) Add(_a0 model.NetworkDomain) error {
 	ret := _m.Called(_a0)
 
 	var r0 error
-	if rf, ok := ret.Get(0).(func(networkdomain.NetworkDomain) error); ok {
+	if rf, ok := ret.Get(0).(func(model.NetworkDomain) error); ok {
 		r0 = rf(_a0)
 	} else {
 		r0 = ret.Error(0)
@@ -37,11 +34,11 @@ func (_m *PndStore) AddPendingChannel(id uuid.UUID, ch chan model.Details) {
 }
 
 // Delete provides a mock function with given fields: _a0
-func (_m *PndStore) Delete(_a0 networkdomain.NetworkDomain) error {
+func (_m *PndStore) Delete(_a0 model.NetworkDomain) error {
 	ret := _m.Called(_a0)
 
 	var r0 error
-	if rf, ok := ret.Get(0).(func(networkdomain.NetworkDomain) error); ok {
+	if rf, ok := ret.Get(0).(func(model.NetworkDomain) error); ok {
 		r0 = rf(_a0)
 	} else {
 		r0 = ret.Error(0)
@@ -51,18 +48,18 @@ func (_m *PndStore) Delete(_a0 networkdomain.NetworkDomain) error {
 }
 
 // Get provides a mock function with given fields: _a0
-func (_m *PndStore) Get(_a0 model.Query) (networkdomain.LoadedPnd, error) {
+func (_m *PndStore) Get(_a0 model.Query) (model.LoadedPnd, error) {
 	ret := _m.Called(_a0)
 
-	var r0 networkdomain.LoadedPnd
+	var r0 model.LoadedPnd
 	var r1 error
-	if rf, ok := ret.Get(0).(func(model.Query) (networkdomain.LoadedPnd, error)); ok {
+	if rf, ok := ret.Get(0).(func(model.Query) (model.LoadedPnd, error)); ok {
 		return rf(_a0)
 	}
-	if rf, ok := ret.Get(0).(func(model.Query) networkdomain.LoadedPnd); ok {
+	if rf, ok := ret.Get(0).(func(model.Query) model.LoadedPnd); ok {
 		r0 = rf(_a0)
 	} else {
-		r0 = ret.Get(0).(networkdomain.LoadedPnd)
+		r0 = ret.Get(0).(model.LoadedPnd)
 	}
 
 	if rf, ok := ret.Get(1).(func(model.Query) error); ok {
@@ -75,19 +72,19 @@ func (_m *PndStore) Get(_a0 model.Query) (networkdomain.LoadedPnd, error) {
 }
 
 // GetAll provides a mock function with given fields:
-func (_m *PndStore) GetAll() ([]networkdomain.LoadedPnd, error) {
+func (_m *PndStore) GetAll() ([]model.LoadedPnd, error) {
 	ret := _m.Called()
 
-	var r0 []networkdomain.LoadedPnd
+	var r0 []model.LoadedPnd
 	var r1 error
-	if rf, ok := ret.Get(0).(func() ([]networkdomain.LoadedPnd, error)); ok {
+	if rf, ok := ret.Get(0).(func() ([]model.LoadedPnd, error)); ok {
 		return rf()
 	}
-	if rf, ok := ret.Get(0).(func() []networkdomain.LoadedPnd); ok {
+	if rf, ok := ret.Get(0).(func() []model.LoadedPnd); ok {
 		r0 = rf()
 	} else {
 		if ret.Get(0) != nil {
-			r0 = ret.Get(0).([]networkdomain.LoadedPnd)
+			r0 = ret.Get(0).([]model.LoadedPnd)
 		}
 	}
 

controller/mocks/RoleService.go

@@ -4,7 +4,7 @@ package mocks
 
 import (
 	rbac "code.fbi.h-da.de/danet/gosdn/controller/interfaces/rbac"
-	store "code.fbi.h-da.de/danet/gosdn/controller/store"
+	model "code.fbi.h-da.de/danet/gosdn/controller/nucleus/domain/model"
 	mock "github.com/stretchr/testify/mock"
 )
 

controller/mocks/RoleStore.go

@@ -4,7 +4,7 @@ package mocks
 
 import (
 	rbac "code.fbi.h-da.de/danet/gosdn/controller/interfaces/rbac"
-	store "code.fbi.h-da.de/danet/gosdn/controller/store"
+	model "code.fbi.h-da.de/danet/gosdn/controller/nucleus/domain/model"
 	mock "github.com/stretchr/testify/mock"
 )
 

controller/mocks/Store.go

@@ -3,8 +3,8 @@
 package mocks
 
 import (
-	networkelement "code.fbi.h-da.de/danet/gosdn/controller/interfaces/networkelement"
-	store "code.fbi.h-da.de/danet/gosdn/controller/store"
+	store "code.fbi.h-da.de/danet/gosdn/controller/interfaces/store"
+	uuid "github.com/google/uuid"
 	mock "github.com/stretchr/testify/mock"
 )
 
@@ -13,13 +13,13 @@ type Store struct {
 	mock.Mock
 }
 
-// Add provides a mock function with given fields: _a0
-func (_m *Store) Add(_a0 networkelement.NetworkElement) error {
-	ret := _m.Called(_a0)
+// Add provides a mock function with given fields: item
+func (_m *Store) Add(item store.Storable) error {
+	ret := _m.Called(item)
 
 	var r0 error
-	if rf, ok := ret.Get(0).(func(networkelement.NetworkElement) error); ok {
-		r0 = rf(_a0)
+	if rf, ok := ret.Get(0).(func(store.Storable) error); ok {
+		r0 = rf(item)
 	} else {
 		r0 = ret.Error(0)
 	}
@@ -27,13 +27,13 @@ func (_m *Store) Add(_a0 networkelement.NetworkElement) error {
 	return r0
 }
 
-// Delete provides a mock function with given fields: _a0
-func (_m *Store) Delete(_a0 networkelement.NetworkElement) error {
-	ret := _m.Called(_a0)
+// Delete provides a mock function with given fields: id
+func (_m *Store) Delete(id uuid.UUID) error {
+	ret := _m.Called(id)
 
 	var r0 error
-	if rf, ok := ret.Get(0).(func(networkelement.NetworkElement) error); ok {
-		r0 = rf(_a0)
+	if rf, ok := ret.Get(0).(func(uuid.UUID) error); ok {
+		r0 = rf(id)
 	} else {
 		r0 = ret.Error(0)
 	}
@@ -41,49 +41,39 @@ func (_m *Store) Delete(_a0 networkelement.NetworkElement) error {
 	return r0
 }
 
-// Get provides a mock function with given fields: _a0
-func (_m *Store) Get(_a0 model.Query) (networkelement.LoadedNetworkElement, error) {
-	ret := _m.Called(_a0)
+// Exists provides a mock function with given fields: id
+func (_m *Store) Exists(id uuid.UUID) bool {
+	ret := _m.Called(id)
 
-	var r0 networkelement.LoadedNetworkElement
-	var r1 error
-	if rf, ok := ret.Get(0).(func(model.Query) (networkelement.LoadedNetworkElement, error)); ok {
-		return rf(_a0)
-	}
-	if rf, ok := ret.Get(0).(func(model.Query) networkelement.LoadedNetworkElement); ok {
-		r0 = rf(_a0)
-	} else {
-		r0 = ret.Get(0).(networkelement.LoadedNetworkElement)
-	}
-
-	if rf, ok := ret.Get(1).(func(model.Query) error); ok {
-		r1 = rf(_a0)
+	var r0 bool
+	if rf, ok := ret.Get(0).(func(uuid.UUID) bool); ok {
+		r0 = rf(id)
 	} else {
-		r1 = ret.Error(1)
+		r0 = ret.Get(0).(bool)
 	}
 
-	return r0, r1
+	return r0
 }
 
-// GetAll provides a mock function with given fields:
-func (_m *Store) GetAll() ([]networkelement.LoadedNetworkElement, error) {
-	ret := _m.Called()
+// Get provides a mock function with given fields: id
+func (_m *Store) Get(id uuid.UUID) (store.Storable, error) {
+	ret := _m.Called(id)
 
-	var r0 []networkelement.LoadedNetworkElement
+	var r0 store.Storable
 	var r1 error
-	if rf, ok := ret.Get(0).(func() ([]networkelement.LoadedNetworkElement, error)); ok {
-		return rf()
+	if rf, ok := ret.Get(0).(func(uuid.UUID) (store.Storable, error)); ok {
+		return rf(id)
 	}
-	if rf, ok := ret.Get(0).(func() []networkelement.LoadedNetworkElement); ok {
-		r0 = rf()
+	if rf, ok := ret.Get(0).(func(uuid.UUID) store.Storable); ok {
+		r0 = rf(id)
 	} else {
 		if ret.Get(0) != nil {
-			r0 = ret.Get(0).([]networkelement.LoadedNetworkElement)
+			r0 = ret.Get(0).(store.Storable)
 		}
 	}
 
-	if rf, ok := ret.Get(1).(func() error); ok {
-		r1 = rf()
+	if rf, ok := ret.Get(1).(func(uuid.UUID) error); ok {
+		r1 = rf(id)
 	} else {
 		r1 = ret.Error(1)
 	}
@@ -91,15 +81,17 @@ func (_m *Store) GetAll() ([]networkelement.LoadedNetworkElement, error) {
 	return r0, r1
 }
 
-// Update provides a mock function with given fields: _a0
-func (_m *Store) Update(_a0 networkelement.NetworkElement) error {
-	ret := _m.Called(_a0)
+// UUIDs provides a mock function with given fields:
+func (_m *Store) UUIDs() []uuid.UUID {
+	ret := _m.Called()
 
-	var r0 error
-	if rf, ok := ret.Get(0).(func(networkelement.NetworkElement) error); ok {
-		r0 = rf(_a0)
+	var r0 []uuid.UUID
+	if rf, ok := ret.Get(0).(func() []uuid.UUID); ok {
+		r0 = rf()
 	} else {
-		r0 = ret.Error(0)
+		if ret.Get(0) != nil {
+			r0 = ret.Get(0).([]uuid.UUID)
+		}
 	}
 
 	return r0

controller/mocks/StreamClient.go

+// Code generated by mockery v2.20.0. DO NOT EDIT.
+
+package mocks
+
+import (
+	context "context"
+
+	mock "github.com/stretchr/testify/mock"
+	metadata "google.golang.org/grpc/metadata"
+
+	plugin_registry "code.fbi.h-da.de/danet/gosdn/api/go/gosdn/plugin-registry"
+)
+
+// StreamClient is an autogenerated mock type for the StreamClient type
+type StreamClient struct {
+	mock.Mock
+}
+
+// CloseSend provides a mock function with given fields:
+func (_m *StreamClient) CloseSend() error {
+	ret := _m.Called()
+
+	var r0 error
+	if rf, ok := ret.Get(0).(func() error); ok {
+		r0 = rf()
+	} else {
+		r0 = ret.Error(0)
+	}
+
+	return r0
+}
+
+// Context provides a mock function with given fields:
+func (_m *StreamClient) Context() context.Context {
+	ret := _m.Called()
+
+	var r0 context.Context
+	if rf, ok := ret.Get(0).(func() context.Context); ok {
+		r0 = rf()
+	} else {
+		if ret.Get(0) != nil {
+			r0 = ret.Get(0).(context.Context)
+		}
+	}
+
+	return r0
+}
+
+// Header provides a mock function with given fields:
+func (_m *StreamClient) Header() (metadata.MD, error) {
+	ret := _m.Called()
+
+	var r0 metadata.MD
+	var r1 error
+	if rf, ok := ret.Get(0).(func() (metadata.MD, error)); ok {
+		return rf()
+	}
+	if rf, ok := ret.Get(0).(func() metadata.MD); ok {
+		r0 = rf()
+	} else {
+		if ret.Get(0) != nil {
+			r0 = ret.Get(0).(metadata.MD)
+		}
+	}
+
+	if rf, ok := ret.Get(1).(func() error); ok {
+		r1 = rf()
+	} else {
+		r1 = ret.Error(1)
+	}
+
+	return r0, r1
+}
+
+// Recv provides a mock function with given fields:
+func (_m *StreamClient) Recv() (*plugin_registry.GetDownloadPayload, error) {
+	ret := _m.Called()
+
+	var r0 *plugin_registry.GetDownloadPayload
+	var r1 error
+	if rf, ok := ret.Get(0).(func() (*plugin_registry.GetDownloadPayload, error)); ok {
+		return rf()
+	}
+	if rf, ok := ret.Get(0).(func() *plugin_registry.GetDownloadPayload); ok {
+		r0 = rf()
+	} else {
+		if ret.Get(0) != nil {
+			r0 = ret.Get(0).(*plugin_registry.GetDownloadPayload)
+		}
+	}
+
+	if rf, ok := ret.Get(1).(func() error); ok {
+		r1 = rf()
+	} else {
+		r1 = ret.Error(1)
+	}
+
+	return r0, r1
+}
+
+// RecvMsg provides a mock function with given fields: m
+func (_m *StreamClient) RecvMsg(m interface{}) error {
+	ret := _m.Called(m)
+
+	var r0 error
+	if rf, ok := ret.Get(0).(func(interface{}) error); ok {
+		r0 = rf(m)
+	} else {
+		r0 = ret.Error(0)
+	}
+
+	return r0
+}
+
+// SendMsg provides a mock function with given fields: m
+func (_m *StreamClient) SendMsg(m interface{}) error {
+	ret := _m.Called(m)
+
+	var r0 error
+	if rf, ok := ret.Get(0).(func(interface{}) error); ok {
+		r0 = rf(m)
+	} else {
+		r0 = ret.Error(0)
+	}
+
+	return r0
+}
+
+// Trailer provides a mock function with given fields:
+func (_m *StreamClient) Trailer() metadata.MD {
+	ret := _m.Called()
+
+	var r0 metadata.MD
+	if rf, ok := ret.Get(0).(func() metadata.MD); ok {
+		r0 = rf()
+	} else {
+		if ret.Get(0) != nil {
+			r0 = ret.Get(0).(metadata.MD)
+		}
+	}
+
+	return r0
+}
+
+type mockConstructorTestingTNewStreamClient interface {
+	mock.TestingT
+	Cleanup(func())
+}
+
+// NewStreamClient creates a new instance of StreamClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
+func NewStreamClient(t mockConstructorTestingTNewStreamClient) *StreamClient {
+	mock := &StreamClient{}
+	mock.Mock.Test(t)
+
+	t.Cleanup(func() { mock.AssertExpectations(t) })
+
+	return mock
+}

controller/mocks/Transport.go

@@ -5,13 +5,10 @@ package mocks
 import (
 	context "context"
 
-	change "code.fbi.h-da.de/danet/gosdn/controller/interfaces/change"
-
 	gnmi "github.com/openconfig/gnmi/proto/gnmi"
-
 	mock "github.com/stretchr/testify/mock"
 
-	transport "code.fbi.h-da.de/danet/gosdn/controller/interfaces/transport"
+	model "code.fbi.h-da.de/danet/gosdn/controller/nucleus/domain/model"
 )
 
 // Transport is an autogenerated mock type for the Transport type
@@ -20,11 +17,11 @@ type Transport struct {
 }
 
 // ControlPlaneSubscribe provides a mock function with given fields: ctx, subscriptionInfo, subInfoChannel
-func (_m *Transport) ControlPlaneSubscribe(ctx context.Context, subscriptionInfo transport.SubscriptionInformation, subInfoChannel chan transport.SubscriptionInformation) error {
+func (_m *Transport) ControlPlaneSubscribe(ctx context.Context, subscriptionInfo model.SubscriptionInformation, subInfoChannel chan model.SubscriptionInformation) error {
 	ret := _m.Called(ctx, subscriptionInfo, subInfoChannel)
 
 	var r0 error
-	if rf, ok := ret.Get(0).(func(context.Context, transport.SubscriptionInformation, chan transport.SubscriptionInformation) error); ok {
+	if rf, ok := ret.Get(0).(func(context.Context, model.SubscriptionInformation, chan model.SubscriptionInformation) error); ok {
 		r0 = rf(ctx, subscriptionInfo, subInfoChannel)
 	} else {
 		r0 = ret.Error(0)
@@ -121,11 +118,11 @@ func (_m *Transport) ProcessResponse(resp interface{}) error {
 }
 
 // Set provides a mock function with given fields: ctx, payload
-func (_m *Transport) Set(ctx context.Context, payload change.Payload) error {
+func (_m *Transport) Set(ctx context.Context, payload model.Payload) error {
 	ret := _m.Called(ctx, payload)
 
 	var r0 error
-	if rf, ok := ret.Get(0).(func(context.Context, change.Payload) error); ok {
+	if rf, ok := ret.Get(0).(func(context.Context, model.Payload) error); ok {
 		r0 = rf(ctx, payload)
 	} else {
 		r0 = ret.Error(0)

controller/mocks/UserService.go

@@ -4,7 +4,7 @@ package mocks
 
 import (
 	rbac "code.fbi.h-da.de/danet/gosdn/controller/interfaces/rbac"
-	store "code.fbi.h-da.de/danet/gosdn/controller/store"
+	model "code.fbi.h-da.de/danet/gosdn/controller/nucleus/domain/model"
 	mock "github.com/stretchr/testify/mock"
 )
 

controller/mocks/UserStore.go

@@ -4,7 +4,7 @@ package mocks
 
 import (
 	rbac "code.fbi.h-da.de/danet/gosdn/controller/interfaces/rbac"
-	store "code.fbi.h-da.de/danet/gosdn/controller/store"
+	model "code.fbi.h-da.de/danet/gosdn/controller/nucleus/domain/model"
 	mock "github.com/stretchr/testify/mock"
 )
 

controller/mocks/storableConstraint.go

+// Code generated by mockery v2.20.0. DO NOT EDIT.
+
+package mocks
+
+import (
+	mock "github.com/stretchr/testify/mock"
+
+	uuid "github.com/google/uuid"
+)
+
+// storableConstraint is an autogenerated mock type for the storableConstraint type
+type storableConstraint struct {
+	mock.Mock
+}
+
+// ID provides a mock function with given fields:
+func (_m *storableConstraint) ID() uuid.UUID {
+	ret := _m.Called()
+
+	var r0 uuid.UUID
+	if rf, ok := ret.Get(0).(func() uuid.UUID); ok {
+		r0 = rf()
+	} else {
+		if ret.Get(0) != nil {
+			r0 = ret.Get(0).(uuid.UUID)
+		}
+	}
+
+	return r0
+}
+
+// Name provides a mock function with given fields:
+func (_m *storableConstraint) Name() string {
+	ret := _m.Called()
+
+	var r0 string
+	if rf, ok := ret.Get(0).(func() string); ok {
+		r0 = rf()
+	} else {
+		r0 = ret.Get(0).(string)
+	}
+
+	return r0
+}
+
+type mockConstructorTestingTnewStorableConstraint interface {
+	mock.TestingT
+	Cleanup(func())
+}
+
+// newStorableConstraint creates a new instance of storableConstraint. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
+func newStorableConstraint(t mockConstructorTestingTnewStorableConstraint) *storableConstraint {
+	mock := &storableConstraint{}
+	mock.Mock.Test(t)
+
+	t.Cleanup(func() { mock.AssertExpectations(t) })
+
+	return mock
+}