Merge branch 'master' into validation-tests

.gitlab/ci/.mk-docs-deploy.yml

 build-mkdocs:
-    image: ${CI_DEPENDENCY_PROXY_GROUP_IMAGE_PREFIX}/python:3.11.5-slim-bullseye
+    image: ${CI_DEPENDENCY_PROXY_GROUP_IMAGE_PREFIX}/python:3.11.5-slim-bookworm
     stage: build
     before_script:
         - pip install mkdocs-material
@@ -13,7 +13,7 @@ build-mkdocs:
         - if: $CI_COMMIT_REF_PROTECTED == "true"
 
 .pages-options: &pages-options
-    image: ${CI_DEPENDENCY_PROXY_GROUP_IMAGE_PREFIX}/python:3.11.5-slim-bullseye
+    image: ${CI_DEPENDENCY_PROXY_GROUP_IMAGE_PREFIX}/python:3.11.5-slim-bookworm
     stage: deploy
     script:
         - mv mkdocs-built public

application-framework/event/type.go

@@ -12,6 +12,8 @@ const (
 	Update
 	// Delete is a delete event.
 	Delete
+	// Subscribe is a gNMI subscribe event.
+	Subscribe
 )
 
 // String implements the stringer interface for types.
@@ -23,6 +25,8 @@ func (t Type) String() string {
 		return "update"
 	case Delete:
 		return "delete"
+	case Subscribe:
+		return "subscribe"
 	}
 
 	return "unknown"
@@ -30,9 +34,10 @@ func (t Type) String() string {
 
 var (
 	typeLookup = map[string]Type{
-		"add":    Add,
-		"update": Update,
-		"delete": Delete,
+		"add":       Add,
+		"update":    Update,
+		"delete":    Delete,
+		"subscribe": Subscribe,
 	}
 )
 

applications/venv-manager/venv-manager.Dockerfile

@@ -2,7 +2,7 @@ ARG GOLANG_VERSION=1.21
 ARG BUILDARGS
 ARG $GITLAB_PROXY=code.fbi.h-da.de:443/danet/dependency_proxy/containers
 
-FROM ${GITLAB_PROXY}golang:$GOLANG_VERSION-bullseye AS builder
+FROM ${GITLAB_PROXY}golang:$GOLANG_VERSION-bookworm AS builder
 
 WORKDIR /gosdn
 

controller/controller.Dockerfile

@@ -2,14 +2,14 @@ ARG GOLANG_VERSION=1.21
 ARG BUILDARGS
 ARG $GITLAB_PROXY
 
-FROM ${GITLAB_PROXY}golang:$GOLANG_VERSION-bullseye as builder
+FROM ${GITLAB_PROXY}golang:$GOLANG_VERSION-bookworm as builder
 WORKDIR /gosdn/
 COPY . .
 RUN --mount=type=cache,target=/root/go/pkg/mod \
     --mount=type=cache,target=/root/.cache/go-build \
     make build-gosdn
 
-FROM ${GITLAB_PROXY}golang:$GOLANG_VERSION-bullseye
+FROM ${GITLAB_PROXY}golang:$GOLANG_VERSION-bookworm
 WORKDIR /app/
 COPY --from=builder /gosdn/controller/configs/development-gosdn.toml.example ./configs/development-gosdn.toml
 COPY --from=builder /gosdn/controller/configs/containerlab-gosdn.toml.example ./configs/containerlab-gosdn.toml

controller/event/event.go

@@ -19,6 +19,9 @@ const (
 
 	// TypeDelete is a delete event.
 	TypeDelete = "delete"
+
+	// TypeSubscribe is a gNMI subscribe event.
+	TypeSubscribe = "subscribe"
 )
 
 // NewAddEvent creates a new add event.
@@ -48,12 +51,12 @@ func NewUpdateEvent(entityID uuid.UUID) Event {
 	}
 }
 
-// NewMneUpdateEvent creates a new update event for managed network elements.
-func NewMneUpdateEvent(entityID uuid.UUID, pathsAndValues map[string]string) Event {
+// NewGnmiSubscribeEvent creates a new gNMI subscribe event for managed network elements.
+func NewGnmiSubscribeEvent(entityID uuid.UUID, pathsAndValues map[string]string) Event {
 	return Event{
 		ID:                uuid.New(),
 		EntityID:          entityID,
-		Type:              TypeUpdate,
+		Type:              TypeSubscribe,
 		PathsAndValuesMap: pathsAndValues,
 	}
 }

controller/event/event_test.go

@@ -121,7 +121,7 @@ func TestNewUpdateEvent(t *testing.T) {
 	}
 }
 
-func TestNewMneUpdateEvent(t *testing.T) {
+func TestNewGnmiSubscribeEvent(t *testing.T) {
 	type args struct {
 		entityID          uuid.UUID
 		pathsAndValuesMap map[string]string
@@ -132,7 +132,7 @@ func TestNewMneUpdateEvent(t *testing.T) {
 		want Event
 	}{
 		{
-			name: "should create a new update event",
+			name: "should create a new subscribe event",
 			args: args{
 				entityID:          getTestEntityUUID(),
 				pathsAndValuesMap: map[string]string{"some/random/path": "val"},
@@ -140,25 +140,25 @@ func TestNewMneUpdateEvent(t *testing.T) {
 			want: Event{
 				ID:                uuid.New(),
 				EntityID:          getTestEntityUUID(),
-				Type:              TypeUpdate,
+				Type:              TypeSubscribe,
 				PathsAndValuesMap: map[string]string{"some/random/path": "val"},
 			},
 		},
 	}
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
-			got := NewMneUpdateEvent(tt.args.entityID, tt.args.pathsAndValuesMap)
+			got := NewGnmiSubscribeEvent(tt.args.entityID, tt.args.pathsAndValuesMap)
 
 			if !reflect.DeepEqual(got.EntityID, tt.want.EntityID) {
-				t.Errorf("NewMneUpdateEvent().EntityID = %v, want %v", got, tt.want)
+				t.Errorf("NewGnmiSubscribeEvent().EntityID = %v, want %v", got, tt.want)
 			}
 
 			if !reflect.DeepEqual(got.Type, tt.want.Type) {
-				t.Errorf("NewMneUpdateEvent().Type = %v, want %v", got, tt.want)
+				t.Errorf("NewGnmiSubscribeEvent().Type = %v, want %v", got, tt.want)
 			}
 
 			if !reflect.DeepEqual(got.PathsAndValuesMap, tt.want.PathsAndValuesMap) {
-				t.Errorf("NewMneUpdateEvent().PathsAndValuesMap = %v, want %v", got, tt.want)
+				t.Errorf("NewGnmiSubscribeEvent().PathsAndValuesMap = %v, want %v", got, tt.want)
 			}
 		})
 	}

controller/nucleus/networkElementService.go

@@ -146,7 +146,7 @@ func (s *NetworkElementService) UpdateModel(networkElementID uuid.UUID, modelAsS
 	}
 
 	// TODO (faseid): check if we want to add the paths with values here instead of empty map!
-	pubEvent := event.NewMneUpdateEvent(networkElementID, map[string]string{})
+	pubEvent := event.NewUpdateEvent(networkElementID)
 	if err := s.eventService.PublishEvent(NetworkElementEventTopic, pubEvent); err != nil {
 		go func() {
 			s.eventService.Reconnect()
@@ -169,7 +169,7 @@ func (s *NetworkElementService) Update(networkElementToUpdate networkelement.Net
 	}
 
 	// TODO (faseid): check if we want to add the paths with values here instead of empty map!
-	pubEvent := event.NewMneUpdateEvent(networkElementToUpdate.ID(), map[string]string{})
+	pubEvent := event.NewUpdateEvent(networkElementToUpdate.ID())
 	if err := s.eventService.PublishEvent(NetworkElementEventTopic, pubEvent); err != nil {
 		go func() {
 			s.eventService.Reconnect()

controller/nucleus/networkElementWatcher.go

@@ -201,7 +201,7 @@ func (n *NetworkElementWatcher) handleSubscribeResponseUpdate(resp *gpb.Subscrib
 		log.Errorf("Error trying to parse uuid, could not handle subscription response: %v", err)
 	}
 
-	pubEvent := event.NewMneUpdateEvent(mneID, pathsAndValues)
+	pubEvent := event.NewGnmiSubscribeEvent(mneID, pathsAndValues)
 	if err := n.eventService.PublishEvent(NetworkElementEventTopic, pubEvent); err != nil {
 		go func() {
 			n.eventService.Reconnect()

plugin-registry/plugin-registry.Dockerfile

@@ -2,7 +2,7 @@ ARG GOLANG_VERSION=1.21
 ARG BUILDARGS
 ARG $GITLAB_PROXY
 
-FROM ${GITLAB_PROXY}golang:$GOLANG_VERSION-bullseye as builder
+FROM ${GITLAB_PROXY}golang:$GOLANG_VERSION-bookworm as builder
 WORKDIR /plugin-registry/
 RUN apt-get update
 RUN apt-get -y install --no-install-recommends zip

plugin-registry/plugin-registry.debug.Dockerfile

@@ -2,7 +2,7 @@ ARG GOLANG_VERSION=1.21
 ARG BUILDARGS
 ARG $GITLAB_PROXY
 
-FROM ${GITLAB_PROXY}golang:$GOLANG_VERSION-bullseye as builder
+FROM ${GITLAB_PROXY}golang:$GOLANG_VERSION-bookworm as builder
 WORKDIR /plugin-registry/
 RUN apt-get update
 RUN apt-get -y install --no-install-recommends zip