This commit is contained in:
@ -367,9 +367,10 @@ class TfElement extends LitElement {
|
|||||||
'"' + this.whoami.replace('"', '""') + '"',
|
'"' + this.whoami.replace('"', '""') + '"',
|
||||||
this.whoami,
|
this.whoami,
|
||||||
];
|
];
|
||||||
let channels = (await Promise.all([
|
let channels = (
|
||||||
this.query_timed(
|
await Promise.all([
|
||||||
`
|
this.query_timed(
|
||||||
|
`
|
||||||
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
|
||||||
JOIN json_each(?2) AS following ON messages.author = following.value
|
JOIN json_each(?2) AS following ON messages.author = following.value
|
||||||
@ -379,10 +380,10 @@ class TfElement extends LitElement {
|
|||||||
messages.author != ?4
|
messages.author != ?4
|
||||||
GROUP by channel
|
GROUP by channel
|
||||||
`,
|
`,
|
||||||
k_args
|
k_args
|
||||||
),
|
),
|
||||||
this.query_timed(
|
this.query_timed(
|
||||||
`
|
`
|
||||||
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
|
||||||
JOIN json_each(?1) AS channels ON messages_refs.ref = '#' || channels.value
|
JOIN json_each(?1) AS channels ON messages_refs.ref = '#' || channels.value
|
||||||
@ -393,10 +394,10 @@ class TfElement extends LitElement {
|
|||||||
messages.author != ?4
|
messages.author != ?4
|
||||||
GROUP by channel
|
GROUP by channel
|
||||||
`,
|
`,
|
||||||
k_args
|
k_args
|
||||||
),
|
),
|
||||||
this.query_timed(
|
this.query_timed(
|
||||||
`
|
`
|
||||||
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
|
||||||
WHERE
|
WHERE
|
||||||
@ -404,28 +405,29 @@ class TfElement extends LitElement {
|
|||||||
messages.content ->> 'root' IS NULL AND
|
messages.content ->> 'root' IS NULL AND
|
||||||
messages.author != ?4
|
messages.author != ?4
|
||||||
`,
|
`,
|
||||||
k_args
|
k_args
|
||||||
),
|
),
|
||||||
this.query_timed(
|
this.query_timed(
|
||||||
`
|
`
|
||||||
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
|
||||||
JOIN json_each(?2) AS following ON messages.author = following.value
|
JOIN json_each(?2) AS following ON messages.author = following.value
|
||||||
WHERE messages.author != ?4
|
WHERE messages.author != ?4
|
||||||
`,
|
`,
|
||||||
k_args
|
k_args
|
||||||
),
|
),
|
||||||
this.query_timed(
|
this.query_timed(
|
||||||
`
|
`
|
||||||
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
|
||||||
WHERE
|
WHERE
|
||||||
messages.content ->> 'type' = 'vote' AND
|
messages.content ->> 'type' = 'vote' AND
|
||||||
messages.author != ?4
|
messages.author != ?4
|
||||||
`,
|
`,
|
||||||
k_args
|
k_args
|
||||||
),
|
),
|
||||||
])).flat();
|
])
|
||||||
|
).flat();
|
||||||
let latest = {};
|
let latest = {};
|
||||||
for (let row of channels) {
|
for (let row of channels) {
|
||||||
if (!latest[row.channel]) {
|
if (!latest[row.channel]) {
|
||||||
|
Reference in New Issue
Block a user