From 176262b98dbcbc65bfd134d81f16dda0a4787182 Mon Sep 17 00:00:00 2001
From: hxy7yx <1595670487@qq.com>
Date: Wed, 18 Sep 2024 15:52:09 +0800
Subject: [PATCH] fix(read paginate):handle only_write tags

---
 src/adapter/driver/driver.c | 7 +++++++
 src/base/group.c            | 4 ++--
 2 files changed, 9 insertions(+), 2 deletions(-)

diff --git a/src/adapter/driver/driver.c b/src/adapter/driver/driver.c
index ea87316e..3809295e 100644
--- a/src/adapter/driver/driver.c
+++ b/src/adapter/driver/driver.c
@@ -2186,6 +2186,13 @@ static void read_group_paginate(int64_t timestamp, int64_t timeout,
         tag_value.datatag.option      = tag->option;
         memcpy(tag_value.datatag.meta, tag->meta, NEU_TAG_META_LENGTH);
 
+        if (tag->attribute == NEU_ATTRIBUTE_WRITE) {
+            tag_value.value.type         = NEU_TYPE_STRING;
+            tag_value.value.value.str[0] = 0;
+            utarray_push_back(tag_values, &tag_value);
+            continue;
+        }
+
         if (neu_driver_cache_meta_get(cache, group, tag->name, &value,
                                       tag_value.metas,
                                       NEU_TAG_META_SIZE) != 0) {
diff --git a/src/base/group.c b/src/base/group.c
index 344edd0b..8254c951 100644
--- a/src/base/group.c
+++ b/src/base/group.c
@@ -315,8 +315,8 @@ UT_array *neu_group_query_read_tag_paginate(neu_group_t *group,
     };
 
     pthread_mutex_lock(&group->mtx);
-    array = filter_tags_by_page(group->tags, is_readable_and_match_query, &q,
-                                current_page, page_size, total_count);
+    array = filter_tags_by_page(group->tags, match_query, &q, current_page,
+                                page_size, total_count);
     pthread_mutex_unlock(&group->mtx);
 
     return array;