Dekescordes/spacebar
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'master' into feat/refactorIdentify

Browse Source
This commit is contained in:
Madeline 2023-07-28 10:34:36 +10:00
commit a5a6321156
No known key found for this signature in database
GPG Key ID: 80D25DA3BCB24281
1 changed files with 19 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
src/api/routes/channels/#channel_id/messages/index.ts
View File

@ -119,25 +119,27 @@ router.get(
}; };
let messages: Message[]; let messages: Message[];
if (after) {
if (BigInt(after) > BigInt(Snowflake.generate())) if (around) {
return res.status(422);
query.where.id = MoreThan(after);
messages = await Message.find(query);
} else if (before) {
if (BigInt(before) < BigInt(req.params.channel_id))
return res.status(422);
query.where.id = LessThan(before);
messages = await Message.find(query);
} else if (around) {
query.take = Math.floor(limit / 2); query.take = Math.floor(limit / 2);
query.where.id = LessThan(around); const [right, left] = await Promise.all([
const messages_before = await Message.find(query); Message.find({ ...query, where: { id: LessThan(around) } }),
query.where.id = MoreThan(around); Message.find({ ...query, where: { id: MoreThan(around) } }),
const messages_after = await Message.find(query); ]);
messages = messages_before.concat(messages_after); right.push(...left);
messages = right;
} else { } else {
throw new HTTPError("after, around or before must be present", 422); if (after) {
if (BigInt(after) > BigInt(Snowflake.generate()))
return res.status(422);
query.where.id = MoreThan(after);
} else if (before) {
if (BigInt(before) < BigInt(Snowflake.generate()))
return res.status(422);
query.where.id = LessThan(before);
}
messages = await Message.find(query);
} }
const endpoint = Config.get().cdn.endpointPublic; const endpoint = Config.get().cdn.endpointPublic;