ssb: Unread status for private messages.

apps/ssb/tf-app.js

@@ -374,7 +374,7 @@ class TfElement extends LitElement {
 		let result = await this.decrypt(
 			await tfrpc.rpc.query(
 				`
-				SELECT messages.id, author, timestamp, json(content) AS content
+				SELECT messages.rowid, messages.id, author, timestamp, json(content) AS content
 				FROM messages
 				JOIN json_each(?) AS ids
 				WHERE messages.id = ids.value

apps/ssb/tf-compose.js

@@ -92,7 +92,9 @@ class TfComposeElement extends LitElement {
 				bubbles: true,
 				composed: true,
 				detail: {
-					id: this.branch ?? (this.recipients ? this.recipients.join(',') : undefined),
+					id:
+						this.branch ??
+						(this.recipients ? this.recipients.join(',') : undefined),
 					draft: draft,
 				},
 			})

apps/ssb/tf-tab-news.js

@@ -116,6 +116,19 @@ class TfTabNewsElement extends LitElement {
 			) {
 				return '✉️ ';
 			}
+		} else if (channel?.startsWith('🔐')) {
+			let key = JSON.stringify(channel.substring('🔐'.length).split(','));
+			if (this.grouped_private_messages?.[key]) {
+				let grouped_latest = Math.max(
+					...this.grouped_private_messages?.[key]?.map((x) => x.rowid)
+				);
+				if (
+					this.channels_unread[channel] === undefined ||
+					grouped_latest > this.channels_unread[channel]
+				) {
+					return '✉️ ';
+				}
+			}
 		} else if (
 			this.channels_latest[channel] &&
 			this.channels_latest[channel] > 0 &&
@@ -268,7 +281,8 @@ class TfTabNewsElement extends LitElement {
 								style=${this.hash == '#🔐' + JSON.parse(key).join(',')
 									? 'font-weight: bold'
 									: undefined}
-								>${(key != '[]' ? JSON.parse(key) : [this.whoami]).map(
+								>${this.unread_status('🔐' + JSON.parse(key).join(','))}
+								${(key != '[]' ? JSON.parse(key) : [this.whoami]).map(
 									(id) => html`
 										<tf-user
 											id=${id}