Skip to content

Commit c9d8f83

Browse files
committed
user and msg
1 parent 188d36f commit c9d8f83

File tree

3 files changed

+597
-51
lines changed

3 files changed

+597
-51
lines changed

msg_controller.cc

Lines changed: 33 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -18,32 +18,33 @@ void chat(const HttpRequestPtr &req, std::function<void(const HttpResponsePtr &)
1818
callback(HttpResponse::newHttpResponse());
1919
return;
2020
}
21+
2122
Json::FastWriter writer;
2223
auto res = HttpResponse::newHttpResponse();
2324
res->addHeader("Access-Control-Allow-Origin", "*");
25+
2426
if (jwtVerify(req))
2527
{
2628
std::string sender = jwtDecrypt(req->getHeader("Authorization").substr(7));
2729
std::string content = req_json["content"].asString();
2830
std::string receiver = req_json["receiver"].asString();
2931

3032
sql_addhistory(sender, receiver, content, "0");
31-
3233
std::string msg = req_json["content"].asString();
33-
res_json["code"] = 200;
3434
res_json["message"] = "message Send Success";
35-
auto output = writer.write(res_json);
36-
res->setBody(output);
35+
res_json["code"] = 200;
3736
}
3837
else
3938
{
4039
res_json["message"] = "No Authorization";
41-
res_json["code"] = 401;
40+
res_json["code"] = 401;
4241
}
42+
4343
auto output = writer.write(res_json);
4444
res->setBody(output);
4545
callback(res);
4646
}
47+
4748
// get message history or new message
4849
void check(const HttpRequestPtr &req, std::function<void(const HttpResponsePtr &)> &&callback)
4950
{
@@ -54,31 +55,33 @@ void check(const HttpRequestPtr &req, std::function<void(const HttpResponsePtr &
5455
Json::FastWriter writer;
5556
auto res = HttpResponse::newHttpResponse();
5657
res->addHeader("Access-Control-Allow-Origin", "*");
58+
5759
if (jwtVerify(req))
5860
{
5961
me = jwtDecrypt(req->getHeader("Authorization").substr(7));
60-
res_json["message"] = sql_find_my_msg(me,check_type);
62+
res_json["message"] = sql_find_my_msg(me, check_type);
6163
res_json["code"] = 200;
62-
6364
}
6465
else
6566
{
6667
res_json["message"] = "No Authorization";
6768
res_json["code"] = 401;
68-
6969
}
70+
7071
auto output = writer.write(res_json);
7172
res->setBody(output);
7273

7374
callback(res);
7475
}
76+
7577
// request new friend or cancel request
7678
void friend_operation(const HttpRequestPtr &req, std::function<void(const HttpResponsePtr &)> &&callback)
7779
{
7880
auto res = HttpResponse::newHttpResponse();
7981
Json::Value res_json;
8082
Json::FastWriter writer;
8183
res->addHeader("Access-Control-Allow-Origin", "*");
84+
8285
if (jwtVerify(req))
8386
{
8487
std::string sender = jwtDecrypt(req->getHeader("Authorization").substr(7));
@@ -92,34 +95,36 @@ void friend_operation(const HttpRequestPtr &req, std::function<void(const HttpRe
9295
sql_addrequest(sender, receiver);
9396
res_json["code"] = 200;
9497
res_json["message"] = "Operation Success";
95-
//res->setBody("Success");
98+
// res->setBody("Success");
9699
}
97100
else
98101
{
99102
res_json["code"] = 404;
100103
res_json["message"] = "No this user";
101-
//res->setBody("No this body");
104+
// res->setBody("No this body");
102105
}
103-
//res->setBody("No this body");
106+
// res->setBody("No this body");
104107
}
105108
else
106109
{
107110
sql_delete_operation(sender, receiver);
108111
res_json["code"] = 200;
109112
res_json["message"] = " Delete Operation Success";
110-
//res->setBody("Success");
113+
// res->setBody("Success");
111114
}
112115
}
113116
else
114117
{
115118
res_json["code"] = 401;
116119
res_json["message"] = "No Authorization ";
117-
//res->setBody("No Authorization");
120+
// res->setBody("No Authorization");
118121
}
122+
119123
auto output = writer.write(res_json);
120124
res->setBody(output);
121125
callback(res);
122126
}
127+
123128
// handle new friend request
124129
void request_processing(const HttpRequestPtr &req, std::function<void(const HttpResponsePtr &)> &&callback)
125130
{
@@ -130,47 +135,51 @@ void request_processing(const HttpRequestPtr &req, std::function<void(const Http
130135

131136
if (jwtVerify(req))
132137
{
133-
134138
std::string receiver = jwtDecrypt(req->getHeader("Authorization").substr(7));
135139
std::string sender = req->getParameter("username");
136140
std::string attitude = req->getParameter("info");
137141
sql_process_request(sender, receiver, attitude);
138-
//res->setBody("Success");
139-
res_json["code"]=200;
140-
res_json["message"]="Friends "+attitude+" Success";
142+
// res->setBody("Success");
143+
res_json["code"] = 200;
144+
res_json["message"] = "Friends " + attitude + " Success";
141145
}
142146
else
143147
{
144-
//res->setBody("No Authorization");
145-
res_json["code"]=401;
146-
res_json["message"]="No Authorization";
148+
// res->setBody("No Authorization");
149+
res_json["code"] = 401;
150+
res_json["message"] = "No Authorization";
147151
}
152+
148153
auto output = writer.write(res_json);
149154
res->setBody(output);
150155

151156
callback(res);
152157
}
158+
153159
// get chat info
154160
void info(const HttpRequestPtr &req, std::function<void(const HttpResponsePtr &)> &&callback)
155161
{
156162
Json::Value res_json;
157163
Json::Reader reader;
158164
std::string me, who_send_me;
159165
Json::FastWriter writer;
166+
160167
auto res = HttpResponse::newHttpResponse();
161168
res->addHeader("Access-Control-Allow-Origin", "*");
169+
162170
if (jwtVerify(req))
163171
{
164-
res_json["code"]=200;
172+
res_json["code"] = 200;
165173
me = jwtDecrypt(req->getHeader("Authorization").substr(7));
166174
res_json["message"] = get_my_info(me);
167175
}
168176
else
169177
{
170-
//res->setBody("No Authorization");
171-
res_json["code"]=401;
172-
res_json["message"]="No Authorization";
178+
// res->setBody("No Authorization");
179+
res_json["code"] = 401;
180+
res_json["message"] = "No Authorization";
173181
}
182+
174183
auto output = writer.write(res_json);
175184
res->setBody(output);
176185
callback(res);

0 commit comments

Comments
 (0)