caretta-sync/core/src/data/local/migration/v1.rs

use rusqlite::{Error, Connection};

pub fn migrate(con: &mut Connection) -> Result<(), Error>{
    let tx = con.transaction()?;
    tx.execute_batch(
        "BEGIN;
            CREATE TABLE authorized_peer (
                id                       INTEGER PRIMARY KEY,
                node_id                  BLOB NOT NULL UNIQUE,
                last_synced_at           TEXT,
                last_sent_version_vector BLOB
                created_at               TEXT NOT NULL,
                updated_at               TEXT NOT NULL,
            );
            CREATE TABLE authorization (
                id         INTEGER PRIMARY KEY,
                node_id    BLOB UNIQUE NOT NULL,
                passcode   TEXT NOT NULL,
                created_at TEXT NOT NULL,
                updated_at TEXT NOT NULL,
            );
            COMMIT;",
    )?;
    tx.pragma_update(None,  "user_version", 1)?;
    tx.commit()?;
    Ok(())
}