Skip to content
Snippets Groups Projects
Commit 4f0ae4e2 authored by Fabian Seidl's avatar Fabian Seidl
Browse files

added delete option for subscribe responses, WIP

parent e2bf1b8a
Branches
No related tags found
3 merge requests!376Add additional example application hostname-checker,!343Add basic application framework and example application to show interaction between events an NBI,!342Resolve "Add an option to send gNMI Subscribe requests via SBI"
Pipeline #109881 passed
...@@ -259,8 +259,7 @@ func (g *Gnmi) ProcessControlPlaneSubscribeResponse(resp *gpb.SubscribeResponse_ ...@@ -259,8 +259,7 @@ func (g *Gnmi) ProcessControlPlaneSubscribeResponse(resp *gpb.SubscribeResponse_
} }
//TODO: maybe remove and combine into one function/method! //TODO: maybe remove and combine into one function/method!
if err := g.processResponseDeletes(notification.Delete, dModel, schema); err != nil { if err := g.processResponseDeletes(notification.Delete, dModel, schema); err != nil {
log.Error(err) return err
//TODO: return err here after implementation!
} }
return nil return nil
...@@ -308,13 +307,18 @@ func handleProcessResponseErrors(errs []error) error { ...@@ -308,13 +307,18 @@ func handleProcessResponseErrors(errs []error) error {
func (g *Gnmi) processResponseDeletes(deletes []*gpb.Path, root ygot.ValidatedGoStruct, s *ytypes.Schema) error { func (g *Gnmi) processResponseDeletes(deletes []*gpb.Path, root ygot.ValidatedGoStruct, s *ytypes.Schema) error {
errs := make([]error, 0) errs := make([]error, 0)
_ = errs
for _, path := range deletes {
if err := ytypes.DeleteNode(s.RootSchema(), root, path); err != nil {
errs = append(errs, err)
}
}
if len(errs) != 0 { if len(errs) != 0 {
return handleProcessResponseErrors(errs) return handleProcessResponseErrors(errs)
} }
return errors.ErrNotYetImplemented{} return nil
} }
// Capabilities calls GNMI capabilities // Capabilities calls GNMI capabilities
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment