mirror of
https://github.com/clockworklabs/SpacetimeDB.git
synced 2026-05-14 19:58:24 -04:00
Kim Altintop
48a205a818
* core: Fix host controller to not replace module if lifecyle hooks failed Previously, `spawn_module_host` would unconditionally insert the new module into the controller state, and not remove it if the lifecycle hooks (`init_database` / `update_database`) returned an error. This would mean that the module code was replaced with the new one, even if it should be rejected because the schema was not updated or the init / update reducer failed. Fix this by starting the module, and later "committing" it to the controller state in two phases. * Add commentary about database mutations / transactionality
101 lines
2.6 KiB
Bash
101 lines
2.6 KiB
Bash
#!/bin/bash
|
|
|
|
if [ "$DESCRIBE_TEST" = 1 ] ; then
|
|
echo "This tests publishing a module without the --clear-database option"
|
|
exit
|
|
fi
|
|
|
|
set -euox pipefail
|
|
|
|
source "./test/lib.include"
|
|
|
|
cat > "${PROJECT_PATH}/src/lib.rs" << EOF
|
|
use spacetimedb::{println, spacetimedb};
|
|
|
|
#[spacetimedb(table)]
|
|
pub struct Person {
|
|
#[primarykey]
|
|
#[autoinc]
|
|
id: u64,
|
|
name: String,
|
|
}
|
|
|
|
#[spacetimedb(reducer)]
|
|
pub fn add(name: String) {
|
|
Person::insert(Person { id: 0, name }).unwrap();
|
|
}
|
|
|
|
#[spacetimedb(reducer)]
|
|
pub fn say_hello() {
|
|
for person in Person::iter() {
|
|
println!("Hello, {}!", person.name);
|
|
}
|
|
println!("Hello, World!");
|
|
}
|
|
EOF
|
|
|
|
IDENT=$(basename "$PROJECT_PATH")
|
|
run_test cargo run publish --skip_clippy --project-path "$PROJECT_PATH" "$IDENT"
|
|
[ "1" == "$(grep -c "reated new database" "$TEST_OUT")" ]
|
|
|
|
run_test cargo run call "$IDENT" add Robert
|
|
run_test cargo run call "$IDENT" add Julie
|
|
run_test cargo run call "$IDENT" add Samantha
|
|
run_test cargo run call "$IDENT" say_hello
|
|
run_test cargo run logs "$IDENT" 100
|
|
[ ' Hello, Samantha!' == "$(grep 'Samantha' "$TEST_OUT" | tail -n 4 | cut -d: -f6-)" ]
|
|
[ ' Hello, Julie!' == "$(grep 'Julie' "$TEST_OUT" | tail -n 4 | cut -d: -f6-)" ]
|
|
[ ' Hello, Robert!' == "$(grep 'Robert' "$TEST_OUT" | tail -n 4 | cut -d: -f6-)" ]
|
|
[ ' Hello, World!' == "$(grep 'World' "$TEST_OUT" | tail -n 4 | cut -d: -f6-)" ]
|
|
|
|
# Unchanged module is ok
|
|
run_test cargo run publish --skip_clippy --project-path "$PROJECT_PATH" "$IDENT"
|
|
[ "1" == "$(grep -c "Updated database" "$TEST_OUT")" ]
|
|
|
|
# Changing an existing table isn't
|
|
cat > "${PROJECT_PATH}/src/lib.rs" <<EOF
|
|
use spacetimedb::spacetimedb;
|
|
|
|
#[spacetimedb(table)]
|
|
pub struct Person {
|
|
#[primarykey]
|
|
#[autoinc]
|
|
id: u64,
|
|
name: String,
|
|
age: u8,
|
|
}
|
|
EOF
|
|
|
|
run_test cargo run publish --skip_clippy --project-path "$PROJECT_PATH" "$IDENT" || true
|
|
[ "1" == "$(grep -c "Error: Database update rejected" "$TEST_OUT")" ]
|
|
# Check that the old module is still running by calling say_hello
|
|
run_test cargo run call "$IDENT" say_hello
|
|
|
|
# Adding a table is ok, and invokes update
|
|
cat > "${PROJECT_PATH}/src/lib.rs" <<EOF
|
|
use spacetimedb::{println, spacetimedb};
|
|
|
|
#[spacetimedb(table)]
|
|
pub struct Person {
|
|
#[primarykey]
|
|
#[autoinc]
|
|
id: u64,
|
|
name: String,
|
|
}
|
|
|
|
#[spacetimedb(table)]
|
|
pub struct Pet {
|
|
species: String,
|
|
}
|
|
|
|
#[spacetimedb(update)]
|
|
pub fn on_module_update() {
|
|
println!("MODULE UPDATED");
|
|
}
|
|
EOF
|
|
|
|
run_test cargo run publish --skip_clippy --project-path "$PROJECT_PATH" "$IDENT"
|
|
[ "1" == "$(grep -c "Updated database" "$TEST_OUT")" ]
|
|
run_test cargo run logs "$IDENT" 2
|
|
[ ' MODULE UPDATED' == "$(grep 'MODULE UPDATED' "$TEST_OUT" | tail -n 1 | cut -d: -f6-)" ]
|