From cebdc3f469bce73d704972c89fa9d40f670f5623 Mon Sep 17 00:00:00 2001
From: fengzero <fengzero@fengzero.com>
Date: Thu, 21 Apr 2022 02:53:20 +0000
Subject: [PATCH] chore(adapter): add write_response interface

---
 include/neuron/adapter.h    | 10 ++++++----
 include/neuron/errcodes.h   |  4 ++++
 src/adapter/driver/driver.c | 33 ++++++++++++++++++++++++++++-----
 3 files changed, 38 insertions(+), 9 deletions(-)

diff --git a/include/neuron/adapter.h b/include/neuron/adapter.h
index 82f5898d..7034f3b2 100644
--- a/include/neuron/adapter.h
+++ b/include/neuron/adapter.h
@@ -93,13 +93,15 @@ typedef struct adapter_callbacks {
     int (*response)(neu_adapter_t *adapter, neu_response_t *resp);
     int (*event_notify)(neu_adapter_t *adapter, neu_event_notify_t *event);
 
-    void (*set_link_status)(neu_adapter_t *        adapter,
-                            neu_node_link_status_e link_status);
+    void (*link_status)(neu_adapter_t *        adapter,
+                        neu_node_link_status_e link_status);
 
     union {
         struct {
-            int (*update)(neu_adapter_t *adapter, const char *name,
-                          neu_dvalue_t value);
+            void (*update)(neu_adapter_t *adapter, const char *name,
+                           neu_dvalue_t value);
+            void (*write_response)(neu_adapter_t *adapter, uint32_t req_id,
+                                   neu_error error);
         } driver;
     };
 } adapter_callbacks_t;
diff --git a/include/neuron/errcodes.h b/include/neuron/errcodes.h
index 2e4317c3..778a9de9 100644
--- a/include/neuron/errcodes.h
+++ b/include/neuron/errcodes.h
@@ -24,6 +24,10 @@
 extern "C" {
 #endif
 
+#include <stdint.h>
+
+typedef int32_t neu_error;
+
 typedef enum {
     NEU_ERR_SUCCESS = 0,
 
diff --git a/src/adapter/driver/driver.c b/src/adapter/driver/driver.c
index 7b533bad..61b84904 100644
--- a/src/adapter/driver/driver.c
+++ b/src/adapter/driver/driver.c
@@ -62,8 +62,31 @@ static neu_data_val_t *read_group(neu_adapter_driver_t *driver,
 static void load_tags(neu_adapter_driver_t *driver, neu_taggrp_config_t *group,
                       UT_array **tags);
 static void free_tags(UT_array *tags);
+static void update(neu_adapter_t *adapter, const char *name,
+                   neu_dvalue_t value);
+static void write_response(neu_adapter_t *adapter, uint32_t req_id,
+                           neu_error error);
+static void write_response(neu_adapter_t *adapter, uint32_t req_id,
+                           neu_error error)
+{
+    neu_reqresp_write_resp_t data = {
+        .grp_config = NULL,
+        .data_val   = neu_datatag_pack_create(1),
+    };
+    neu_response_t resp = {
+        .req_id    = req_id,
+        .resp_type = NEU_REQRESP_WRITE_RESP,
+        .buf       = &data,
+        .buf_len   = sizeof(neu_reqresp_write_resp_t),
+        .recver_id = 0,
+    };
 
-static int update(neu_adapter_t *adapter, const char *name, neu_dvalue_t value)
+    neu_datatag_pack_add(data.data_val, 0, NEU_DTYPE_ERRORCODE, 0,
+                         (void *) &error);
+    adapter->cb_funs.response(adapter, &resp);
+}
+
+static void update(neu_adapter_t *adapter, const char *name, neu_dvalue_t value)
 {
     neu_adapter_driver_t *driver = (neu_adapter_driver_t *) adapter;
     uint16_t              n_byte = 0;
@@ -104,7 +127,6 @@ static int update(neu_adapter_t *adapter, const char *name, neu_dvalue_t value)
         neu_driver_cache_update(driver->cache, name, 0, n_byte,
                                 value.value.bytes);
     }
-    return 0;
 }
 
 neu_adapter_driver_t *neu_adapter_driver_create(neu_adapter_t *adapter)
@@ -115,9 +137,10 @@ neu_adapter_driver_t *neu_adapter_driver_create(neu_adapter_t *adapter)
     free(adapter);
 
     pthread_mutex_init(&driver->grp_mtx, NULL);
-    driver->cache                         = neu_driver_cache_new();
-    driver->driver_events                 = neu_event_new();
-    driver->adapter.cb_funs.driver.update = update;
+    driver->cache                                 = neu_driver_cache_new();
+    driver->driver_events                         = neu_event_new();
+    driver->adapter.cb_funs.driver.update         = update;
+    driver->adapter.cb_funs.driver.write_response = write_response;
 
     return driver;
 }