MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-10-03 06:08:52 +02:00
Code Issues Releases Wiki Activity

modules/client/profile: Plug in remote user profile query; minor reorg.

Browse source
This commit is contained in:
Jason Volk 2018-02-25 00:29:44 -08:00
parent 619a5a6a96
commit 8c24d590a4
1 changed files with 101 additions and 36 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

137
modules/client/profile.cc
View file

@ -29,43 +29,12 @@ profile_resource
static resource::response
get__profile_full(client &client,
const resource::request &request,
const m::room user_room)
{
const m::room::state state
{
user_room
};
const m::room &user_room);
std::vector<json::member> members;
state.for_each("ircd.profile", [&members]
(const m::event &event)
{
const auto &key
{
at<"state_key"_>(event)
};
const auto &value
{
at<"content"_>(event).at("text")
};
members.emplace_back(key, value);
});
const json::strung response
{
data(members), data(members) + size(members)
};
return resource::response
{
client, json::object
{
response
}
};
}
static resource::response
get__profile_remote(client &client,
const resource::request &request,
const m::user &user);
resource::response
get__profile(client &client,
@ -92,6 +61,9 @@ get__profile(client &client,
user.room_id()
};
if(!my(user) && !exists(user_room_id))
return get__profile_remote(client, request, user);
const m::room user_room
{
user_room_id
@ -131,6 +103,99 @@ method_get
profile_resource, "GET", get__profile
};
resource::response
get__profile_full(client &client,
const resource::request &request,
const m::room &user_room)
{
const m::room::state state
{
user_room
};
std::vector<json::member> members;
state.for_each("ircd.profile", [&members]
(const m::event &event)
{
const auto &key
{
at<"state_key"_>(event)
};
const auto &value
{
at<"content"_>(event).at("text")
};
members.emplace_back(key, value);
});
const json::strung response
{
data(members), data(members) + size(members)
};
return resource::response
{
client, json::object
{
response
}
};
}
resource::response
get__profile_remote(client &client,
const resource::request &request,
const m::user &user)
{
//TODO: XXX cache strat user's room
const string_view &field
{
request.parv[1]
};
const unique_buffer<mutable_buffer> buf
{
64_KiB
};
m::v1::query::opts opts;
opts.remote = user.user_id.host();
m::v1::query::profile federation_request
{
user.user_id, field, buf, opts
};
//TODO: conf
if(federation_request.wait(seconds(8)) == ctx::future_status::timeout)
{
cancel(federation_request);
return resource::response
{
client, http::REQUEST_TIMEOUT
};
}
const http::code &code
{
federation_request.get()
};
const json::object &response
{
federation_request
};
//TODO: cache into a room with ttl
return resource::response
{
client, response
};
}
resource::response
put__profile(client &client,
const resource::request &request)