fix message response

Author: aphralG

internal/command/command_plugin.go

@@ -260,7 +260,7 @@ func (cp *CommandPlugin) monitorSubscribeChannel(ctx context.Context) {
 				if cp.commandServerType != model.Command {
 					slog.WarnContext(newCtx, "Auxiliary command server can not perform config apply",
 						"command_server_type", cp.commandServerType.String())
-					cp.handleInvalidRequest(newCtx, message)
+					cp.handleInvalidRequest(newCtx, message, "Config apply failed")
 
 					return
 				}
@@ -273,7 +273,7 @@ func (cp *CommandPlugin) monitorSubscribeChannel(ctx context.Context) {
 				if cp.commandServerType != model.Command {
 					slog.WarnContext(newCtx, "Auxiliary command server can not perform api action",
 						"command_server_type", cp.commandServerType.String())
-					cp.handleInvalidRequest(newCtx, message)
+					cp.handleInvalidRequest(newCtx, message, "API action failed")
 
 					return
 				}
@@ -365,15 +365,17 @@ func (cp *CommandPlugin) handleHealthRequest(newCtx context.Context) {
 	cp.messagePipe.Process(newCtx, &bus.Message{Topic: bus.DataPlaneHealthRequestTopic})
 }
 
-func (cp *CommandPlugin) handleInvalidRequest(ctx context.Context, message *mpi.ManagementPlaneRequest) {
+func (cp *CommandPlugin) handleInvalidRequest(ctx context.Context,
+	request *mpi.ManagementPlaneRequest, message string,
+) {
 	err := cp.commandService.SendDataPlaneResponse(ctx, &mpi.DataPlaneResponse{
-		MessageMeta: message.GetMessageMeta(),
+		MessageMeta: request.GetMessageMeta(),
 		CommandResponse: &mpi.CommandResponse{
 			Status:  mpi.CommandResponse_COMMAND_STATUS_FAILURE,
-			Message: "Can not perform write action as auxiliary command server",
-			Error:   "request not allowed",
+			Message: message,
+			Error:   "Can not perform write action as auxiliary command server",
 		},
-		InstanceId: message.GetActionRequest().GetInstanceId(),
+		InstanceId: request.GetActionRequest().GetInstanceId(),
 	})
 	if err != nil {
 		slog.ErrorContext(ctx, "Unable to send data plane response", "error", err)