add some info/warn logs for debugging

@@ -31,2 +31,4 @@
 indent_size = 4
 indent_style = space
+
+[Makefile]

@@ -1,6 +1,9 @@
 #!/usr/bin/env bash
 
-dotenv_if_exists
+watch_file .env

@@ -0,0 +1,76 @@
+---

@@ -0,0 +1,116 @@
+---

@@ -0,0 +1,174 @@
+---

@@ -0,0 +1,255 @@
+SHELL=/bin/bash

@@ -6,10 +6,10 @@ set -euo pipefail
 COMPLEMENT_SRC="${COMPLEMENT_SRC:-$1}"

@@ -51,2 +61,2 @@
-    go test -tags="conduwuit_blacklist" -skip="$SKIPPED_COMPLEMENT_TESTS" -v -timeout 1h -json ./tests/... | tee "$LOG_FILE"
-set -o pipefail
+if [ "$HAS_GOTESTSUM" = true ]; then
+    # gotestsum writes full JSON logs

@@ -0,0 +1 @@
+Implemented transactional wrappers around room joins and other key database operations to guarantee atomicity. This mitigates previously silent race conditions where partial state was written (fixes #1142 "Room has no state" sync error).

@@ -0,0 +1 @@
+The `roomsynctoken_shortstatehash` table — responsible for 60% to 90% of database bloat — has been removed. Sync state is now computed statelessly from the timeline on each request, eliminating the per-room write on every sync response. Existing table data is orphaned on disk and can be reclaimed by a future database compaction. Ref: [#917](https://forgejo.ellis.link/continuwuation/continuwuity/issues/917)

@@ -6,12 +6,18 @@
 # ============================================= #

@@ -0,0 +1,6 @@
+{"ImportPath":"./tests/...","Action":"build-output","Output":"# ./tests/...\n"}

@@ -1286,3 +1290,3 @@
 #allow_legacy_media = true
 
-# This item is undocumented. Please contribute documentation for it.
+# Disallow remote legacy media downloading. If set to true, requests for

@@ -320,0 +319,4 @@
+		.config
+		.yes_i_am_very_very_sure_i_want_an_open_registration_server_prone_to_abuse;
+
+	if services.firstrun.is_first_run() && !open_registration {

@@ -115,3 +114,3 @@
 		content_type,
 		content_disposition,
-	} = fetch_thumbnail(&services, &mxc, user, body.timeout_ms, &dim).await?;
+	} = match fetch_thumbnail(&services, &mxc, Some(user), body.timeout_ms, &dim).await {

@@ -164,3 +164,3 @@
 		| _ =>
 			if !services.globals.server_is_ours(&body.server_name) && body.allow_remote {
-				let response = services
+				debug_info!(%mxc, "Fetching remote media via authenticated federation fallback");

@@ -383,0 +380,4 @@
+	// Parallel discovery: Kick off make_join to multiple servers at once.
+	// The first one to return a valid stub wins and we try to finish the join with
+	// them.
+	let last_error = Arc::new(tokio::sync::Mutex::new(None));

@@ -288,3 +288,3 @@
 		let make_leave_response = services
 			.sending
-			.send_federation_request(
+			.send_synapse_request(

@@ -141,3 +141,3 @@
 		.wide_filter_map(|item| visibility_filter(&services, item, sender_user))
 		.take(limit)
-		.then(async |mut pdu| {
+		.wide_then(move |mut pdu| async move {

@@ -85,3 +85,3 @@
 			})
 		},
-		| _ => Err!(Request(NotFound("Presence state for this user was not found"))),
+		| _ => {

@@ -413,3 +409,1 @@
-			warn!(%user_id, %room_id, "Failed to update/send new profile join membership update in room: {e}");
-		}
-	}
+	all_joined_rooms

@@ -31,3 +31,3 @@
 
 	if !visible || is_ignored_pdu(services, &event, body.sender_user()).await? {
-		return Err!(Request(Forbidden("You don't have permission to view this event.")));
+		return Err!(Request(NotFound("Event not found.")));

@@ -349,3 +349,3 @@
 							.await
 							.map_err(|e| {
-								err!(Request(Unknown("Failed resolving alias \"{alias}\": {e}")))
+								err!(Request(BadAlias("Failed resolving alias \"{alias}\": {e}")))

@@ -298,11 +319,26 @@ async fn build_state_and_timeline(
 	// history
 	let prev_batch = timeline.pdus.front().map(at!(0));
 
+	let user_has_join_event_in_sync = timeline

@@ -628,0 +703,4 @@
+			.ok();
+
+		// If we can resolve the previous membership event, check if it was Join.
+		// If we couldn't resolve it (None), default to false (not a fresh join)

@@ -628,0 +712,4 @@
+		);
+
+		if joined_since_last_sync && membership_during_previous_sync.is_some() {
+			warn!(

@@ -272,2 +273,2 @@
-				.await
-				.ok()
+		.broad_filter_map(|event_id: OwnedEventId| async move {
+			services.rooms.timeline.get_pdu(&event_id).await.ok()

@@ -149,12 +149,12 @@ pub fn build(router: Router<State>, server: &Server) -> Router<State> {
 		.ruma_route(&client::search_events_route)

@@ -93,1 +93,4 @@
 
+		// if the body is not empty and not media, but json parsing failed, it is
+		// invalid JSON
+		if json_body.is_none()

@@ -366,3 +366,2 @@
 			let msg = match e.reason() {
-				| TypedHeaderRejectionReason::Missing => "Missing Authorization header.",
-				| TypedHeaderRejectionReason::Error(_) => "Invalid X-Matrix signatures.",
+				| TypedHeaderRejectionReason::Missing => "Missing Authorization header",

@@ -21,2 +21,4 @@
 	where
 		H: RumaHandler<T>;
+
+	fn ruma_route_path<H, T>(self, handler: &'static H, path: &str) -> Self

@@ -259,3 +259,3 @@
 				}
 			},
-			| AllowRule::UnstableSpamChecker =>
+			| AllowRule::UnstableSpamChecker => {

@@ -359,6 +359,9 @@ async fn handle_room(
 }
 
 async fn handle_edu(services: &Services, client: &IpAddr, origin: &ServerName, edu: Edu) {
+	if services.server.check_running().is_err() {

@@ -46,15 +46,28 @@ pub(super) async fn check(&self) -> Result {
 		join!(world_readable, server_in_room, server_can_see, acl_check);
 
 	if !acl_check {

@@ -14,1 +12,3 @@
-# name = "conduwuit_build_metadata"
+
+[[bin]]
+name = "conduwuit-version"

@@ -1,25 +1,17 @@
-use std::process::Command;
+#[path = "src/git.rs"]
+mod git;

@@ -27,3 +23,2 @@
 pub static GIT_REMOTE_COMMIT_URL: Option<&str> = option_env!("GIT_REMOTE_COMMIT_URL");
-
-// TODO: Mark dirty builds within the version string
+pub static GIT_REMOTE_URL: Option<&str> = option_env!("GIT_REMOTE_URL");

@@ -0,0 +1,11 @@
+#[path = "../git.rs"]

@@ -0,0 +1,54 @@
+use std::process::Command;

@@ -2787,3 +2798,3 @@
 fn default_client_response_timeout() -> u64 { 120 }
 
-fn default_client_shutdown_timeout() -> u64 { 15 }
+fn default_client_shutdown_timeout() -> u64 { 10 }

@@ -157,6 +157,14 @@ macro_rules! err_lev {
 		}
 	};
 
+	(info) => {

@@ -70,3 +70,3 @@
 #[inline]
 pub fn inspect_debug_log<E: fmt::Debug>(error: &E) {
-	inspect_debug_log_level(error, Level::ERROR);
+	inspect_debug_log_level(error, Level::WARN);

@@ -132,2 +132,4 @@
 	Uiaa(ruma::api::client::uiaa::UiaaInfo),
 
+	// federation / remote
+	#[error("Federation timeout: {0}")]

@@ -16,3 +16,3 @@
 	fn into_response(self) -> axum::response::Response {
 		let status = self.status_code();
-		if status.is_server_error() {
+		if status == StatusCode::INTERNAL_SERVER_ERROR {

@@ -28,2 +30,4 @@
 
 #[inline]
+#[must_use]
+pub fn git_remote_commit_url() -> &'static str {

@@ -467,3 +467,3 @@
 
 	if !matches!(membership_state, MembershipState::Join) {
-		warn!(
+		info!(

@@ -692,3 +691,3 @@
 				);
 			} else {
-				warn!(event_id = aid.as_str(), "missing auth event");
+				info!(event_id = aid.as_str(), "missing auth event");