Skip to content

Commit 9079ca7

Browse files
Merge origin/master
2 parents e7097c2 + 3d0334a commit 9079ca7

File tree

2 files changed

+8
-4
lines changed

2 files changed

+8
-4
lines changed

CHANGELOG.md

+1
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@ BUG FIXES:
1010
BUG FIXES:
1111
* Js Api version 3.28 (Fix bug in auth callbacks)
1212
* Fix bug in auth callbacks
13+
* complete api function getTrackPipeUsers
1314

1415
## v3.1
1516

src/Client_connection.cpp

+7-4
Original file line numberDiff line numberDiff line change
@@ -987,7 +987,7 @@ int Client_connection::track_pipe_users(thread_data* local_buf, char* event_data
987987
}
988988

989989

990-
std::string usersstr("{\"event_name\":\"answer\",\"data\":{");
990+
std::string usersstr("{\"event_name\":\"answer\",\"data\":{\"users\":[");
991991

992992
char strtmp[200];
993993
TagLoger::log(Log_ClientServer, 0, "track_pipe_users pipe:%s\n", name);
@@ -1003,8 +1003,9 @@ int Client_connection::track_pipe_users(thread_data* local_buf, char* event_data
10031003
CP<Client_connection> r = tcpServer <Client_connection>::instance()->get(conection_id);
10041004
if(r)
10051005
{
1006+
// @todo отдавать всем не uuid а его солёный хеш.
10061007
bzero(strtmp, 200);
1007-
snprintf(strtmp, 200, "{\"user_id\":\"%d\",\"uuid\":\"%s\"}", r->web_user_id, r->web_user_uuid);
1008+
snprintf(strtmp, 200, "{\"user_id\":%d,\"uuid\":\"%s\"}", r->web_user_id, r->web_user_uuid);
10081009
usersstr.append(strtmp);
10091010
}
10101011

@@ -1016,13 +1017,15 @@ int Client_connection::track_pipe_users(thread_data* local_buf, char* event_data
10161017
}
10171018
}
10181019

1019-
usersstr.append("},\"marker\":\"").append(marker).append("\"");
1020+
usersstr.append("]}}");
10201021

10211022
std::string rdname("_answer_to_");
10221023
rdname.append(name);
1024+
std::string addData("\"marker\":\"");
1025+
addData.append(marker).append("\"");
10231026

10241027
TagLoger::log(Log_ClientServer, 0, "answer:%s\n", usersstr.data());
1025-
if(message(local_buf, base64_encode( (const char*)usersstr.data()).data() , rdname.data()) < 0)
1028+
if(message(local_buf, base64_encode( (const char*)usersstr.data()).data() , rdname.data(), MESSAGE_TEXT, addData.data()) < 0)
10261029
{
10271030
return -1;
10281031
}

0 commit comments

Comments
 (0)