request works w/oc

controller.go

@@ -7,7 +7,7 @@ import (
 	"os"
 	"os/signal"
 	"sync"
-	"time"
+	"syscall"
 
 	"github.com/google/uuid"
 	log "github.com/sirupsen/logrus"
@@ -52,7 +52,7 @@ func init() {
 	}
 
 	// Setting up signal capturing
-	signal.Notify(c.stopChan, os.Interrupt)
+	signal.Notify(c.stopChan, os.Interrupt, syscall.SIGTERM)
 }
 
 // initialize does start-up housekeeping like reading controller config files
@@ -127,8 +127,6 @@ func Run(ctx context.Context) error {
 			return shutdown()
 		case <-ctx.Done():
 			return shutdown()
-		case <-time.Tick(time.Minute):
-			log.Debug("up and running")
 		}
 	}
 }

nucleus/device.go

 package nucleus
 
 import (
-	"code.fbi.h-da.de/cocsn/gosdn/nucleus/errors"
-
 	tpb "code.fbi.h-da.de/cocsn/api/go/gosdn/transport"
 	"code.fbi.h-da.de/cocsn/gosdn/interfaces/device"
 	"code.fbi.h-da.de/cocsn/gosdn/interfaces/southbound"
@@ -134,5 +132,5 @@ func (d *CsbiDevice) SBI() southbound.SouthboundInterface {
 }
 
 func (d *CsbiDevice) ProcessResponse(resp proto.Message) error {
-	return &errors.ErrNotYetImplemented{}
+	return d.transport.ProcessResponse(resp, d.GoStruct, d.sbi.Schema())
 }

nucleus/southbound.go

@@ -166,7 +166,7 @@ func (csbi *Csbi) SbiIdentifier() string {
 
 func (csbi *Csbi) SetNode() func(schema *yang.Entry, root interface{}, path *gpb.Path, val interface{}, opts ...ytypes.SetNodeOpt) error {
 	return func(schema *yang.Entry, root interface{}, path *gpb.Path, val interface{}, opts ...ytypes.SetNodeOpt) error {
-		return &errors.ErrNotYetImplemented{}
+		return ytypes.SetNode(schema, root.(*openconfig.Device), path, val, opts...)
 	}
 }
 

nucleus/store.go

@@ -222,7 +222,7 @@ func (s DeviceStore) GetDevice(id uuid.UUID, parseErrors ...error) (device.Devic
 	}
 	log.WithFields(log.Fields{
 		"uuid": id,
-		"name": d.Name,
+		"name": d.Name(),
 	}).Debug("device was accessed")
 
 	return d, nil