send proxy mapping updates

management/internals/modules/reverseproxy/manager/api.go

@@ -17,7 +17,7 @@ type handler struct {
 	manager reverseproxy.Manager
 }
 
-func RegisterEndpoints(router *mux.Router, manager reverseproxy.Manager) {
+func RegisterEndpoints(manager reverseproxy.Manager, router *mux.Router) {
 	h := &handler{
 		manager: manager,
 	}

management/internals/modules/reverseproxy/manager/manager.go

@@ -5,6 +5,7 @@ import (
 	"fmt"
 
 	"github.com/netbirdio/netbird/management/internals/modules/reverseproxy"
+	nbgrpc "github.com/netbirdio/netbird/management/internals/shared/grpc"
 	"github.com/netbirdio/netbird/management/server/account"
 	"github.com/netbirdio/netbird/management/server/activity"
 	"github.com/netbirdio/netbird/management/server/permissions"
@@ -18,13 +19,15 @@ type managerImpl struct {
 	store              store.Store
 	accountManager     account.Manager
 	permissionsManager permissions.Manager
+	proxyGRPCServer    *nbgrpc.ProxyServiceServer
 }
 
-func NewManager(store store.Store, accountManager account.Manager, permissionsManager permissions.Manager) reverseproxy.Manager {
+func NewManager(store store.Store, accountManager account.Manager, permissionsManager permissions.Manager, proxyGRPCServer *nbgrpc.ProxyServiceServer) reverseproxy.Manager {
 	return &managerImpl{
 		store:              store,
 		accountManager:     accountManager,
 		permissionsManager: permissionsManager,
+		proxyGRPCServer:    proxyGRPCServer,
 	}
 }
 
@@ -91,6 +94,8 @@ func (m *managerImpl) CreateReverseProxy(ctx context.Context, accountID, userID
 
 	m.accountManager.StoreEvent(ctx, userID, reverseProxy.ID, accountID, activity.ReverseProxyCreated, reverseProxy.EventMeta())
 
+	m.proxyGRPCServer.SendReverseProxyUpdate(reverseProxy.ToProtoMapping(reverseproxy.Create, ""))
+
 	return reverseProxy, nil
 }
 
@@ -135,6 +140,8 @@ func (m *managerImpl) UpdateReverseProxy(ctx context.Context, accountID, userID
 
 	m.accountManager.StoreEvent(ctx, userID, reverseProxy.ID, accountID, activity.ReverseProxyUpdated, reverseProxy.EventMeta())
 
+	m.proxyGRPCServer.SendReverseProxyUpdate(reverseProxy.ToProtoMapping(reverseproxy.Update, ""))
+
 	return reverseProxy, nil
 }
 
@@ -167,5 +174,7 @@ func (m *managerImpl) DeleteReverseProxy(ctx context.Context, accountID, userID,
 
 	m.accountManager.StoreEvent(ctx, userID, reverseProxyID, accountID, activity.ReverseProxyDeleted, reverseProxy.EventMeta())
 
+	m.proxyGRPCServer.SendReverseProxyUpdate(reverseProxy.ToProtoMapping(reverseproxy.Delete, ""))
+
 	return nil
 }

management/internals/modules/reverseproxy/reverseproxy.go

@@ -2,10 +2,21 @@ package reverseproxy
 
 import (
 	"errors"
+	"fmt"
 
 	"github.com/rs/xid"
+	log "github.com/sirupsen/logrus"
 
 	"github.com/netbirdio/netbird/shared/management/http/api"
+	"github.com/netbirdio/netbird/shared/management/proto"
+)
+
+type Operation string
+
+const (
+	Create Operation = "create"
+	Update Operation = "update"
+	Delete Operation = "delete"
 )
 
 type Target struct {
@@ -119,11 +130,79 @@ func (r *ReverseProxy) ToAPIResponse() *api.ReverseProxy {
 	}
 }
 
+func (r *ReverseProxy) ToProtoMapping(operation Operation, setupKey string) *proto.ProxyMapping {
+	pathMappings := make([]*proto.PathMapping, 0, len(r.Targets))
+	for _, target := range r.Targets {
+		if !target.Enabled {
+			continue
+		}
+
+		targetURL := target.Protocol + "://" + target.Host
+		if target.Port > 0 {
+			targetURL += ":" + fmt.Sprintf("%d", target.Port)
+		}
+
+		path := "/"
+		if target.Path != nil {
+			path = *target.Path
+		}
+
+		pathMappings = append(pathMappings, &proto.PathMapping{
+			Path:   path,
+			Target: targetURL,
+		})
+	}
+
+	auth := &proto.Authentication{}
+
+	if r.Auth.PasswordAuth != nil && r.Auth.PasswordAuth.Enabled {
+		auth.Password = &proto.Password{
+			Enabled:  true,
+			Password: r.Auth.PasswordAuth.Password,
+		}
+	}
+
+	if r.Auth.PinAuth != nil && r.Auth.PinAuth.Enabled {
+		auth.Pin = &proto.Pin{
+			Enabled: true,
+			Pin:     r.Auth.PinAuth.Pin,
+		}
+	}
+
+	if r.Auth.BearerAuth != nil && r.Auth.BearerAuth.Enabled {
+		auth.Oidc = &proto.OIDC{
+			Enabled: true,
+		}
+	}
+
+	return &proto.ProxyMapping{
+		Type:     operationToProtoType(operation),
+		Id:       r.ID,
+		Domain:   r.Domain,
+		Path:     pathMappings,
+		SetupKey: setupKey,
+		Auth:     auth,
+	}
+}
+
+func operationToProtoType(op Operation) proto.ProxyMappingUpdateType {
+	switch op {
+	case Create:
+		return proto.ProxyMappingUpdateType_UPDATE_TYPE_CREATED
+	case Update:
+		return proto.ProxyMappingUpdateType_UPDATE_TYPE_MODIFIED
+	case Delete:
+		return proto.ProxyMappingUpdateType_UPDATE_TYPE_REMOVED
+	default:
+		log.Fatalf("unknown operation type: %v", op)
+		return proto.ProxyMappingUpdateType_UPDATE_TYPE_CREATED
+	}
+}
+
 func (r *ReverseProxy) FromAPIRequest(req *api.ReverseProxyRequest) {
 	r.Name = req.Name
 	r.Domain = req.Domain
 
-	// Convert API targets to internal targets
 	targets := make([]Target, 0, len(req.Targets))
 	for _, apiTarget := range req.Targets {
 		targets = append(targets, Target{