Groupcast: Testing events. (#43621)

* Groupcast: Testing events.

* Code review.

Author: rcasallas-silabs

src/app/CommandHandlerImpl.cpp

@@ -34,6 +34,7 @@
 #include <platform/LockTracker.h>
 #include <protocols/interaction_model/StatusCode.h>
 #include <protocols/secure_channel/Constants.h>
+#include <transport/raw/GroupcastTesting.h>
 
 namespace chip {
 namespace app {
@@ -525,6 +526,15 @@ Status CommandHandlerImpl::ProcessGroupCommandDataIB(CommandDataIB::Parser & aCo
                       mapping.endpoint_id, ChipLogValueMEI(clusterId), ChipLogValueMEI(commandId));
 
         const ConcreteCommandPath concretePath(mapping.endpoint_id, clusterId, commandId);
+        // Groupcast Testing
+        auto & testing = Groupcast::GetTesting();
+        if (testing.IsEnabled() && testing.IsFabricUnderTest(fabric))
+        {
+            testing.SetGroupID(groupId);
+            testing.SetEndpointID(mapping.endpoint_id);
+            testing.SetClusterID(clusterId);
+            testing.SetElementID(static_cast<uint32_t>(commandId));
+        }
 
         {
             Access::SubjectDescriptor subjectDescriptor = GetSubjectDescriptor();

src/app/InteractionModelEngine.cpp

@@ -51,6 +51,7 @@
 #include <lib/support/FibonacciUtils.h>
 #include <lib/support/ReadOnlyBuffer.h>
 #include <protocols/interaction_model/StatusCode.h>
+#include <transport/raw/GroupcastTesting.h>
 
 #include <cinttypes>
 
@@ -1097,6 +1098,27 @@ CHIP_ERROR InteractionModelEngine::OnMessageReceived(Messaging::ExchangeContext
         status = Status::InvalidAction;
     }
 
+    // Groupcast Testing
+    if (apExchangeContext->IsGroupExchangeContext())
+    {
+        auto & testing = Groupcast::GetTesting();
+        if (testing.IsEnabled() && testing.IsFabricUnderTest(apExchangeContext->GetSessionHandle()->GetFabricIndex()))
+        {
+            Clusters::Groupcast::Events::GroupcastTesting::Type event;
+            if ((testing.GetTestResultEnum() == Groupcast::Testing::Result::kSuccess) && (status != Status::Success))
+            {
+                testing.SetTestResult(Groupcast::Testing::Result::kGeneralError);
+            }
+            // Convert to event type
+            testing.ToEventType(event);
+            testing.Clear();
+            // Generate event
+            DataModel::EventsGenerator & eventGenerator = EventManagement::GetInstance();
+            eventGenerator.GenerateEvent(event, kRootEndpointId);
+            eventGenerator.ScheduleUrgentEventDeliverySync();
+        }
+    }
+
     if (status != Status::Success && !apExchangeContext->IsGroupExchangeContext())
     {
         return StatusResponse::Send(status, apExchangeContext, false /*aExpectResponse*/);
@@ -1817,6 +1839,16 @@ Protocols::InteractionModel::Status InteractionModelEngine::ValidateCommandCanBe
     Access::Privilege privilegeToCheck = commandExists ? acceptedCommandEntry.GetInvokePrivilege() : Access::Privilege::kOperate;
 
     Status accessStatus = CheckCommandAccess(request, privilegeToCheck);
+    // Groupcast Testing
+    auto & testing = Groupcast::GetTesting();
+    if (testing.IsEnabled() && testing.IsFabricUnderTest(request.GetAccessingFabricIndex()))
+    {
+        testing.SetAccessAllowed(Status::Success == accessStatus);
+        if (!testing.GetAccessAllowed().ValueOr(false))
+        {
+            testing.SetTestResult(Groupcast::Testing::Result::kFailedAuth);
+        }
+    }
     VerifyOrReturnValue(accessStatus == Status::Success, accessStatus);
 
     if (!commandExists)

src/app/WriteHandler.cpp

@@ -40,6 +40,7 @@
 #include <lib/support/logging/TextOnlyLogging.h>
 #include <messaging/ExchangeContext.h>
 #include <protocols/interaction_model/StatusCode.h>
+#include <transport/raw/GroupcastTesting.h>
 
 #include <optional>
 
@@ -503,6 +504,15 @@ CHIP_ERROR WriteHandler::ProcessGroupAttributeDataIBs(TLV::TLVReader & aAttribut
             }
 
             dataAttributePath.mEndpointId = mapping.endpoint_id;
+            // Groupcast Testing
+            auto & testing = Groupcast::GetTesting();
+            if (testing.IsEnabled() && testing.IsFabricUnderTest(fabric))
+            {
+                testing.SetGroupID(groupId);
+                testing.SetEndpointID(dataAttributePath.mEndpointId);
+                testing.SetClusterID(dataAttributePath.mClusterId);
+                testing.SetElementID(static_cast<uint32_t>(dataAttributePath.mAttributeId));
+            }
 
             // Try to get the metadata from for the attribute from one of the expanded endpoints (it doesn't really matter which
             // endpoint we pick, as long as it's valid) and update the path info according to it and recheck if we need to report

src/app/clusters/groupcast/GroupcastCluster.cpp

@@ -8,11 +8,11 @@
 #include <credentials/GroupDataProvider.h>
 #include <lib/core/CHIPError.h>
 #include <lib/support/CodeUtils.h>
+#include <transport/raw/GroupcastTesting.h>
 
 using chip::Protocols::InteractionModel::Status;
 
 using namespace chip::Credentials;
-using GroupDataProvider = GroupDataProvider;
 using GroupInfo         = GroupDataProvider::GroupInfo;
 using GroupEndpoint     = GroupDataProvider::GroupEndpoint;
 using GroupInfoIterator = GroupDataProvider::GroupInfoIterator;
@@ -89,7 +89,7 @@ DataModel::ActionReturnStatus GroupcastCluster::ReadAttribute(const DataModel::R
     case Groupcast::Attributes::UsedMcastAddrCount::Id:
         return ReadUsedMcastAddrCount(request.path.mEndpointId, encoder);
     case Groupcast::Attributes::FabricUnderTest::Id:
-        return encoder.Encode(mFabricUnderTest);
+        return encoder.Encode(chip::Groupcast::GetTesting().GetFabricIndex());
     }
     return Protocols::InteractionModel::Status::UnsupportedAttribute;
 }
@@ -174,7 +174,8 @@ CHIP_ERROR GroupcastCluster::GeneratedCommands(const ConcreteClusterPath & path,
 
 Status GroupcastCluster::GroupcastTesting(FabricIndex fabricIndex, Groupcast::Commands::GroupcastTesting::DecodableType data)
 {
-    VerifyOrReturnError(mFabricUnderTest == kUndefinedFabricIndex || mFabricUnderTest == fabricIndex, Status::ConstraintError);
+    FabricIndex fabricUnderTest = chip::Groupcast::GetTesting().GetFabricIndex();
+    VerifyOrReturnError(fabricUnderTest == kUndefinedFabricIndex || fabricUnderTest == fabricIndex, Status::ConstraintError);
 
     if (data.testOperation == Groupcast::GroupcastTestingEnum::kDisableTesting)
     {
@@ -205,7 +206,14 @@ Status GroupcastCluster::GroupcastTesting(FabricIndex fabricIndex, Groupcast::Co
 
 void GroupcastCluster::SetFabricUnderTest(FabricIndex fabricUnderTest)
 {
-    SetAttributeValue(mFabricUnderTest, fabricUnderTest, Groupcast::Attributes::FabricUnderTest::Id);
+    auto & testing = chip::Groupcast::GetTesting();
+    if (fabricUnderTest != testing.GetFabricIndex())
+    {
+        testing.Clear();
+        testing.SetFabricIndex(fabricUnderTest);
+        NotifyAttributeChanged(Groupcast::Attributes::FabricUnderTest::Id);
+    }
+    testing.SetEnabled(fabricUnderTest != kUndefinedFabricIndex);
 }
 
 // MembershipChangedTimer implementation

src/app/clusters/groupcast/GroupcastCluster.h

@@ -70,7 +70,6 @@ class GroupcastCluster : public DefaultServerCluster, public Credentials::GroupD
     Protocols::InteractionModel::Status GroupcastTesting(FabricIndex fabricIndex,
                                                          Groupcast::Commands::GroupcastTesting::DecodableType data);
 
-    inline FabricIndex GetFabricUnderTest() const { return mFabricUnderTest; }
     const BitFlags<Groupcast::Feature> & Features() const { return mFeatures; }
 
     // Methods moved from GroupcastLogic
@@ -129,7 +128,6 @@ class GroupcastCluster : public DefaultServerCluster, public Credentials::GroupD
     bool mIanaAddressUsed                    = false;
 
     Groupcast::GroupcastTestingEnum mTestingState = Groupcast::GroupcastTestingEnum::kDisableTesting;
-    FabricIndex mFabricUnderTest                  = kUndefinedFabricIndex;
     class MembershipChangedTimer : public TimerContext
     {
     public:

src/transport/SessionManager.cpp

@@ -48,6 +48,7 @@
 #include <transport/SecureMessageCodec.h>
 #include <transport/TracingStructs.h>
 #include <transport/TransportMgr.h>
+#include <transport/raw/GroupcastTesting.h>
 
 namespace chip {
 
@@ -1166,7 +1167,16 @@ void SessionManager::SecureGroupMessageDispatch(const PacketHeader & partialPack
 #endif // CHIP_CONFIG_PRIVACY_ACCEPT_NONSPEC_SVE2
     }
     iter.Release();
-
+    // Groupcast Testing
+    auto & testing = chip::Groupcast::GetTesting();
+    if (testing.IsEnabled() && testing.IsFabricUnderTest(groupContext.fabric_index))
+    {
+        testing.SetGroupID(packetHeaderCopy.GetDestinationGroupId().Value());
+        if (!decrypted)
+        {
+            testing.SetTestResult(chip::Groupcast::Testing::Result::kNoAvailableKey);
+        }
+    }
     if (!decrypted)
     {
         ChipLogError(Inet, "Failed to decrypt group message. Discarding everything");

src/transport/raw/BUILD.gn

@@ -26,6 +26,8 @@ static_library("raw") {
 
   sources = [
     "Base.h",
+    "GroupcastTesting.cpp",
+    "GroupcastTesting.h",
     "MessageHeader.cpp",
     "MessageHeader.h",
     "PeerAddress.cpp",

src/transport/raw/GroupcastTesting.cpp

@@ -0,0 +1,30 @@
+/*
+ *    Copyright (c) 2026 Project CHIP Authors
+ *    All rights reserved.
+ *
+ *    Licensed under the Apache License, Version 2.0 (the "License");
+ *    you may not use this file except in compliance with the License.
+ *    You may obtain a copy of the License at
+ *
+ *        http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *    Unless required by applicable law or agreed to in writing, software
+ *    distributed under the License is distributed on an "AS IS" BASIS,
+ *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *    See the License for the specific language governing permissions and
+ *    limitations under the License.
+ */
+
+#include "GroupcastTesting.h"
+
+namespace chip {
+namespace Groupcast {
+
+Testing & GetTesting()
+{
+    static Testing sInstance;
+    return sInstance;
+}
+
+} // namespace Groupcast
+} // namespace chip