cyonjan/WeChatFerry
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Test receive message

Browse Source
This commit is contained in:
Changhua 2024-06-02 16:23:13 +08:00
parent c679be366f
commit e217f35bdf
2 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
WeChatFerry/spy/receive_msg.cpp
View File

@ -80,7 +80,7 @@ void ListenMessage()
LOG_WARN("gIsListening || (g_WeChatWinDllAddr == 0)"); LOG_WARN("gIsListening || (g_WeChatWinDllAddr == 0)");
return; return;
} }
funcRecvMsg = (funcRecvMsg_t)(g_WeChatWinDllAddr + g_WxCalls.recvMsg.call); funcRecvMsg = (funcRecvMsg_t)(g_WeChatWinDllAddr + 0x2206570); // TODO: Fix me
status = MH_Initialize(); status = MH_Initialize();
if (status != MH_OK) { if (status != MH_OK) {
@ -88,13 +88,13 @@ void ListenMessage()
return; return;
} }
status = MH_CreateHook(&funcRecvMsg, &DispatchMsg, reinterpret_cast<LPVOID *>(&realRecvMsg)); status = MH_CreateHook(funcRecvMsg, &DispatchMsg, reinterpret_cast<LPVOID *>(&realRecvMsg));
if (status != MH_OK) { if (status != MH_OK) {
LOG_ERROR("MH_CreateHook failed: {}", to_string(status)); LOG_ERROR("MH_CreateHook failed: {}", to_string(status));
return; return;
} }
status = MH_EnableHook(&funcRecvMsg); status = MH_EnableHook(funcRecvMsg);
if (status != MH_OK) { if (status != MH_OK) {
LOG_ERROR("MH_EnableHook failed: {}", to_string(status)); LOG_ERROR("MH_EnableHook failed: {}", to_string(status));
return; return;
@ -110,7 +110,7 @@ void UnListenMessage()
return; return;
} }
status = MH_DisableHook(&funcRecvMsg); status = MH_DisableHook(funcRecvMsg);
if (status != MH_OK) { if (status != MH_OK) {
LOG_ERROR("MH_DisableHook failed: {}", to_string(status)); LOG_ERROR("MH_DisableHook failed: {}", to_string(status));
return; return;
@ -125,6 +125,10 @@ void UnListenMessage()
gIsListening = false; gIsListening = false;
} }
void ListenPyq() { }
void UnListenPyq() { }
#if 0 #if 0
// static DWORD reg_buffer = 0; // static DWORD reg_buffer = 0;
// static DWORD recvMsgHookAddr = 0; // static DWORD recvMsgHookAddr = 0;

5
WeChatFerry/spy/rpc_server.cpp
View File

@ -426,7 +426,7 @@ bool func_forward_msg(uint64_t id, char *receiver, uint8_t *out, size_t *len)
return true; return true;
} }
#endif
static void PushMessage() static void PushMessage()
{ {
static uint8_t buffer[G_BUF_SIZE] = { 0 }; static uint8_t buffer[G_BUF_SIZE] = { 0 };
@ -543,6 +543,7 @@ bool func_disable_recv_txt(uint8_t *out, size_t *len)
return true; return true;
} }
#if 0
bool func_exec_db_query(char *db, char *sql, uint8_t *out, size_t *len) bool func_exec_db_query(char *db, char *sql, uint8_t *out, size_t *len)
{ {
Response rsp = Response_init_default; Response rsp = Response_init_default;
@ -907,7 +908,6 @@ static bool dispatcher(uint8_t *in, size_t in_len, uint8_t *out, size_t *out_len
ret = func_forward_msg(req.msg.fm.id, req.msg.fm.receiver, out, out_len); ret = func_forward_msg(req.msg.fm.id, req.msg.fm.receiver, out, out_len);
break; break;
} }
#if 0
case Functions_FUNC_SEND_XML: { case Functions_FUNC_SEND_XML: {
ret = func_send_xml(req.msg.xml, out, out_len); ret = func_send_xml(req.msg.xml, out, out_len);
break; break;
@ -925,6 +925,7 @@ static bool dispatcher(uint8_t *in, size_t in_len, uint8_t *out, size_t *out_len
ret = func_disable_recv_txt(out, out_len); ret = func_disable_recv_txt(out, out_len);
break; break;
} }
#if 0
case Functions_FUNC_EXEC_DB_QUERY: { case Functions_FUNC_EXEC_DB_QUERY: {
ret = func_exec_db_query(req.msg.query.db, req.msg.query.sql, out, out_len); ret = func_exec_db_query(req.msg.query.db, req.msg.query.sql, out, out_len);
break; break;