diff options
Diffstat (limited to 'yt/src/storage/migrate')
| -rw-r--r-- | yt/src/storage/migrate/mod.rs | 24 | ||||
| -rw-r--r-- | yt/src/storage/migrate/sql/01_zero_to_one.sql | 19 |
2 files changed, 41 insertions, 2 deletions
diff --git a/yt/src/storage/migrate/mod.rs b/yt/src/storage/migrate/mod.rs index 4e956de..9696616 100644 --- a/yt/src/storage/migrate/mod.rs +++ b/yt/src/storage/migrate/mod.rs @@ -18,8 +18,11 @@ pub enum DbVersion { /// The first database version. /// Introduced: 2025-02-16. Zero, + + /// Introduced: 2025-02-17. + One, } -const CURRENT_VERSION: DbVersion = DbVersion::Zero; +const CURRENT_VERSION: DbVersion = DbVersion::One; async fn set_db_version( tx: &mut Transaction<'_, Sqlite>, @@ -59,13 +62,16 @@ impl DbVersion { match self { DbVersion::Empty => unreachable!("A empty version does not have an associated integer"), DbVersion::Zero => 0, + DbVersion::One => 1, } } fn from_db(number: i64, namespace: &str) -> Result<Self> { match (number, namespace) { (0, "yt") => Ok(DbVersion::Zero), + (1, "yt") => Ok(DbVersion::One), (0, other) => bail!("Db version is Zero, but got unknown namespace: '{other}'"), + (1, other) => bail!("Db version is One, but got unknown namespace: '{other}'"), (other, "yt") => bail!("Got unkown version for 'yt' namespace: {other}"), (num, nasp) => bail!("Got unkown version number ({num}) and namespace ('{nasp}')"), @@ -92,10 +98,24 @@ impl DbVersion { Box::pin(Self::Zero.update(app)).await } - // This is the current version DbVersion::Zero => { + let mut tx = app.database.begin().await?; debug!("Migrate: Zero -> One"); + sqlx::raw_sql(include_str!("./sql/01_zero_to_one.sql")) + .execute(&mut *tx) + .await?; + + set_db_version(&mut tx, Some(DbVersion::Zero), DbVersion::One).await?; + + tx.commit().await?; + Box::pin(Self::One.update(app)).await + } + + // This is the current_version + DbVersion::One => { + debug!("Migrate: One -> Two"); + assert_eq!(self, CURRENT_VERSION); assert_eq!(self, get_version(app).await?); Ok(()) diff --git a/yt/src/storage/migrate/sql/01_zero_to_one.sql b/yt/src/storage/migrate/sql/01_zero_to_one.sql new file mode 100644 index 0000000..42c3b02 --- /dev/null +++ b/yt/src/storage/migrate/sql/01_zero_to_one.sql @@ -0,0 +1,19 @@ +-- Is the video currently in a playlist? +ALTER TABLE videos ADD in_playlist INTEGER NOT NULL DEFAULT 0 CHECK (in_playlist IN (0, 1)); +UPDATE videos SET in_playlist = 0; + +-- Is it 'focused' (i.e., the select video)? +-- Only of video should be focused at a time. +ALTER TABLE videos +ADD COLUMN is_focused INTEGER NOT NULL DEFAULT 0 +CHECK (is_focused IN (0, 1)); +UPDATE videos SET is_focused = 0; + +-- The progress the user made in watching the video. +ALTER TABLE videos ADD watch_progress INTEGER NOT NULL DEFAULT 0 CHECK (watch_progress <= duration); + +-- Assume, that the user has watched the video to end, if it is marked as watched +UPDATE videos SET watch_progress = duration WHERE status = 3; +UPDATE videos SET watch_progress = 0 WHERE status != 3; + +ALTER TABLE videos DROP COLUMN status_change; |