Joscha
b57c70dd01
Resets migrations because nobody except me is using cove anyways and this is easier than keeping backwards compatibility.
82 lines
2.6 KiB
Rust
82 lines
2.6 KiB
Rust
use rusqlite::{Connection, Transaction};
|
|
|
|
pub fn migrate(conn: &mut Connection) -> rusqlite::Result<()> {
|
|
let mut tx = conn.transaction()?;
|
|
|
|
let user_version: usize =
|
|
tx.query_row("SELECT * FROM pragma_user_version", [], |r| r.get(0))?;
|
|
|
|
let total = MIGRATIONS.len();
|
|
assert!(user_version <= total, "malformed database schema");
|
|
for (i, migration) in MIGRATIONS.iter().enumerate().skip(user_version) {
|
|
println!("Migrating vault from {} to {} (out of {})", i, i + 1, total);
|
|
migration(&mut tx)?;
|
|
}
|
|
|
|
tx.pragma_update(None, "user_version", total)?;
|
|
tx.commit()
|
|
}
|
|
|
|
const MIGRATIONS: [fn(&mut Transaction<'_>) -> rusqlite::Result<()>; 1] = [m1];
|
|
|
|
fn m1(tx: &mut Transaction<'_>) -> rusqlite::Result<()> {
|
|
tx.execute_batch(
|
|
"
|
|
CREATE TABLE euph_rooms (
|
|
room TEXT NOT NULL PRIMARY KEY,
|
|
first_joined INT NOT NULL,
|
|
last_joined INT NOT NULL
|
|
) STRICT;
|
|
|
|
CREATE TABLE euph_msgs (
|
|
-- Message
|
|
room TEXT NOT NULL,
|
|
id INT NOT NULL,
|
|
parent INT,
|
|
previous_edit_id INT,
|
|
time INT NOT NULL,
|
|
content TEXT NOT NULL,
|
|
encryption_key_id TEXT,
|
|
edited INT,
|
|
deleted INT,
|
|
truncated INT NOT NULL,
|
|
|
|
-- SessionView
|
|
user_id TEXT NOT NULL,
|
|
name TEXT,
|
|
server_id TEXT NOT NULL,
|
|
server_era TEXT NOT NULL,
|
|
session_id TEXT NOT NULL,
|
|
is_staff INT NOT NULL,
|
|
is_manager INT NOT NULL,
|
|
client_address TEXT,
|
|
real_client_address TEXT,
|
|
|
|
PRIMARY KEY (room, id),
|
|
FOREIGN KEY (room) REFERENCES euph_rooms (room)
|
|
ON DELETE CASCADE
|
|
) STRICT;
|
|
|
|
CREATE TABLE euph_spans (
|
|
room TEXT NOT NULL,
|
|
start INT,
|
|
end INT,
|
|
|
|
UNIQUE (room, start, end),
|
|
FOREIGN KEY (room) REFERENCES euph_rooms (room)
|
|
ON DELETE CASCADE,
|
|
CHECK (start IS NULL OR end IS NOT NULL)
|
|
) STRICT;
|
|
|
|
CREATE TABLE euph_cookies (
|
|
cookie TEXT NOT NULL
|
|
) STRICT;
|
|
|
|
CREATE INDEX euph_idx_msgs_room_id_parent
|
|
ON euph_msgs (room, id, parent);
|
|
|
|
CREATE INDEX euph_idx_msgs_room_parent_id
|
|
ON euph_msgs (room, parent, id);
|
|
",
|
|
)
|
|
}
|