Page Menu
Home
Phorge
Search
Configure Global Search
Log In
Files
F2578368
client-model.cpp
No One
Temporary
Actions
Download File
Edit File
Delete File
View Transforms
Subscribe
Award Token
Flag For Later
Size
3 KB
Referenced Files
None
Subscribers
None
client-model.cpp
View Options
/*
* Copyright (C) 2020 Tusooa Zhu <tusooa@vista.aero>
*
* This file is part of libkazv.
*
* libkazv is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as
* published by the Free Software Foundation, either version 3 of the
* License, or (at your option) any later version.
*
* libkazv is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with libkazv. If not, see <https://www.gnu.org/licenses/>.
*/
#include
<lager/util.hpp>
#include
<lager/context.hpp>
#include
<functional>
#include
<immer/flex_vector_transient.hpp>
#include
"client-model.hpp"
#include
"actions/states.hpp"
#include
"actions/auth.hpp"
#include
"actions/membership.hpp"
#include
"actions/paginate.hpp"
#include
"actions/send.hpp"
#include
"actions/states.hpp"
#include
"actions/sync.hpp"
#include
"actions/ephemeral.hpp"
namespace
Kazv
{
auto
ClientModel
::
update
(
ClientModel
m
,
Action
a
)
->
Result
{
return
lager
::
match
(
std
::
move
(
a
))(
[
&
](
Error
::
Action
a
)
->
Result
{
m
.
error
=
Error
::
update
(
m
.
error
,
a
);
return
{
std
::
move
(
m
),
lager
::
noop
};
},
[
&
](
RoomListAction
a
)
->
Result
{
m
.
roomList
=
RoomListModel
::
update
(
std
::
move
(
m
.
roomList
),
a
);
return
{
std
::
move
(
m
),
lager
::
noop
};
},
[
&
](
auto
a
)
->
decltype
(
updateClient
(
m
,
a
))
{
return
updateClient
(
m
,
a
);
},
#define RESPONSE_FOR(_jobId) \
if (r.jobId() == #_jobId) { \
return processResponse(m, _jobId##Response{std::move(r)}); \
}
[
&
](
ProcessResponseAction
a
)
->
Result
{
auto
r
=
std
::
move
(
a
.
response
);
// auth
RESPONSE_FOR
(
Login
);
// paginate
RESPONSE_FOR
(
GetRoomEvents
);
// sync
RESPONSE_FOR
(
Sync
);
// membership
RESPONSE_FOR
(
CreateRoom
);
RESPONSE_FOR
(
InviteUser
);
RESPONSE_FOR
(
JoinRoomById
);
RESPONSE_FOR
(
JoinRoom
);
RESPONSE_FOR
(
LeaveRoom
);
RESPONSE_FOR
(
ForgetRoom
);
// send
RESPONSE_FOR
(
SendMessage
);
// states
RESPONSE_FOR
(
GetRoomState
);
RESPONSE_FOR
(
SetRoomStateWithKey
);
// ephemeral
RESPONSE_FOR
(
SetTyping
);
RESPONSE_FOR
(
PostReceipt
);
RESPONSE_FOR
(
SetReadMarker
);
m
.
addTrigger
(
UnrecognizedResponse
{
r
});
return
{
m
,
lager
::
noop
};
}
#undef RESPONSE_FOR
);
}
}
File Metadata
Details
Attached
Mime Type
text/x-c++
Expires
Wed, Jun 25, 2:22 AM (18 h, 51 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
235122
Default Alt Text
client-model.cpp (3 KB)
Attached To
Mode
rL libkazv
Attached
Detach File
Event Timeline
Log In to Comment