[slop]fix(rivetkit): surface raw error messages instead of generic

Author: abcxff

engine/packages/error/src/error.rs

@@ -1,14 +1,7 @@
 use crate::INTERNAL_ERROR;
 use crate::schema::RivetErrorSchema;
 use serde::Serialize;
-use std::{fmt, sync::OnceLock};
-
-static EXPOSE_INTERNAL_ERRORS: OnceLock<bool> = OnceLock::new();
-
-fn expose_internal_errors() -> bool {
-	*EXPOSE_INTERNAL_ERRORS
-		.get_or_init(|| matches!(std::env::var("RIVET_EXPOSE_ERRORS").as_deref(), Ok("1")))
-}
+use std::fmt;
 
 #[derive(Debug, Clone)]
 pub struct RivetError {
@@ -36,7 +29,7 @@ impl RivetError {
 		Self {
 			schema: &INTERNAL_ERROR,
 			meta,
-			message: expose_internal_errors().then(|| format!("Internal error: {}", error)),
+			message: Some(format!("{}", error)),
 		}
 	}
 

rivetkit-rust/engine/artifacts/errors/sqlite.query_failed.json

@@ -0,0 +1,5 @@
+{
+  "code": "query_failed",
+  "group": "sqlite",
+  "message": "SQL query failed."
+}

rivetkit-rust/packages/rivetkit-core/src/actor/sqlite.rs

@@ -633,7 +633,11 @@ fn map_local_worker_error(error: anyhow::Error) -> anyhow::Error {
 		return SqliteRuntimeError::Closed.build();
 	}
 
-	error
+	// User SQL errors (syntax, constraints, etc.)
+	SqliteRuntimeError::QueryFailed {
+		message: format!("{error}"),
+	}
+	.build()
 }
 
 fn protocol_bind_params(params: Vec<BindParam>) -> Vec<protocol::SqliteBindParam> {

rivetkit-rust/packages/rivetkit-core/src/error.rs

@@ -20,6 +20,7 @@ pub fn public_error_status_code(group: &str, code: &str) -> Option<u16> {
 			| "complete_not_configured"
 			| "timed_out",
 		) => Some(400),
+		("sqlite", "query_failed") => Some(400),
 		_ => None,
 	}
 }
@@ -192,6 +193,9 @@ pub(crate) enum SqliteRuntimeError {
 		"Remote SQLite generation is stale: {reason}"
 	)]
 	RemoteFenceMismatch { reason: String },
+
+	#[error("query_failed", "SQL query failed.", "SQL query failed: {message}")]
+	QueryFailed { message: String },
 }
 
 #[derive(RivetError, Debug, Clone, Deserialize, Serialize)]