[OTA PROVIDER] - Read ApplyUpdateRequest as a flag using named pipes

.github/workflows/nightly.yaml

@@ -14,15 +14,15 @@
 
 name: Daily Run for slow tests
 on:
-    schedule:
-      - cron: '0 0 * * *'
+    # schedule:
+    #   - cron: '0 0 * * *'
 # --- TEST SECTION: Uncomment below to test on PRs ---
-    # push:
-    #     branches:
-    #         - master
-    #         - 'v*-branch'
-    # pull_request:
-    # merge_group:
+    push:
+        branches:
+            - master
+            - 'v*-branch'
+    pull_request:
+    merge_group:
 # --- END TEST SECTION ---
     workflow_dispatch:
         inputs:

examples/ota-provider-app/linux/OtaProviderAppCommandDelegate.cpp

@@ -59,6 +59,19 @@ static std::string ToString(const Json::Value & v)
     return Json::writeString(w, v);
 }
 
+Json::Value OtaProviderAppCommandHandler::BuildApplyUpdateRequestSnapshot(uint16_t endpoint)
+{
+    Json::Value payload(Json::objectValue);
+    payload["VendorID"]                         = GetOtaProviderExample().GetVendorId();
+    payload["ProductID"]                        = GetOtaProviderExample().GetProductId();
+    payload["SoftwareVersion"]                  = GetOtaProviderExample().GetSoftwareVersion();
+    payload["ApplyUpdateRequestSentStatus"]     = GetOtaProviderExample().GetApplyRequestSentStatus();
+    payload["ApplyUpdateRequestActionResponse"] = Json::UInt(GetOtaProviderExample().GetApplyRequestActionStatus());
+    payload["ApplyUpdateRequestDelayResponse"]  = GetOtaProviderExample().GetApplyRequestDelayStatus();
+    payload["ApplyUpdateRequestCount"]          = GetOtaProviderExample().GetApplyRequestCount();
+    return payload;
+}
+
 Json::Value OtaProviderAppCommandHandler::BuildOtaProviderSnapshot(uint16_t endpoint)
 {
     Json::Value payload(Json::objectValue);
@@ -132,6 +145,21 @@ void OtaProviderAppCommandHandler::HandleCommand(intptr_t context)
         return;
     }
 
+    if (name == "GetApplyUpdateRequestStatus")
+    {
+        Json::Value out(Json::objectValue);
+        out["Name"]     = "ApplyUpdateRequestResponse";
+        out["Cluster"]  = cluster;
+        out["Endpoint"] = endpoint;
+        out["Payload"]  = self->BuildApplyUpdateRequestSnapshot(endpoint);
+
+        if (delegate && delegate->GetPipes())
+        {
+            delegate->GetPipes()->WriteToOutPipe(ToString(out));
+        }
+        return;
+    }
+
     ChipLogError(NotSpecified, "Unhandled command: Should never happen");
 }
 

examples/ota-provider-app/linux/OtaProviderAppCommandDelegate.h

@@ -51,6 +51,7 @@ class OtaProviderAppCommandHandler
 
     static void HandleCommand(intptr_t context);
 
+    Json::Value BuildApplyUpdateRequestSnapshot(uint16_t endpoint);
     Json::Value BuildOtaProviderSnapshot(uint16_t endpoint);
 
     struct PrivateCtorTag

examples/ota-provider-app/ota-provider-common/OTAProviderExample.cpp

@@ -507,6 +507,12 @@ void OTAProviderExample::HandleApplyUpdateRequest(app::CommandHandler * commandO
     response.action            = mUpdateAction;
     response.delayedActionTime = mDelayedApplyActionTimeSec;
 
+    // Values for named pipes
+    mApplyUpdateRequestCount++;
+    mApplyUpdateRequestSent       = true;
+    mApplyUpdateRequestActionSent = mUpdateAction;
+    mApplyUpdateRequestDelaySent  = mDelayedApplyActionTimeSec;
+
     // Reset delay back to 0 for subsequent uses
     mDelayedApplyActionTimeSec = 0;
     // Reset back to success case for subsequent uses
@@ -525,6 +531,8 @@ void OTAProviderExample::HandleNotifyUpdateApplied(app::CommandHandler * command
 
     GetUpdateTokenString(commandData.updateToken, tokenBuf, kUpdateTokenStrLen);
     ChipLogDetail(SoftwareUpdate, "%s: token: %s, version: %" PRIu32, __FUNCTION__, tokenBuf, commandData.softwareVersion);
+    mApplyUpdateRequestSent  = false;
+    mApplyUpdateRequestCount = 0;
 
     commandObj->AddStatus(commandPath, Status::Success);
 }

examples/ota-provider-app/ota-provider-common/OTAProviderExample.h

@@ -104,6 +104,15 @@ class OTAProviderExample : public chip::app::Clusters::OTAProviderDelegate
     uint16_t GetProductId() const { return mProductId; }
     uint16_t GetHardwareVersion() const { return mHardwareVersion; }
     uint32_t GetSoftwareVersion() const { return mRequestorSoftwareVersion; }
+    // Variables used for named pipes
+    bool GetApplyRequestSentStatus() const { return mApplyUpdateRequestSent; }
+    chip::app::Clusters::OtaSoftwareUpdateProvider::OTAApplyUpdateAction GetApplyRequestActionStatus() const
+    {
+        return mApplyUpdateRequestActionSent;
+    }
+    uint32_t GetApplyRequestDelayStatus() const { return mApplyUpdateRequestDelaySent; }
+    uint16_t GetApplyRequestCount() const { return mApplyUpdateRequestCount; }
+    // End of variables used for named pipes
     chip::Span<const DownloadProtocolEnum> GetProtocolsSupported() const
     {
         return chip::Span<const DownloadProtocolEnum>(mProtocolsSupported);
@@ -161,4 +170,8 @@ class OTAProviderExample : public chip::app::Clusters::OTAProviderDelegate
     DownloadProtocolEnum mProtocolsSupported[kMaxProtocolsSupported];
     bool mRequestorCanConsent;
     char mLocation[kMaxLocation] = { 0, 0, 0 };
+    bool mApplyUpdateRequestSent = false;
+    OTAApplyUpdateAction mApplyUpdateRequestActionSent;
+    uint32_t mApplyUpdateRequestDelaySent;
+    u_int16_t mApplyUpdateRequestCount = 0;
 };