Bitcraft hotfix

crates/core/src/host/module_host.rs

@@ -1139,7 +1139,23 @@ impl ModuleHost {
         let db = replica_ctx.relational_db.clone();
         let subscriptions = replica_ctx.subscriptions.clone();
         let auth = AuthCtx::new(replica_ctx.owner_identity, caller_identity);
-        log::debug!("One-off query: {query}");
+
+        const BUILDING_STATE_SQL: &str = "SELECT location_state.* FROM location_state JOIN building_state ON building_state.entity_id = location_state.entity_id";
+        const CLAIM_STATE_SQL: &str = "SELECT location_state.* FROM location_state JOIN claim_state ON claim_state.owner_building_entity_id = location_state.entity_id";
+
+        const OPT_BUILDING_STATE_SQL: &str = "SELECT location_state.* FROM building_state JOIN location_state ON building_state.entity_id = location_state.entity_id";
+        const OPT_CLAIM_STATE_SQL: &str = "SELECT location_state.* FROM claim_state JOIN location_state ON claim_state.owner_building_entity_id = location_state.entity_id";
+
+        let query = if query == BUILDING_STATE_SQL {
+            OPT_BUILDING_STATE_SQL.to_owned()
+        } else if query == CLAIM_STATE_SQL {
+            OPT_CLAIM_STATE_SQL.to_owned()
+        } else {
+            query
+        };
+
+        log::info!("One-off query: {query}");
+
         let metrics = self
             .on_module_thread("one_off_query", move || {
                 let (tx_offset_sender, tx_offset_receiver) = oneshot::channel();

crates/core/src/host/wasm_common/module_host_actor.rs

@@ -1,3 +1,6 @@
+#![allow(unused_imports)]
+#![allow(dead_code)]
+
 use prometheus::{Histogram, IntCounter, IntGauge};
 use spacetimedb_lib::db::raw_def::v9::Lifecycle;
 use spacetimedb_schema::auto_migrate::{MigratePlan, MigrationPolicy, MigrationPolicyError};
@@ -464,8 +467,8 @@ impl InstanceCommon {
             }) {
                 Ok(()) => EventStatus::Committed(DatabaseUpdate::default()),
                 Err(err) => {
-                    log::info!("reducer returned error: {err}");
-                    log_reducer_error(replica_ctx, timestamp, reducer_name, &err);
+                    // log::info!("reducer returned error: {err}");
+                    // log_reducer_error(replica_ctx, timestamp, reducer_name, &err);
                     EventStatus::Failed(err.into())
                 }
             },

crates/core/src/subscription/module_subscription_manager.rs

@@ -1,3 +1,5 @@
+#![allow(unused_variables)]
+
 use super::execution_unit::QueryHash;
 use super::tx::DeltaTx;
 use crate::client::messages::{
@@ -1627,7 +1629,7 @@ fn send_to_client(
 ) {
     tracing::trace!(client = %client.id, tx_offset, "send_to_client");
     if let Err(e) = client.send_message(tx_offset, message) {
-        tracing::warn!(%client.id, "failed to send update message to client: {e}")
+        // tracing::warn!(%client.id, "failed to send update message to client: {e}")
     }
 }
 

smoketests/tests/client_connected_error_rejects_connection.py

@@ -36,7 +36,7 @@ def test_client_connected_error_rejects_connection(self):
             self.subscribe("select * from all_u8s", n = 0)()
 
         logs = self.logs(100)
-        self.assertIn('Rejecting connection from client', logs)
+        # self.assertIn('Rejecting connection from client', logs)
         self.assertNotIn('This should never be called, since we reject all connections!', logs)
 
 class ClientDisconnectedErrorStillDeletesStClient(Smoketest):

smoketests/tests/panic.py

@@ -47,4 +47,4 @@ def test_reducer_error_message(self):
         with self.assertRaises(Exception):
             self.call("fail")
 
-        self.assertIn("oopsie :(", self.logs(2))
+        # self.assertIn("oopsie :(", self.logs(2))