From 2a4b09d06586af92100f13aa9d71a9a469d0113d Mon Sep 17 00:00:00 2001
From: joonhaengHeo <85541460+joonhaengHeo@users.noreply.github.com>
Date: Fri, 31 Mar 2023 02:37:49 +0900
Subject: [PATCH] [Android] Add eventMin parameter (#25204)

* Add eventMin parameter

* Restyle

* Modify space

* Modify read dialog string
---
 .../clusterclient/WildcardFragment.kt         |  27 +++-
 .../app/src/main/res/layout/read_dialog.xml   |  30 ++++-
 .../src/main/res/layout/subscribe_dialog.xml  |  12 ++
 .../app/src/main/res/values/strings.xml       |   2 +
 .../java/CHIPDeviceController-JNI.cpp         |  14 +-
 .../ChipDeviceController.java                 | 120 ++++++++++++++++--
 6 files changed, 187 insertions(+), 18 deletions(-)

diff --git a/examples/android/CHIPTool/app/src/main/java/com/google/chip/chiptool/clusterclient/WildcardFragment.kt b/examples/android/CHIPTool/app/src/main/java/com/google/chip/chiptool/clusterclient/WildcardFragment.kt
index 83a3ba0eae7cbc..c665adaeb97b47 100644
--- a/examples/android/CHIPTool/app/src/main/java/com/google/chip/chiptool/clusterclient/WildcardFragment.kt
+++ b/examples/android/CHIPTool/app/src/main/java/com/google/chip/chiptool/clusterclient/WildcardFragment.kt
@@ -229,7 +229,7 @@ class WildcardFragment : Fragment() {
     return stringBuilder.toString()
   }
 
-  private suspend fun subscribe(minInterval: Int, maxInterval: Int, keepSubscriptions: Boolean, isFabricFiltered: Boolean) {
+  private suspend fun subscribe(minInterval: Int, maxInterval: Int, keepSubscriptions: Boolean, isFabricFiltered: Boolean, eventMin: Long?) {
     val subscriptionEstablishedCallback =
       SubscriptionEstablishedCallback {
         subscriptionId ->
@@ -255,17 +255,19 @@ class WildcardFragment : Fragment() {
             maxInterval,
             keepSubscriptions,
             isFabricFiltered,
-            /* imTimeoutMs= */ 0)
+            /* imTimeoutMs= */ 0,
+            eventMin)
   }
 
-  private suspend fun read(isFabricFiltered: Boolean) {
+  private suspend fun read(isFabricFiltered: Boolean, eventMin: Long?) {
     deviceController.readPath(reportCallback,
             ChipClient.getConnectedDevicePointer(requireContext(),
                     addressUpdateFragment.deviceId),
             attributePath.ifEmpty { null },
             eventPath.ifEmpty { null },
             isFabricFiltered,
-            /* imTimeoutMs= */ 0)
+            /* imTimeoutMs= */ 0,
+            eventMin)
   }
 
   private suspend fun write(writeValueType: String, writeValue: String, dataVersion: Int?, timedRequestTimeoutMs: Int, imTimeoutMs: Int) {
@@ -336,14 +338,20 @@ class WildcardFragment : Fragment() {
       return
     }
     val dialogView = requireActivity().layoutInflater.inflate(R.layout.read_dialog, null)
+    val eventMinEd = dialogView.findViewById<EditText>(R.id.eventMinEd)
+    eventMinEd.visibility = if (eventPath.isNotEmpty()) { View.VISIBLE } else { View.GONE }
     val dialog = AlertDialog.Builder(requireContext()).apply {
       setView(dialogView)
     }.create()
 
-    val isFabricFilteredEd = dialogView.findViewById<EditText>(R.id.isFabricFilteredSp)
+    val isFabricFilteredEd = dialogView.findViewById<Spinner>(R.id.isFabricFilteredSp)
     dialogView.findViewById<Button>(R.id.readBtn).setOnClickListener {
       scope.launch {
-        read(isFabricFilteredEd.text.toString().toBoolean())
+        var eventMin : Long? = null
+        if (eventPath.isNotEmpty() && eventMinEd.text.isNotBlank()) {
+          eventMin = eventMinEd.text.toString().toULong().toLong()
+        }
+        read(isFabricFilteredEd.selectedItem.toString().toBoolean(), eventMin)
         requireActivity().runOnUiThread { dialog.dismiss() }
       }
     }
@@ -385,6 +393,8 @@ class WildcardFragment : Fragment() {
       return
     }
     val dialogView = requireActivity().layoutInflater.inflate(R.layout.subscribe_dialog, null)
+    val eventMinEd = dialogView.findViewById<EditText>(R.id.eventMinEd)
+    eventMinEd.visibility = if (eventPath.isNotEmpty()) { View.VISIBLE } else { View.GONE }
     val dialog = AlertDialog.Builder(requireContext()).apply {
       setView(dialogView)
     }.create()
@@ -396,11 +406,16 @@ class WildcardFragment : Fragment() {
     dialogView.findViewById<Button>(R.id.subscribeBtn).setOnClickListener {
       scope.launch {
         if(minIntervalEd.text.isNotBlank() && maxIntervalEd.text.isNotBlank()) {
+          var eventMin : Long? = null
+          if (eventPath.isNotEmpty() && eventMinEd.text.isNotBlank()) {
+            eventMin = eventMinEd.text.toString().toULong().toLong()
+          }
           subscribe(
             minIntervalEd.text.toString().toInt(),
             maxIntervalEd.text.toString().toInt(),
             keepSubscriptionsSp.selectedItem.toString().toBoolean(),
             isFabricFilteredSp.selectedItem.toString().toBoolean(),
+            eventMin,
           )
         } else {
           Log.e(TAG, "minInterval or maxInterval is empty!" )
diff --git a/examples/android/CHIPTool/app/src/main/res/layout/read_dialog.xml b/examples/android/CHIPTool/app/src/main/res/layout/read_dialog.xml
index 4ac2a1ccb46385..9b92a5a23deef0 100644
--- a/examples/android/CHIPTool/app/src/main/res/layout/read_dialog.xml
+++ b/examples/android/CHIPTool/app/src/main/res/layout/read_dialog.xml
@@ -1,6 +1,7 @@
 <?xml version="1.0" encoding="utf-8"?>
 <androidx.constraintlayout.widget.ConstraintLayout xmlns:android="http://schemas.android.com/apk/res/android"
     xmlns:app="http://schemas.android.com/apk/res-auto"
+    xmlns:tools="http://schemas.android.com/tools"
     android:layout_width="wrap_content"
     android:layout_height="wrap_content"
     android:padding="16dp">
@@ -13,16 +14,41 @@
       app:layout_constraintStart_toStartOf="parent"
       app:layout_constraintTop_toTopOf="parent" />
 
-  <EditText
+  <TextView
+      android:id="@+id/titleIsFabricFilter"
+      android:layout_width="match_parent"
+      android:layout_height="wrap_content"
+      android:text="@string/read_dialog_is_fabric_filtered_hint"
+      android:textSize="16sp"
+      android:layout_marginTop="8dp"
+      app:layout_constraintStart_toStartOf="parent"
+      app:layout_constraintTop_toBottomOf="@id/titleText"
+      />
+
+  <Spinner
       android:id="@+id/isFabricFilteredSp"
       android:layout_width="wrap_content"
       android:layout_height="wrap_content"
       android:hint="@string/read_dialog_is_fabric_filtered_hint"
       android:inputType="text"
+      android:entries="@array/chip_select_menu"
+      android:spinnerMode="dropdown"
       android:textSize="16sp"
       android:layout_marginBottom="8dp"
       app:layout_constraintStart_toStartOf="parent"
-      app:layout_constraintTop_toBottomOf="@id/titleText"
+      app:layout_constraintTop_toBottomOf="@id/titleIsFabricFilter"
+      app:layout_constraintBottom_toTopOf="@+id/eventMinEd"/>
+
+  <EditText
+      android:id="@+id/eventMinEd"
+      android:layout_width="wrap_content"
+      android:layout_height="wrap_content"
+      android:hint="@string/read_dialog_event_min_hint"
+      android:inputType="number"
+      android:textSize="16sp"
+      android:layout_marginBottom="8dp"
+      app:layout_constraintStart_toStartOf="parent"
+      app:layout_constraintTop_toBottomOf="@id/isFabricFilteredSp"
       app:layout_constraintBottom_toTopOf="@+id/readBtn"/>
 
   <Button
diff --git a/examples/android/CHIPTool/app/src/main/res/layout/subscribe_dialog.xml b/examples/android/CHIPTool/app/src/main/res/layout/subscribe_dialog.xml
index 3830ddf971abd1..6e27040ccb0c68 100644
--- a/examples/android/CHIPTool/app/src/main/res/layout/subscribe_dialog.xml
+++ b/examples/android/CHIPTool/app/src/main/res/layout/subscribe_dialog.xml
@@ -79,6 +79,18 @@
       android:layout_marginBottom="8dp"
       app:layout_constraintStart_toStartOf="parent"
       app:layout_constraintTop_toBottomOf="@id/titleIsFabricFilter"
+      app:layout_constraintBottom_toTopOf="@+id/eventMinEd"/>
+
+  <EditText
+      android:id="@+id/eventMinEd"
+      android:layout_width="wrap_content"
+      android:layout_height="wrap_content"
+      android:hint="@string/subscribe_dialog_event_min_hint"
+      android:inputType="number"
+      android:textSize="16sp"
+      android:layout_marginBottom="8dp"
+      app:layout_constraintStart_toStartOf="parent"
+      app:layout_constraintTop_toBottomOf="@id/isFabricFilteredSp"
       app:layout_constraintBottom_toTopOf="@+id/subscribeBtn"/>
 
   <Button
diff --git a/examples/android/CHIPTool/app/src/main/res/values/strings.xml b/examples/android/CHIPTool/app/src/main/res/values/strings.xml
index 5a37d3ef35461c..b7e67159849233 100644
--- a/examples/android/CHIPTool/app/src/main/res/values/strings.xml
+++ b/examples/android/CHIPTool/app/src/main/res/values/strings.xml
@@ -137,6 +137,7 @@
     <string name="read_dialog_title_text">Read</string>
     <string name="read_dialog_read_btn_text">Read</string>
     <string name="read_dialog_is_fabric_filtered_hint">is Fabric Filtered (bool)</string>
+    <string name="read_dialog_event_min_hint">Minimum Event Number</string>
 
     <string name="subscribe_dialog_title_text">Subscribe</string>
     <string name="subscribe_dialog_subscribe_btn_text">Subscribe</string>
@@ -144,6 +145,7 @@
     <string name="subscribe_dialog_max_interval_hint">Maximum interval (seconds)</string>
     <string name="subscribe_dialog_keep_subscriptions_hint">keep subscriptions (bool)</string>
     <string name="subscribe_dialog_is_fabric_filtered_hint">is Fabric Filtered (bool)</string>
+    <string name="subscribe_dialog_event_min_hint">Minimum Event Number</string>
 
     <string name="write_dialog_title_text">Write</string>
     <string name="write_dialog_write_btn_text">Write</string>
diff --git a/src/controller/java/CHIPDeviceController-JNI.cpp b/src/controller/java/CHIPDeviceController-JNI.cpp
index db5e47eb46e788..b12d31b7d81ca5 100644
--- a/src/controller/java/CHIPDeviceController-JNI.cpp
+++ b/src/controller/java/CHIPDeviceController-JNI.cpp
@@ -1370,7 +1370,7 @@ JNI_METHOD(jobject, computePaseVerifier)
 
 JNI_METHOD(void, subscribe)
 (JNIEnv * env, jobject self, jlong handle, jlong callbackHandle, jlong devicePtr, jobject attributePathList, jobject eventPathList,
- jint minInterval, jint maxInterval, jboolean keepSubscriptions, jboolean isFabricFiltered, jint imTimeoutMs)
+ jint minInterval, jint maxInterval, jboolean keepSubscriptions, jboolean isFabricFiltered, jint imTimeoutMs, jobject eventMin)
 {
     chip::DeviceLayer::StackLock lock;
     CHIP_ERROR err               = CHIP_NO_ERROR;
@@ -1417,6 +1417,11 @@ JNI_METHOD(void, subscribe)
         attributePaths.release();
     }
 
+    if (eventMin != nullptr)
+    {
+        params.mEventNumber.SetValue(static_cast<chip::EventNumber>(JniReferences::GetInstance().LongToPrimitive(eventMin)));
+    }
+
     if (eventPathList != nullptr)
     {
         SuccessOrExit(err = JniReferences::GetInstance().GetListSize(eventPathList, numEventPaths));
@@ -1473,7 +1478,7 @@ JNI_METHOD(void, subscribe)
 
 JNI_METHOD(void, read)
 (JNIEnv * env, jobject self, jlong handle, jlong callbackHandle, jlong devicePtr, jobject attributePathList, jobject eventPathList,
- jboolean isFabricFiltered, jint imTimeoutMs)
+ jboolean isFabricFiltered, jint imTimeoutMs, jobject eventMin)
 {
     chip::DeviceLayer::StackLock lock;
     CHIP_ERROR err = CHIP_NO_ERROR;
@@ -1502,6 +1507,11 @@ JNI_METHOD(void, read)
     params.mIsFabricFiltered = (isFabricFiltered != JNI_FALSE);
     params.mTimeout          = imTimeoutMs != 0 ? System::Clock::Milliseconds32(imTimeoutMs) : System::Clock::kZero;
 
+    if (eventMin != nullptr)
+    {
+        params.mEventNumber.SetValue(static_cast<chip::EventNumber>(JniReferences::GetInstance().LongToPrimitive(eventMin)));
+    }
+
     readClient = Platform::New<app::ReadClient>(app::InteractionModelEngine::GetInstance(), device->GetExchangeManager(),
                                                 callback->mClusterCacheAdapter.GetBufferedCallback(),
                                                 app::ReadClient::InteractionType::Read);
diff --git a/src/controller/java/src/chip/devicecontroller/ChipDeviceController.java b/src/controller/java/src/chip/devicecontroller/ChipDeviceController.java
index c22753ccbaa463..652e53c038bfaa 100644
--- a/src/controller/java/src/chip/devicecontroller/ChipDeviceController.java
+++ b/src/controller/java/src/chip/devicecontroller/ChipDeviceController.java
@@ -578,7 +578,8 @@ public void subscribeToAttributePath(
         maxInterval,
         false,
         false,
-        imTimeoutMs);
+        imTimeoutMs,
+        null);
   }
 
   /**
@@ -616,7 +617,33 @@ public void subscribeToEventPath(
         maxInterval,
         false,
         false,
-        imTimeoutMs);
+        imTimeoutMs,
+        null);
+  }
+
+  public void subscribeToEventPath(
+      SubscriptionEstablishedCallback subscriptionEstablishedCallback,
+      ReportCallback reportCallback,
+      long devicePtr,
+      List<ChipEventPath> eventPaths,
+      int minInterval,
+      int maxInterval,
+      int imTimeoutMs,
+      @Nullable Long eventMin) {
+    ReportCallbackJni jniCallback =
+        new ReportCallbackJni(subscriptionEstablishedCallback, reportCallback, null);
+    subscribe(
+        deviceControllerPtr,
+        jniCallback.getCallbackHandle(),
+        devicePtr,
+        null,
+        eventPaths,
+        minInterval,
+        maxInterval,
+        false,
+        false,
+        imTimeoutMs,
+        eventMin);
   }
 
   /**
@@ -664,7 +691,39 @@ public void subscribeToPath(
         maxInterval,
         keepSubscriptions,
         isFabricFiltered,
-        imTimeoutMs);
+        imTimeoutMs,
+        null);
+  }
+
+  public void subscribeToPath(
+      SubscriptionEstablishedCallback subscriptionEstablishedCallback,
+      ResubscriptionAttemptCallback resubscriptionAttemptCallback,
+      ReportCallback reportCallback,
+      long devicePtr,
+      List<ChipAttributePath> attributePaths,
+      List<ChipEventPath> eventPaths,
+      int minInterval,
+      int maxInterval,
+      boolean keepSubscriptions,
+      boolean isFabricFiltered,
+      int imTimeoutMs,
+      @Nullable Long eventMin) {
+    // TODO: pass resubscriptionAttemptCallback to ReportCallbackJni since jni layer is not ready
+    // for auto-resubscribe
+    ReportCallbackJni jniCallback =
+        new ReportCallbackJni(subscriptionEstablishedCallback, reportCallback, null);
+    subscribe(
+        deviceControllerPtr,
+        jniCallback.getCallbackHandle(),
+        devicePtr,
+        attributePaths,
+        eventPaths,
+        minInterval,
+        maxInterval,
+        keepSubscriptions,
+        isFabricFiltered,
+        imTimeoutMs,
+        eventMin);
   }
 
   /**
@@ -689,7 +748,8 @@ public void readAttributePath(
         attributePaths,
         null,
         true,
-        imTimeoutMs);
+        imTimeoutMs,
+        null);
   }
 
   /**
@@ -711,7 +771,27 @@ public void readEventPath(
         null,
         eventPaths,
         true,
-        imTimeoutMs);
+        imTimeoutMs,
+        null);
+  }
+
+  /** Read the given event path. */
+  public void readEventPath(
+      ReportCallback callback,
+      long devicePtr,
+      List<ChipEventPath> eventPaths,
+      int imTimeoutMs,
+      @Nullable Long eventMin) {
+    ReportCallbackJni jniCallback = new ReportCallbackJni(null, callback, null);
+    read(
+        deviceControllerPtr,
+        jniCallback.getCallbackHandle(),
+        devicePtr,
+        null,
+        eventPaths,
+        true,
+        imTimeoutMs,
+        eventMin);
   }
 
   /**
@@ -739,7 +819,29 @@ public void readPath(
         attributePaths,
         eventPaths,
         isFabricFiltered,
-        imTimeoutMs);
+        imTimeoutMs,
+        null);
+  }
+
+  /** Read the given attribute/event path with isFabricFiltered flag. */
+  public void readPath(
+      ReportCallback callback,
+      long devicePtr,
+      List<ChipAttributePath> attributePaths,
+      List<ChipEventPath> eventPaths,
+      boolean isFabricFiltered,
+      int imTimeoutMs,
+      @Nullable Long eventMin) {
+    ReportCallbackJni jniCallback = new ReportCallbackJni(null, callback, null);
+    read(
+        deviceControllerPtr,
+        jniCallback.getCallbackHandle(),
+        devicePtr,
+        attributePaths,
+        eventPaths,
+        isFabricFiltered,
+        imTimeoutMs,
+        eventMin);
   }
 
   /**
@@ -840,7 +942,8 @@ private native void subscribe(
       int maxInterval,
       boolean keepSubscriptions,
       boolean isFabricFiltered,
-      int imTimeoutMs);
+      int imTimeoutMs,
+      @Nullable Long eventMin);
 
   private native void read(
       long deviceControllerPtr,
@@ -849,7 +952,8 @@ private native void read(
       List<ChipAttributePath> attributePaths,
       List<ChipEventPath> eventPaths,
       boolean isFabricFiltered,
-      int imTimeoutMs);
+      int imTimeoutMs,
+      @Nullable Long eventMin);
 
   private native void write(
       long deviceControllerPtr,