Page MenuHomePhorge
Files F2697516

paginate.cpp
No OneTemporary
Actions

Size
3 KB
Referenced Files
None
Subscribers
None

paginate.cpp
View Options

/*
* This file is part of libkazv.
* SPDX-FileCopyrightText: 2020 Tusooa Zhu
* SPDX-License-Identifier: AGPL-3.0-or-later
*/
#include <libkazv-config.hpp>
// eager requires tuplify but did not include it.
// This is a bug.
#include <zug/tuplify.hpp>
#include <zug/transducer/eager.hpp>
#include <zug/into.hpp>
#include <lager/util.hpp>
#include <types.hpp>
#include <debug.hpp>
#include <cursorutil.hpp>
#include <status-utils.hpp>
#include "paginate.hpp"
namespace Kazv
{
ClientResult updateClient(ClientModel m, PaginateTimelineAction a)
{
auto roomId = a.roomId;
auto room = m.roomList.at(roomId);
if (! room.timelineGaps.find(a.fromEventId)) {
kzo.client.dbg() << "There is no such gap at " << a.fromEventId << std::endl;
return { m, simpleFail };
}
auto paginateBackToken = room.timelineGaps[a.fromEventId];
auto job = m.job<GetRoomEventsJob>().make(
roomId,
"b"s, // dir
paginateBackToken, // from
std::nullopt, // to
a.limit).withData(json{{"roomId", roomId},
{"gapEventId", a.fromEventId}});
m.addJob(std::move(job));
return { m, lager::noop };
}
ClientResult processResponse(ClientModel m, GetRoomEventsResponse r)
{
auto roomId = r.dataStr("roomId");
auto gapEventId = r.dataStr("gapEventId");
if (! r.success()) {
kzo.client.dbg() << "Get room events failed" << std::endl;
m.addTrigger(PaginateFailed{roomId});
return { m, failWithResponse(r) };
}
auto paginateBackToken = r.end();
auto chunk = r.chunk();
try {
// kzo.client.dbg() << "We got " << chunk.size() << " events here" << std::endl;
auto room = m.roomList.at(roomId);
// The timeline from paginate backwards is returned
// in reversed order, so restore the order.
auto events = intoImmer(EventList{}, zug::reversed, chunk);
AddToTimelineAction action
{events, paginateBackToken, std::nullopt, gapEventId};
m.roomList = RoomListModel::update(
std::move(m.roomList),
UpdateRoomAction{roomId, action});
m.roomList = RoomListModel::update(
std::move(m.roomList),
UpdateRoomAction{roomId, MaybeAddStateEventsAction{
intoImmer(EventList{},
zug::filter(&Event::isState),
events)
}});
// r.state() contains state events prior to the timeline
// we add them later than the timeline, so the states in the
// timeline takes priority
m.roomList = RoomListModel::update(
std::move(m.roomList),
UpdateRoomAction{roomId, MaybeAddStateEventsAction{
r.state()
}});
m.addTrigger(PaginateSuccessful{roomId});
return { std::move(m), lager::noop };
} catch (const std::out_of_range &e) {
// Ignore it, the client model is modified
// such that it knows nothing about this room.
// May happen in debugger.
return { std::move(m), simpleFail };
}
}
}

File Metadata

Mime Type
text/x-c++
Expires
Fri, Jul 18, 6:48 AM (5 h, 27 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
261364
Default Alt Text
paginate.cpp (3 KB)

Event Timeline