From 2e9cf595ee775cb2c420e1fae8dba542cddc6c77 Mon Sep 17 00:00:00 2001
From: Changhua <lichanghua0821@gmail.com>
Date: Mon, 6 Mar 2023 19:41:01 +0800
Subject: [PATCH] Fix duplicated message

---
 spy/rpc_server.cpp | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/spy/rpc_server.cpp b/spy/rpc_server.cpp
index c163ba9..ac7761f 100644
--- a/spy/rpc_server.cpp
+++ b/spy/rpc_server.cpp
@@ -66,7 +66,7 @@ bool func_is_login(uint8_t *out, size_t *len)
 
 bool func_get_self_wxid(uint8_t *out, size_t *len)
 {
-    string wxid = GetSelfWxid();
+    string wxid   = GetSelfWxid();
     Response rsp  = Response_init_default;
     rsp.func      = Functions_FUNC_GET_SELF_WXID;
     rsp.which_msg = Response_str_tag;
@@ -306,6 +306,7 @@ static void PushMessage()
                 rsp.msg.wxmsg.content  = (char *)wxmsg.content.c_str();
                 gMsgQueue.pop();
                 LOG_DEBUG("Recv msg: {}", wxmsg.content);
+                pb_ostream_t stream = pb_ostream_from_buffer(buffer, G_BUF_SIZE);
                 if (!pb_encode(&stream, Response_fields, &rsp)) {
                     LOG_ERROR("Encoding failed: {}", PB_GET_ERROR(&stream));
                     continue;