Move / redirect handling to C

src/ssb.db.c

@@ -1754,3 +1754,93 @@ bool tf_ssb_db_identity_get_active(sqlite3* db, const char* user, const char* pa
 	}
 	return found;
 }
+
+typedef struct _resolve_index_t
+{
+	uv_work_t work;
+	tf_ssb_t* ssb;
+	const char* host;
+	const char* path;
+	void (*callback)(const char* path, void* user_data);
+	void* user_data;
+} resolve_index_t;
+
+static void _tf_ssb_db_resolve_index_work(uv_work_t* work)
+{
+	resolve_index_t* request = work->data;
+
+	sqlite3* db = tf_ssb_acquire_db_reader(request->ssb);
+	sqlite3_stmt* statement;
+	if (sqlite3_prepare(db, "SELECT json_extract(value, '$.index_map') FROM properties WHERE id = 'core' AND key = 'settings'", -1, &statement, NULL) == SQLITE_OK)
+	{
+		if (sqlite3_step(statement) == SQLITE_ROW)
+		{
+			const char* index_map = (const char*)sqlite3_column_text(statement, 0);
+			const char* start = index_map;
+			while (start)
+			{
+				const char* end = strchr(start, '\n');
+				const char* equals = strchr(start, '=');
+				if (equals && strncasecmp(request->host, start, equals - start) == 0)
+				{
+					size_t value_length = end && equals < end ? (size_t)(end - (equals + 1)) : strlen(equals + 1);
+					char* path = tf_malloc(value_length + 1);
+					memcpy(path, equals + 1, value_length);
+					path[value_length] = '\0';
+					request->path = path;
+					break;
+				}
+				start = end ? end + 1 : NULL;
+			}
+		}
+		sqlite3_finalize(statement);
+	}
+	else
+	{
+		tf_printf("prepare failed: %s\n", sqlite3_errmsg(db));
+	}
+
+	if (!request->path)
+	{
+		if (sqlite3_prepare(db, "SELECT json_extract(value, '$.index') FROM properties WHERE id = 'core' AND key = 'settings'", -1, &statement, NULL) == SQLITE_OK)
+		{
+			if (sqlite3_step(statement) == SQLITE_ROW)
+			{
+				request->path = tf_strdup((const char*)sqlite3_column_text(statement, 0));
+			}
+			sqlite3_finalize(statement);
+		}
+		else
+		{
+			tf_printf("prepare failed: %s\n", sqlite3_errmsg(db));
+		}
+	}
+	tf_ssb_release_db_reader(request->ssb, db);
+}
+
+static void _tf_ssb_db_resolve_index_after_work(uv_work_t* work, int status)
+{
+	resolve_index_t* request = work->data;
+	request->callback(request->path, request->user_data);
+	tf_free((void*)request->host);
+	tf_free((void*)request->path);
+	tf_free(request);
+}
+
+void tf_ssb_db_resolve_index_async(tf_ssb_t* ssb, const char* host, void (*callback)(const char* path, void* user_data), void* user_data)
+{
+	resolve_index_t* request = tf_malloc(sizeof(resolve_index_t));
+	*request = (resolve_index_t)
+	{
+		.work = { .data = request },
+		.ssb = ssb,
+		.host = tf_strdup(host),
+		.callback = callback,
+		.user_data = user_data,
+	};
+	int r = uv_queue_work(tf_ssb_get_loop(ssb), &request->work, _tf_ssb_db_resolve_index_work, _tf_ssb_db_resolve_index_after_work);
+	if (r)
+	{
+		_tf_ssb_db_resolve_index_after_work(&request->work, r);
+	}
+}