Skip to content
Snippets Groups Projects
Commit 4d28be52 authored by Neil Schark's avatar Neil Schark
Browse files

hopefully fixed linting

parent c5e88164
No related branches found
No related tags found
1 merge request!404Enable export and import of SDN configuration
Pipeline #124748 failed
...@@ -117,20 +117,30 @@ func (c ConfigurationManagementServer) ImportSDNConfig(ctx context.Context, requ ...@@ -117,20 +117,30 @@ func (c ConfigurationManagementServer) ImportSDNConfig(ctx context.Context, requ
//TODO: Clear DB //TODO: Clear DB
//Create all elements //Create all elements
c.createElements(&sdnConfig, request)
if err != nil {
return nil, err
}
return &cmpb.ImportSDNConfigResponse{
Timestamp: time.Now().UnixNano()}, nil
}
func (c ConfigurationManagementServer) createElements(sdnConfig *loadedSDNConfig, request *cmpb.ImportSDNConfigRequest) error {
pndUUID := uuid.MustParse(request.Pid) pndUUID := uuid.MustParse(request.Pid)
pnd, err := c.pndStore.Get(store.Query{ID: pndUUID}) pnd, err := c.pndStore.Get(store.Query{ID: pndUUID})
if err != nil { if err != nil {
return nil, err return err
} }
for _, inputSBI := range sdnConfig.Sbis { for _, inputSBI := range sdnConfig.Sbis {
sbi, err := nucleus.NewSBI(inputSBI.Type, uuid.MustParse(inputSBI.ID)) sbi, err := nucleus.NewSBI(inputSBI.Type, uuid.MustParse(inputSBI.ID))
if err != nil { if err != nil {
return nil, err return err
} }
err = pnd.AddSbi(sbi) err = pnd.AddSbi(sbi)
if err != nil { if err != nil {
return nil, err return err
} }
} }
...@@ -141,7 +151,7 @@ func (c ConfigurationManagementServer) ImportSDNConfig(ctx context.Context, requ ...@@ -141,7 +151,7 @@ func (c ConfigurationManagementServer) ImportSDNConfig(ctx context.Context, requ
} }
_, err = c.nodeService.EnsureExists(node) _, err = c.nodeService.EnsureExists(node)
if err != nil { if err != nil {
return nil, err return err
} }
} }
...@@ -153,26 +163,26 @@ func (c ConfigurationManagementServer) ImportSDNConfig(ctx context.Context, requ ...@@ -153,26 +163,26 @@ func (c ConfigurationManagementServer) ImportSDNConfig(ctx context.Context, requ
} }
_, err = c.portService.EnsureExists(port) _, err = c.portService.EnsureExists(port)
if err != nil { if err != nil {
return nil, err return err
} }
} }
for _, inputPort := range sdnConfig.Links { for _, inputPort := range sdnConfig.Links {
sourceNode, err := c.nodeService.Get(store.Query{ID: inputPort.SourceNode.ID}) sourceNode, err := c.nodeService.Get(store.Query{ID: inputPort.SourceNode.ID})
if err != nil { if err != nil {
return nil, err return err
} }
targetNode, err := c.nodeService.Get(store.Query{ID: inputPort.TargetNode.ID}) targetNode, err := c.nodeService.Get(store.Query{ID: inputPort.TargetNode.ID})
if err != nil { if err != nil {
return nil, err return err
} }
sourcePort, err := c.portService.Get(store.Query{ID: inputPort.SourcePort.ID}) sourcePort, err := c.portService.Get(store.Query{ID: inputPort.SourcePort.ID})
if err != nil { if err != nil {
return nil, err return err
} }
targetPort, err := c.portService.Get(store.Query{ID: inputPort.TargetPort.ID}) targetPort, err := c.portService.Get(store.Query{ID: inputPort.TargetPort.ID})
if err != nil { if err != nil {
return nil, err return err
} }
link := links.Link{ link := links.Link{
ID: inputPort.ID, ID: inputPort.ID,
...@@ -184,7 +194,7 @@ func (c ConfigurationManagementServer) ImportSDNConfig(ctx context.Context, requ ...@@ -184,7 +194,7 @@ func (c ConfigurationManagementServer) ImportSDNConfig(ctx context.Context, requ
} }
err = c.topologyService.AddLink(link) err = c.topologyService.AddLink(link)
if err != nil { if err != nil {
return nil, err return err
} }
} }
...@@ -205,21 +215,18 @@ func (c ConfigurationManagementServer) ImportSDNConfig(ctx context.Context, requ ...@@ -205,21 +215,18 @@ func (c ConfigurationManagementServer) ImportSDNConfig(ctx context.Context, requ
uuid.MustParse(inputNetworkElement.ID), uuid.MustParse(inputNetworkElement.ID),
) )
if err != nil { if err != nil {
return nil, err return err
} }
networkelement, err := pnd.GetNetworkElement(inputNetworkElement.ID) networkelement, err := pnd.GetNetworkElement(inputNetworkElement.ID)
if err != nil { if err != nil {
return nil, err return err
} }
err = pnd.UpdateNetworkElement(networkelement, inputNetworkElement.Model) err = pnd.UpdateNetworkElement(networkelement, inputNetworkElement.Model)
if err != nil { if err != nil {
return nil, err return err
} }
} }
return nil
return &cmpb.ImportSDNConfigResponse{
Timestamp: time.Now().UnixNano()}, nil
} }
...@@ -245,7 +245,7 @@ func (pnd *pndImplementation) RemoveSbi(sid uuid.UUID) error { ...@@ -245,7 +245,7 @@ func (pnd *pndImplementation) RemoveSbi(sid uuid.UUID) error {
return pnd.removeSbi(sid) return pnd.removeSbi(sid)
} }
// AddNetworkElement adds a new network element to the PND. The UUID for the networkElementID is optional and should normally be empty // AddNetworkElement adds a new network element to the PND. The UUID for the networkElementID is optional and should normally be empty.
func (pnd *pndImplementation) AddNetworkElement(name string, opt *tpb.TransportOption, sid uuid.UUID, optionalNetworkElementID ...uuid.UUID) (uuid.UUID, error) { func (pnd *pndImplementation) AddNetworkElement(name string, opt *tpb.TransportOption, sid uuid.UUID, optionalNetworkElementID ...uuid.UUID) (uuid.UUID, error) {
networkElementID := uuid.Nil networkElementID := uuid.Nil
if len(optionalNetworkElementID) > 0 { if len(optionalNetworkElementID) > 0 {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment