cory/tildefriends
5
6
Fork 2
Code Issues 28 Pull Requests Actions Releases 39 Wiki Activity

ssb: Log all the query timing.
Some checks failed
Build Tilde Friends / Build-All (push) Has been cancelled
Details

Browse Source
This commit is contained in:
Cory McWilliams
2025-11-16 11:59:18 -05:00
parent bb75edfd42
commit 3c1f60b62d
3 changed files with 8 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
apps/ssb.json
View File

@@ -1,5 +1,5 @@
{ {
"type": "tildefriends-app", "type": "tildefriends-app",
"emoji": "🦀", "emoji": "🦀",
"previous": "&Gic1e3jOZ7z5131jSCclbFXRpjyu8JlWJrjE7Fvn5dc=.sha256" "previous": "&6mBMHVKDgkYigy+PnHmii8AJW68ezgCtk5vuQ+HwN7s=.sha256"
} }

3
apps/ssb/app.js
View File

@@ -52,10 +52,13 @@ tfrpc.register(async function closeConnection(id) {
await ssb.closeConnection(id); await ssb.closeConnection(id);
}); });
tfrpc.register(async function query(sql, args) { tfrpc.register(async function query(sql, args) {
let start = new Date();
let result = []; let result = [];
await ssb.sqlAsync(sql, args, function callback(row) { await ssb.sqlAsync(sql, args, function callback(row) {
result.push(row); result.push(row);
}); });
let end = new Date();
print((end - start) / 1000, sql.replaceAll(/\s+/g, ' ').trim());
return result; return result;
}); });
tfrpc.register(async function appendMessage(id, message) { tfrpc.register(async function appendMessage(id, message) {

16
apps/ssb/tf-app.js
View File

@@ -403,14 +403,6 @@ class TfElement extends LitElement {
return [cache.latest, cache.messages]; return [cache.latest, cache.messages];
} }
async query_timed(sql, args) {
let start = new Date();
let result = await tfrpc.rpc.query(sql, args);
let end = new Date();
console.log((end - start) / 1000, sql.replaceAll(/\s+/g, ' ').trim());
return result;
}
async group_private_messages(messages) { async group_private_messages(messages) {
let groups = {}; let groups = {};
let result = await this.decrypt( let result = await this.decrypt(
@@ -452,7 +444,7 @@ class TfElement extends LitElement {
]; ];
let channels = ( let channels = (
await Promise.all([ await Promise.all([
this.query_timed( tfrpc.rpc.query(
` `
SELECT channels.value AS channel, MAX(messages.rowid) AS rowid FROM messages SELECT channels.value AS channel, MAX(messages.rowid) AS rowid FROM messages
JOIN json_each(?1) AS channels ON messages.content ->> 'channel' = channels.value JOIN json_each(?1) AS channels ON messages.content ->> 'channel' = channels.value
@@ -465,7 +457,7 @@ class TfElement extends LitElement {
`, `,
k_args k_args
), ),
this.query_timed( tfrpc.rpc.query(
` `
SELECT channels.value AS channel, MAX(messages.rowid) AS rowid FROM messages SELECT channels.value AS channel, MAX(messages.rowid) AS rowid FROM messages
JOIN messages_refs ON messages.id = messages_refs.message JOIN messages_refs ON messages.id = messages_refs.message
@@ -479,7 +471,7 @@ class TfElement extends LitElement {
`, `,
k_args k_args
), ),
this.query_timed( tfrpc.rpc.query(
` `
SELECT '' AS channel, MAX(messages.rowid) AS rowid FROM messages SELECT '' AS channel, MAX(messages.rowid) AS rowid FROM messages
JOIN json_each(?2) AS following ON messages.author = following.value JOIN json_each(?2) AS following ON messages.author = following.value
@@ -490,7 +482,7 @@ class TfElement extends LitElement {
`, `,
k_args k_args
), ),
this.query_timed( tfrpc.rpc.query(
` `
SELECT '@' AS channel, MAX(messages.rowid) AS rowid FROM messages_fts(?3) SELECT '@' AS channel, MAX(messages.rowid) AS rowid FROM messages_fts(?3)
JOIN messages ON messages.rowid = messages_fts.rowid JOIN messages ON messages.rowid = messages_fts.rowid