export default query(
async ({ db }, opts) => {
const results = await db
.query('messages')
.paginate(opts);
const page = await Promise.all(
results.page.map(async (item) => {
return {
...item,
focus: (await db.get(item.focusId)) as Doc<'focuses'>,
fromUser: (await db.get(item.fromUserId)) as Doc<'users'>,
};
}),
);
return {
isDone: results.isDone,
continueCursor: results.continueCursor,
page,
};
},
);
export default query(
async ({ db }, opts) => {
const results = await db
.query('messages')
.paginate(opts);
const page = await Promise.all(
results.page.map(async (item) => {
return {
...item,
focus: (await db.get(item.focusId)) as Doc<'focuses'>,
fromUser: (await db.get(item.fromUserId)) as Doc<'users'>,
};
}),
);
return {
isDone: results.isDone,
continueCursor: results.continueCursor,
page,
};
},
);