apps/ssb.json

@@ -1,5 +1,5 @@
 {
 	"type": "tildefriends-app",
 	"emoji": "🦀",
-	"previous": "&h9uzh3gVWy1KWIu6wFYCrBZkVmnQAi7QLAj5iIXffFM=.sha256"
+	"previous": "&YZCzXrfB6j+y0sXF4KspAibwjLsSCaMoB5rdO3mQl+Q=.sha256"
 }

apps/ssb/tf-app.js

@@ -175,23 +175,10 @@ class TfElement extends LitElement {
 			}
 		}
 
-		const k_chunk_size = 1024;
-		let min_row_id = 0;
-		console.log(
-			'loading about for',
-			ids.length,
-			'accounts',
-			cache.last_row_id,
-			'=>',
-			max_row_id
-		);
-		try {
-			while (true) {
 		let abouts = await tfrpc.rpc.query(
 			`
-						SELECT * FROM (
 				SELECT
-								messages.rowid AS rowid, messages.author, json(messages.content) AS content, messages.sequence
+					messages.author, json(messages.content) AS content, messages.sequence
 				FROM
 					messages,
 					json_each(?1) AS following
@@ -202,28 +189,23 @@ class TfElement extends LitElement {
 					messages.rowid <= ?4
 				UNION
 				SELECT
-								messages.rowid AS rowid, messages.author, json(messages.content) AS content, messages.sequence
+					messages.author, json(messages.content) AS content, messages.sequence
 				FROM
 					messages,
 					json_each(?2) AS following
 				WHERE
 					messages.author = following.value AND
 					messages.content ->> 'type' = 'about' AND
-								messages.rowid > ?6 AND
 					messages.rowid <= ?4
-						)
-						ORDER BY rowid LIMIT ?5
+				ORDER BY messages.author, messages.sequence
 			`,
 			[
 				JSON.stringify(ids.filter((id) => cache.about[id])),
 				JSON.stringify(ids.filter((id) => !cache.about[id])),
 				cache.last_row_id,
 				max_row_id,
-						k_chunk_size,
-						min_row_id,
 			]
 		);
-				let max_seen;
 		for (let about of abouts) {
 			let content = JSON.parse(about.content);
 			if (content.about === about.author) {
@@ -234,18 +216,8 @@ class TfElement extends LitElement {
 					content
 				);
 			}
-					max_seen = about.rowid;
 		}
-				console.log(
-					'cache =',
-					cache.last_row_id,
-					'seen =',
-					max_seen,
-					'max =',
-					max_row_id
-				);
-				cache.last_row_id = Math.max(cache.last_row_id, max_seen ?? max_row_id);
-				min_row_id = Math.max(min_row_id, max_seen ?? max_row_id);
+		cache.last_row_id = max_row_id;
 		let new_cache = JSON.stringify(cache);
 		if (new_cache !== original_cache) {
 			let start_time = new Date();
@@ -261,13 +233,6 @@ class TfElement extends LitElement {
 				cache.about[id]
 			);
 		}
-				if (cache.last_row_id >= max_row_id) {
-					break;
-				}
-			}
-		} catch (e) {
-			console.log(e);
-		}
 		return Object.assign({}, users);
 	}
 

apps/ssb/tf-message.js

@@ -431,17 +431,12 @@ class TfMessageElement extends LitElement {
 					>
 						Copy ID
 					</button>
-					${this.drafts[this.message?.id] === undefined
-						? html`
+					${this.drafts[this.message?.id] === undefined ? html`
 						<button class="w3-button w3-bar-item" @click=${this.show_reply}>
 							⮢ Reply
 						</button>
-							`
-						: undefined}
-					<button
-						class="w3-button w3-bar-item w3-border-bottom"
-						@click=${this.react}
-					>
+					` : undefined}
+					<button class="w3-button w3-bar-item w3-border-bottom" @click=${this.react}>
 						👍 React
 					</button>
 					${formats.map(
@@ -546,7 +541,8 @@ class TfMessageElement extends LitElement {
 				: undefined;
 		return html`
 			<div class="w3-section w3-container">
-				${reply} ${this.render_children()}
+				${reply}
+				${this.render_children()}
 			</div>
 		`;
 	}

apps/ssb/tf-tab-news-feed.js

@@ -81,9 +81,7 @@ class TfTabNewsFeedElement extends LitElement {
 			`,
 			[JSON.stringify(combined.map((x) => x.id))]
 		);
-		return [].concat(
-			combined,
-			await tfrpc.rpc.query(
+		return [].concat(combined, await tfrpc.rpc.query(
 			`
 				SELECT FALSE AS is_primary, messages.rowid, messages.id, messages.previous, messages.author, messages.sequence, messages.timestamp, messages.hash, json(messages.content) AS content, messages.signature
 				FROM messages
@@ -91,12 +89,8 @@ class TfTabNewsFeedElement extends LitElement {
 				JOIN json_each(?1) AS following ON messages.author = following.value
 				WHERE messages.content ->> 'type' = 'vote'
 			`,
-				[
-					JSON.stringify(this.following),
-					JSON.stringify(refs2.map((x) => x.ref)),
-				]
-			)
-		);
+			[JSON.stringify(this.following), JSON.stringify(refs2.map((x) => x.ref))]
+		));
 	}
 
 	async fetch_messages(start_time, end_time) {
@@ -259,11 +253,7 @@ class TfTabNewsFeedElement extends LitElement {
 		try {
 			let more = [];
 			let last_start_time = this.time_range[0];
-			try {
 			more = await this.fetch_messages(null, last_start_time);
-			} catch (e) {
-				console.log(e);
-			}
 			this.update_time_range_from_messages(
 				more.filter((x) => x.timestamp < last_start_time)
 			);

src/ssb.rpc.c

@@ -1594,20 +1594,27 @@ static void _tf_ssb_rpc_delete_feeds_work(tf_ssb_t* ssb, void* user_data)
 	db = tf_ssb_acquire_db_writer(ssb);
 	sqlite3_stmt* statement;
 	if (sqlite3_prepare(db,
-			"DELETE FROM messages WHERE id IN ("
-			"  SELECT id FROM messages WHERE author NOT IN (SELECT value FROM json_each(?)) ORDER BY rowid DESC LIMIT 1024"
-			")",
+			"DELETE FROM messages WHERE author IN ("
+			"  SELECT author FROM messages WHERE author NOT IN (SELECT value FROM json_each(?)) GROUP BY author LIMIT 1"
+			") RETURNING author",
 			-1, &statement, NULL) == SQLITE_OK)
 	{
+		int status = SQLITE_OK;
+		bool printed = false;
 		if (sqlite3_bind_text(statement, 1, arg, -1, NULL) == SQLITE_OK)
 		{
-			if (sqlite3_step(statement) != SQLITE_DONE)
+			while ((status = sqlite3_step(statement)) == SQLITE_ROW)
 			{
-				tf_printf("deleting messages: %s\n", sqlite3_errmsg(db));
+				if (!printed)
+				{
+					tf_printf("deleting %s\n", sqlite3_column_text(statement, 0));
+					printed = true;
+					delete->deleted++;
 				}
-			else
+			}
+			if (status != SQLITE_DONE)
 			{
-				delete->deleted += sqlite3_changes(db);
+				tf_printf("deleting feeds: %s\n", sqlite3_errmsg(db));
 			}
 		}
 		sqlite3_finalize(statement);
@@ -1620,7 +1627,7 @@ static void _tf_ssb_rpc_delete_feeds_work(tf_ssb_t* ssb, void* user_data)
 	JS_FreeRuntime(runtime);
 
 	delete->duration_ms = (uv_hrtime() - start_ns) / 1000000LL;
-	tf_printf("Deleted %d message in %d ms.\n", delete->deleted, (int)delete->duration_ms);
+	tf_printf("Deleted %d feeds in %d ms.\n", delete->deleted, (int)delete->duration_ms);
 	_tf_ssb_rpc_checkpoint(ssb);
 }