arithefirst/svchat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: Cassandra message sorting issues

Browse Source
This commit is contained in:
April Hall 2025-01-11 15:08:51 -05:00
parent 6e825fd589
commit 016813dd56
Signed by: arithefirst
GPG Key ID: 4508A15C4DB91C5B
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/lib/server/db/index.ts
View File

@ -28,14 +28,17 @@ async function storeMessage(client: cassandra.Client, channelName: string, conte
async function getMessages(client: cassandra.Client, channelName: string, limit: number) { async function getMessages(client: cassandra.Client, channelName: string, limit: number) {
try { try {
const res = await client.execute(`SELECT * FROM channels.channel_${channelName} LIMIT ${limit}`); const res = await client.execute(`SELECT * FROM channels.channel_${channelName}`);
// We have to sort the rows within the function instead of an ORDER BY // We have to sort the rows within the function instead of an ORDER BY
// because of a limitation within Cassandra requiring a partition key // because of a limitation within Cassandra requiring a partition key
// to be specified by EQ or IN when using ORDER BY // to be specified by EQ or IN when using ORDER BY
res.rows.sort((a, b) => a.timestamp - b.timestamp); res.rows.sort((a, b) => a.timestamp - b.timestamp);
return res.rows;
// For the same reason as above, we have to apply the limit manually
// as well, because if we only query 5, but they're not properly sorted,
// it will only return the first 5 instead of the last 5
return res.rows.slice(-limit);
} catch (e) { } catch (e) {
// @ts-expect-error I don't like this thing yelling at me // @ts-expect-error I don't like this thing yelling at me
console.log(`Error fetching messages: ${e.message}`); console.log(`Error fetching messages: ${e.message}`);