feat: Publish key change event after key deletion (#5200)

Signed-off-by: FelixTing <[email protected]>

Author: FelixTing

internal/core/keeper/controller/http/kv.go

@@ -19,6 +19,8 @@ import (
 	"github.com/edgexfoundry/go-mod-bootstrap/v4/di"
 	"github.com/edgexfoundry/go-mod-core-contracts/v4/dtos/requests"
 	"github.com/edgexfoundry/go-mod-core-contracts/v4/dtos/responses"
+	"github.com/edgexfoundry/go-mod-core-contracts/v4/models"
+
 	"github.com/labstack/echo/v4"
 )
 
@@ -127,6 +129,9 @@ func (rc *KVController) DeleteKeys(c echo.Context) error {
 		return utils.WriteErrorResponse(w, ctx, lc, err, "")
 	}
 
+	// publish the key change event
+	go application.PublishKeyChange(models.KVS{Key: key}, key, ctx, rc.dic)
+
 	response := responses.NewKeysResponse("", "", http.StatusOK, resp)
 	utils.WriteHttpHeader(w, ctx, http.StatusOK)
 	return pkg.EncodeAndWriteResponse(response, w, lc)

internal/core/keeper/controller/http/kv_test.go

@@ -1,5 +1,5 @@
 //
-// Copyright (C) 2024 IOTech Ltd
+// Copyright (C) 2024-2025 IOTech Ltd
 //
 // SPDX-License-Identifier: Apache-2.0
 
@@ -350,6 +350,8 @@ func TestDeleteKeys(t *testing.T) {
 	prefixExistsKey := "prefix-key"
 	keyResp := []models.KeyOnly{models.KeyOnly(key)}
 
+	msgClientMock := &messageClientMocks.MessageClient{}
+	msgClientMock.On("Publish", mock.Anything, mock.Anything).Return(nil)
 	dic := mockDic()
 	dbClientMock := &mocks.DBClient{}
 	dbClientMock.On("DeleteKeeperKeys", key, true).Return(keyResp, nil)
@@ -361,6 +363,9 @@ func TestDeleteKeys(t *testing.T) {
 		container.DBClientInterfaceName: func(get di.Get) interface{} {
 			return dbClientMock
 		},
+		bootstrapContainer.MessagingClientName: func(get di.Get) interface{} {
+			return msgClientMock
+		},
 	})
 
 	controller := NewKVController(dic)