add crsql_config_set function

core/rs/core/src/c.rs

@@ -263,7 +263,7 @@ fn bindgen_test_layout_crsql_ExtData() {
  let ptr = UNINIT.as_ptr();
  assert_eq!(
  ::core::mem::size_of::<crsql_ExtData>(),
- 128usize,
+ 136usize,
  concat!("Size of: ", stringify!(crsql_ExtData))
  );
  assert_eq!(
@@ -453,4 +453,14 @@ fn bindgen_test_layout_crsql_ExtData() {
  stringify!(pSelectClockTablesStmt)
  )
  );
+ assert_eq!(
+ unsafe { ::core::ptr::addr_of!((*ptr).tieBreakSameColValue) as usize - ptr as usize },
+ 128usize,
+ concat!(
+ "Offset of field: ",
+ stringify!(crsql_ExtData),
+ "::",
+ stringify!(tieBreakSameColValue)
+ )
+ );
 }

core/rs/core/src/config.rs

@@ -0,0 +1,30 @@
+use sqlite::Context;
+use sqlite_nostd as sqlite;
+use sqlite_nostd::{ResultCode, Value};
+
+use crate::c::crsql_ExtData;
+
+pub extern "C" fn crsql_config_set(
+ ctx: *mut sqlite::context,
+ argc: i32,
+ argv: *mut *mut sqlite::value,
+) {
+ let args = sqlite::args!(argc, argv);
+
+ let name = args[0].text();
+
+ match name {
+ "always-declare-winner" => {
+ let value = args[1].int() == 1;
+ let ext_data = ctx.user_data() as *mut crsql_ExtData;
+ unsafe { (*ext_data).tieBreakSameColValue = value };
+ }
+ _ => {
+ ctx.result_error("Unknown setting name");
+ ctx.result_error_code(ResultCode::ERROR);
+ return;
+ }
+ }
+
+ ctx.result_error_code(ResultCode::OK);
+}

core/rs/core/src/lib.rs

@@ -18,6 +18,7 @@ mod changes_vtab;
 mod changes_vtab_read;
 mod changes_vtab_write;
 mod compare_values;
+mod config;
 mod consts;
 mod create_cl_set_vtab;
 mod create_crr;
@@ -52,6 +53,7 @@ use alter::crsql_compact_post_alter;
 use automigrate::*;
 use backfill::*;
 use c::{crsql_freeExtData, crsql_newExtData};
+use config::crsql_config_set;
 use core::ffi::{c_int, c_void, CStr};
 use create_crr::create_crr;
 use db_version::{crsql_fill_db_version_if_needed, crsql_next_db_version};
@@ -153,6 +155,22 @@ pub extern "C" fn sqlite3_crsqlcore_init(
  return null_mut();
  }
 
+ let rc = db
+ .create_function_v2(
+ "crsql_config_set",
+ 2,
+ sqlite::UTF8,
+ None,
+ Some(crsql_config_set),
+ None,
+ None,
+ None,
+ )
+ .unwrap_or(sqlite::ResultCode::ERROR);
+ if rc != ResultCode::OK {
+ return null_mut();
+ }
+
  let rc = unpack_columns_vtab::create_module(db).unwrap_or(sqlite::ResultCode::ERROR);
  if rc != ResultCode::OK {
  return null_mut();