point to 2pc bindings

Author: Shubham8287

crates/bindings/src/remote_reducer.rs

@@ -103,12 +103,14 @@ pub fn call_reducer_on_db_2pc(
     database_identity: Identity,
     reducer_name: &str,
     args: &[u8],
-) -> Result<(), RemoteCallError> {
+) -> Result<Vec<u8>, RemoteCallError> {
     let identity_bytes = database_identity.to_byte_array();
     match spacetimedb_bindings_sys::call_reducer_on_db_2pc(identity_bytes, reducer_name, args) {
         Ok((status, body_source)) => {
             if status < 300 {
-                return Ok(());
+                let mut out = Vec::new();
+                read_bytes_source_into(body_source, &mut out);
+                return Ok(out);
             }
             let msg = if body_source == spacetimedb_bindings_sys::raw::BytesSource::INVALID {
                 String::new()

modules/tpcc/src/remote.rs

@@ -1,10 +1,9 @@
 use spacetimedb::{
-    reducer, remote_reducer::call_reducer_on_db, table, DeserializeOwned, Identity, ReducerContext, Serialize,
+    reducer, remote_reducer::call_reducer_on_db_2pc, table, DeserializeOwned, Identity, ReducerContext, Serialize,
     SpacetimeType, Table,
 };
 use spacetimedb_sats::bsatn;
 
-
 /// For warehouses not managed by this database, stores the [`Identity`] of the remote database which manages that warehouse.
 ///
 /// Will not have a row present for a warehouse managed by the local database.
@@ -55,7 +54,7 @@ where
     let args = bsatn::to_vec(args).map_err(|e| {
         format!("Failed to BSATN-serialize args for remote reducer {reducer_name} on database {database_ident}: {e}")
     })?;
-    let out = call_reducer_on_db(database_ident, reducer_name, &args)
+    let out = call_reducer_on_db_2pc(database_ident, reducer_name, &args)
         .map_err(|e| format!("Failed to call remote reducer {reducer_name} on database {database_ident}: {e}"))?;
     bsatn::from_slice(&out).map_err(|e| {
         format!(