Page MenuHomePhorge
Files F13520345

client.cpp
No OneTemporary
Actions

Size
3 KB
Referenced Files
None
Subscribers
None

client.cpp
View Options

#include <lager/util.hpp>
#include <lager/context.hpp>
#include <functional>
#include "client.hpp"
#include "csapi/login.hpp"
#include "types.hpp"
#include "debug.hpp"
namespace Kazv
{
lager::effect<Client::Action> loginEffect(Client::LoginAction a)
{
return
[=](auto &&ctx) {
LoginJob job(a.serverUrl,
"m.login.password"s, // type
UserIdentifier{ "m.id.user"s, json{{"user", a.username}} }, // identifier
a.password,
{}, // token, not used
{}, // device id, not used
a.deviceName.value_or("libkazv"));
auto res = job.fetch();
dbgClient << "Result validity: " << res.valid() << std::endl;
auto r = res.get();
if (job.success(r)) {
dbgClient << "Job success" << std::endl;
const json &j = jsonBody(r).get();
try {
std::string serverUrl = j.contains("well_known")
? j.at("well_known").at("m.homeserver").at("base_url").get<std::string>()
: a.serverUrl;
ctx.dispatch(Client::LoadUserInfoAction{
serverUrl,
j.at("user_id"),
j.at("access_token"),
j.at("device_id"),
/* loggedIn = */ true
});
} catch (const json::out_of_range &e) {
dbgClient << "Json error: " << e.what() << std::endl;
ctx.dispatch(Error::SetErrorAction{e.what()});
}
}
};
}
lager::effect<Client::Action> logoutEffect(Client::LogoutAction a)
{
return
[=](auto &&ctx) {
ctx.dispatch(Client::LoadUserInfoAction{
""s,
""s,
""s,
""s,
/* loggedIn = */ true
});
};
}
auto Client::update(Client m, Action a) -> Result
{
dbgClient << "Client::update()" << std::endl;
return
std::visit(lager::visitor{
[=](Error::Action a) mutable -> Result {
m.error = Error::update(m.error, a);
return {std::move(m), lager::noop};
},
[=](LoginAction a) mutable -> Result {
return {std::move(m), loginEffect(std::move(a))};
},
[=](LogoutAction a) mutable -> Result {
return {std::move(m), logoutEffect(std::move(a))};
},
[=](LoadUserInfoAction a) mutable -> Result {
dbgClient << "LoadUserInfoAction: " << a.userId << std::endl;
m.serverUrl = a.serverUrl;
m.userId = a.userId;
m.token = a.token;
m.deviceId = a.deviceId;
m.loggedIn = a.loggedIn;
return { std::move(m),
[](auto &&ctx) {
ctx.dispatch(Error::SetErrorAction{Error::NoError{}});
}
};
},
}, std::move(a));
}
}

File Metadata

Mime Type
text/x-c++
Expires
Sun, Dec 7, 7:31 PM (1 d, 14 h)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
700130
Default Alt Text
client.cpp (3 KB)

Event Timeline