Minimal subsonic functionality

src/entities/artist.rs

@@ -14,6 +14,9 @@ pub struct Model {
     pub top_songs: String,
     /// JSON-serialized Vec of similar artist info
     pub similar_artists: String,
+    pub monitored: bool,
+    #[sea_orm(nullable)]
+    pub last_checked_at: Option<chrono::NaiveDateTime>,
 }
 
 #[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]

src/entities/mod.rs

@@ -1,13 +1,19 @@
 pub mod album;
 pub mod artist;
 pub mod download_queue;
+pub mod playlist;
+pub mod playlist_track;
 pub mod search_cache;
 pub mod track;
+pub mod user;
 pub mod wanted_item;
 
 pub use album::Entity as Albums;
 pub use artist::Entity as Artists;
 pub use download_queue::Entity as DownloadQueue;
+pub use playlist::Entity as Playlists;
+pub use playlist_track::Entity as PlaylistTracks;
 pub use search_cache::Entity as SearchCache;
 pub use track::Entity as Tracks;
+pub use user::Entity as Users;
 pub use wanted_item::Entity as WantedItems;

src/entities/playlist.rs

@@ -0,0 +1,43 @@
+use sea_orm::entity::prelude::*;
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Serialize, Deserialize)]
+#[sea_orm(table_name = "playlists")]
+pub struct Model {
+    #[sea_orm(primary_key)]
+    pub id: i32,
+    pub name: String,
+    #[sea_orm(nullable)]
+    pub description: Option<String>,
+    #[sea_orm(nullable)]
+    pub user_id: Option<i32>,
+    pub created_at: chrono::NaiveDateTime,
+    pub updated_at: chrono::NaiveDateTime,
+}
+
+#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
+pub enum Relation {
+    #[sea_orm(
+        belongs_to = "super::user::Entity",
+        from = "Column::UserId",
+        to = "super::user::Column::Id",
+        on_delete = "SetNull"
+    )]
+    User,
+    #[sea_orm(has_many = "super::playlist_track::Entity")]
+    PlaylistTracks,
+}
+
+impl Related<super::user::Entity> for Entity {
+    fn to() -> RelationDef {
+        Relation::User.def()
+    }
+}
+
+impl Related<super::playlist_track::Entity> for Entity {
+    fn to() -> RelationDef {
+        Relation::PlaylistTracks.def()
+    }
+}
+
+impl ActiveModelBehavior for ActiveModel {}

src/entities/playlist_track.rs

@@ -0,0 +1,43 @@
+use sea_orm::entity::prelude::*;
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Serialize, Deserialize)]
+#[sea_orm(table_name = "playlist_tracks")]
+pub struct Model {
+    #[sea_orm(primary_key)]
+    pub id: i32,
+    pub playlist_id: i32,
+    pub track_id: i32,
+    pub position: i32,
+}
+
+#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
+pub enum Relation {
+    #[sea_orm(
+        belongs_to = "super::playlist::Entity",
+        from = "Column::PlaylistId",
+        to = "super::playlist::Column::Id",
+        on_delete = "Cascade"
+    )]
+    Playlist,
+    #[sea_orm(
+        belongs_to = "super::track::Entity",
+        from = "Column::TrackId",
+        to = "super::track::Column::Id"
+    )]
+    Track,
+}
+
+impl Related<super::playlist::Entity> for Entity {
+    fn to() -> RelationDef {
+        Relation::Playlist.def()
+    }
+}
+
+impl Related<super::track::Entity> for Entity {
+    fn to() -> RelationDef {
+        Relation::Track.def()
+    }
+}
+
+impl ActiveModelBehavior for ActiveModel {}

src/entities/user.rs

@@ -0,0 +1,42 @@
+use sea_orm::entity::prelude::*;
+use serde::{Deserialize, Serialize};
+
+#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize, EnumIter, DeriveActiveEnum)]
+#[sea_orm(rs_type = "String", db_type = "Text")]
+pub enum UserRole {
+    #[sea_orm(string_value = "admin")]
+    Admin,
+    #[sea_orm(string_value = "user")]
+    User,
+}
+
+#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Serialize, Deserialize)]
+#[sea_orm(table_name = "users")]
+pub struct Model {
+    #[sea_orm(primary_key)]
+    pub id: i32,
+    #[sea_orm(unique)]
+    pub username: String,
+    #[serde(skip_serializing)]
+    pub password_hash: String,
+    #[serde(skip_serializing)]
+    #[sea_orm(nullable)]
+    pub subsonic_password: Option<String>,
+    pub role: UserRole,
+    pub created_at: chrono::NaiveDateTime,
+    pub updated_at: chrono::NaiveDateTime,
+}
+
+#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
+pub enum Relation {
+    #[sea_orm(has_many = "super::wanted_item::Entity")]
+    WantedItems,
+}
+
+impl Related<super::wanted_item::Entity> for Entity {
+    fn to() -> RelationDef {
+        Relation::WantedItems.def()
+    }
+}
+
+impl ActiveModelBehavior for ActiveModel {}

src/entities/wanted_item.rs

@@ -37,6 +37,8 @@ pub struct Model {
     pub album_id: Option<i32>,
     #[sea_orm(nullable)]
     pub track_id: Option<i32>,
+    #[sea_orm(nullable)]
+    pub user_id: Option<i32>,
     pub name: String,
     #[sea_orm(nullable)]
     pub musicbrainz_id: Option<String>,
@@ -47,6 +49,13 @@ pub struct Model {
 
 #[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
 pub enum Relation {
+    #[sea_orm(
+        belongs_to = "super::user::Entity",
+        from = "Column::UserId",
+        to = "super::user::Column::Id",
+        on_delete = "Cascade"
+    )]
+    User,
     #[sea_orm(
         belongs_to = "super::artist::Entity",
         from = "Column::ArtistId",
@@ -72,6 +81,12 @@ pub enum Relation {
     Downloads,
 }
 
+impl Related<super::user::Entity> for Entity {
+    fn to() -> RelationDef {
+        Relation::User.def()
+    }
+}
+
 impl Related<super::artist::Entity> for Entity {
     fn to() -> RelationDef {
         Relation::Artist.def()

src/migration/m20260319_000011_create_users.rs

@@ -0,0 +1,67 @@
+use sea_orm_migration::prelude::*;
+
+#[derive(DeriveMigrationName)]
+pub struct Migration;
+
+#[async_trait::async_trait]
+impl MigrationTrait for Migration {
+    async fn up(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        manager
+            .create_table(
+                Table::create()
+                    .table(Users::Table)
+                    .if_not_exists()
+                    .col(
+                        ColumnDef::new(Users::Id)
+                            .integer()
+                            .not_null()
+                            .auto_increment()
+                            .primary_key(),
+                    )
+                    .col(
+                        ColumnDef::new(Users::Username)
+                            .text()
+                            .not_null()
+                            .unique_key(),
+                    )
+                    .col(ColumnDef::new(Users::PasswordHash).text().not_null())
+                    .col(
+                        ColumnDef::new(Users::Role)
+                            .text()
+                            .not_null()
+                            .default("user"),
+                    )
+                    .col(
+                        ColumnDef::new(Users::CreatedAt)
+                            .date_time()
+                            .not_null()
+                            .default(Expr::current_timestamp()),
+                    )
+                    .col(
+                        ColumnDef::new(Users::UpdatedAt)
+                            .date_time()
+                            .not_null()
+                            .default(Expr::current_timestamp()),
+                    )
+                    .to_owned(),
+            )
+            .await
+    }
+
+    async fn down(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        manager
+            .drop_table(Table::drop().table(Users::Table).to_owned())
+            .await
+    }
+}
+
+#[derive(DeriveIden)]
+pub(crate) enum Users {
+    Table,
+    Id,
+    Username,
+    PasswordHash,
+    Role,
+    CreatedAt,
+    UpdatedAt,
+}

src/migration/m20260319_000012_add_user_id_to_wanted_items.rs

@@ -0,0 +1,45 @@
+use sea_orm_migration::prelude::*;
+
+#[derive(DeriveMigrationName)]
+pub struct Migration;
+
+#[async_trait::async_trait]
+impl MigrationTrait for Migration {
+    async fn up(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        manager
+            .alter_table(
+                Table::alter()
+                    .table(WantedItems::Table)
+                    .add_column(ColumnDef::new(WantedItems::UserId).integer())
+                    .to_owned(),
+            )
+            .await?;
+
+        manager
+            .create_index(
+                Index::create()
+                    .name("idx_wanted_items_user_id")
+                    .table(WantedItems::Table)
+                    .col(WantedItems::UserId)
+                    .to_owned(),
+            )
+            .await
+    }
+
+    async fn down(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        manager
+            .alter_table(
+                Table::alter()
+                    .table(WantedItems::Table)
+                    .drop_column(WantedItems::UserId)
+                    .to_owned(),
+            )
+            .await
+    }
+}
+
+#[derive(DeriveIden)]
+enum WantedItems {
+    Table,
+    UserId,
+}

src/migration/m20260320_000013_add_artist_monitoring.rs

@@ -0,0 +1,59 @@
+use sea_orm_migration::prelude::*;
+
+#[derive(DeriveMigrationName)]
+pub struct Migration;
+
+#[async_trait::async_trait]
+impl MigrationTrait for Migration {
+    async fn up(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        manager
+            .alter_table(
+                Table::alter()
+                    .table(Artists::Table)
+                    .add_column(
+                        ColumnDef::new(Artists::Monitored)
+                            .boolean()
+                            .not_null()
+                            .default(false),
+                    )
+                    .to_owned(),
+            )
+            .await?;
+
+        manager
+            .alter_table(
+                Table::alter()
+                    .table(Artists::Table)
+                    .add_column(ColumnDef::new(Artists::LastCheckedAt).timestamp())
+                    .to_owned(),
+            )
+            .await
+    }
+
+    async fn down(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        manager
+            .alter_table(
+                Table::alter()
+                    .table(Artists::Table)
+                    .drop_column(Artists::LastCheckedAt)
+                    .to_owned(),
+            )
+            .await?;
+
+        manager
+            .alter_table(
+                Table::alter()
+                    .table(Artists::Table)
+                    .drop_column(Artists::Monitored)
+                    .to_owned(),
+            )
+            .await
+    }
+}
+
+#[derive(DeriveIden)]
+enum Artists {
+    Table,
+    Monitored,
+    LastCheckedAt,
+}

src/migration/m20260320_000014_create_playlists.rs

@@ -0,0 +1,136 @@
+use sea_orm_migration::prelude::*;
+
+#[derive(DeriveMigrationName)]
+pub struct Migration;
+
+#[async_trait::async_trait]
+impl MigrationTrait for Migration {
+    async fn up(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        manager
+            .create_table(
+                Table::create()
+                    .table(Playlists::Table)
+                    .if_not_exists()
+                    .col(
+                        ColumnDef::new(Playlists::Id)
+                            .integer()
+                            .not_null()
+                            .auto_increment()
+                            .primary_key(),
+                    )
+                    .col(ColumnDef::new(Playlists::Name).text().not_null())
+                    .col(ColumnDef::new(Playlists::Description).text())
+                    .col(ColumnDef::new(Playlists::UserId).integer())
+                    .col(
+                        ColumnDef::new(Playlists::CreatedAt)
+                            .date_time()
+                            .not_null()
+                            .default(Expr::current_timestamp()),
+                    )
+                    .col(
+                        ColumnDef::new(Playlists::UpdatedAt)
+                            .date_time()
+                            .not_null()
+                            .default(Expr::current_timestamp()),
+                    )
+                    .foreign_key(
+                        ForeignKey::create()
+                            .from(Playlists::Table, Playlists::UserId)
+                            .to(Users::Table, Users::Id),
+                    )
+                    .to_owned(),
+            )
+            .await?;
+
+        manager
+            .create_table(
+                Table::create()
+                    .table(PlaylistTracks::Table)
+                    .if_not_exists()
+                    .col(
+                        ColumnDef::new(PlaylistTracks::Id)
+                            .integer()
+                            .not_null()
+                            .auto_increment()
+                            .primary_key(),
+                    )
+                    .col(
+                        ColumnDef::new(PlaylistTracks::PlaylistId)
+                            .integer()
+                            .not_null(),
+                    )
+                    .col(ColumnDef::new(PlaylistTracks::TrackId).integer().not_null())
+                    .col(
+                        ColumnDef::new(PlaylistTracks::Position)
+                            .integer()
+                            .not_null(),
+                    )
+                    .foreign_key(
+                        ForeignKey::create()
+                            .from(PlaylistTracks::Table, PlaylistTracks::PlaylistId)
+                            .to(Playlists::Table, Playlists::Id)
+                            .on_delete(ForeignKeyAction::Cascade),
+                    )
+                    .foreign_key(
+                        ForeignKey::create()
+                            .from(PlaylistTracks::Table, PlaylistTracks::TrackId)
+                            .to(Tracks::Table, Tracks::Id),
+                    )
+                    .to_owned(),
+            )
+            .await?;
+
+        manager
+            .create_index(
+                Index::create()
+                    .name("idx_playlist_tracks_unique")
+                    .table(PlaylistTracks::Table)
+                    .col(PlaylistTracks::PlaylistId)
+                    .col(PlaylistTracks::Position)
+                    .unique()
+                    .to_owned(),
+            )
+            .await
+    }
+
+    async fn down(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        manager
+            .drop_table(Table::drop().table(PlaylistTracks::Table).to_owned())
+            .await?;
+        manager
+            .drop_table(Table::drop().table(Playlists::Table).to_owned())
+            .await
+    }
+}
+
+#[derive(DeriveIden)]
+enum Playlists {
+    Table,
+    Id,
+    Name,
+    Description,
+    UserId,
+    CreatedAt,
+    UpdatedAt,
+}
+
+#[derive(DeriveIden)]
+enum PlaylistTracks {
+    Table,
+    Id,
+    PlaylistId,
+    TrackId,
+    Position,
+}
+
+#[derive(DeriveIden)]
+enum Users {
+    Table,
+    Id,
+}
+
+#[derive(DeriveIden)]
+enum Tracks {
+    Table,
+    Id,
+}

src/migration/m20260320_000015_add_subsonic_password.rs

@@ -0,0 +1,35 @@
+use sea_orm_migration::prelude::*;
+
+#[derive(DeriveMigrationName)]
+pub struct Migration;
+
+#[async_trait::async_trait]
+impl MigrationTrait for Migration {
+    async fn up(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        manager
+            .alter_table(
+                Table::alter()
+                    .table(Users::Table)
+                    .add_column(ColumnDef::new(Users::SubsonicPassword).text())
+                    .to_owned(),
+            )
+            .await
+    }
+
+    async fn down(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        manager
+            .alter_table(
+                Table::alter()
+                    .table(Users::Table)
+                    .drop_column(Users::SubsonicPassword)
+                    .to_owned(),
+            )
+            .await
+    }
+}
+
+#[derive(DeriveIden)]
+enum Users {
+    Table,
+    SubsonicPassword,
+}

src/migration/mod.rs

@@ -9,6 +9,11 @@ mod m20260317_000006_create_search_cache;
 mod m20260317_000007_unique_artist_album;
 mod m20260317_000009_add_wanted_name;
 mod m20260317_000010_add_wanted_mbid;
+mod m20260319_000011_create_users;
+mod m20260319_000012_add_user_id_to_wanted_items;
+mod m20260320_000013_add_artist_monitoring;
+mod m20260320_000014_create_playlists;
+mod m20260320_000015_add_subsonic_password;
 
 pub struct Migrator;
 
@@ -25,6 +30,11 @@ impl MigratorTrait for Migrator {
             Box::new(m20260317_000007_unique_artist_album::Migration),
             Box::new(m20260317_000009_add_wanted_name::Migration),
             Box::new(m20260317_000010_add_wanted_mbid::Migration),
+            Box::new(m20260319_000011_create_users::Migration),
+            Box::new(m20260319_000012_add_user_id_to_wanted_items::Migration),
+            Box::new(m20260320_000013_add_artist_monitoring::Migration),
+            Box::new(m20260320_000014_create_playlists::Migration),
+            Box::new(m20260320_000015_add_subsonic_password::Migration),
         ]
     }
 }

src/queries/artists.rs

@@ -38,6 +38,8 @@ pub async fn upsert(
         added_at: Set(now),
         top_songs: Set("[]".to_string()),
         similar_artists: Set("[]".to_string()),
+        monitored: Set(false),
+        last_checked_at: Set(None),
         ..Default::default()
     };
     match active.insert(db).await {
@@ -109,3 +111,25 @@ pub async fn delete(db: &DatabaseConnection, id: i32) -> DbResult<()> {
     Artists::delete_by_id(id).exec(db).await?;
     Ok(())
 }
+
+pub async fn set_monitored(db: &DatabaseConnection, id: i32, monitored: bool) -> DbResult<Artist> {
+    let existing = get_by_id(db, id).await?;
+    let mut active: ActiveModel = existing.into();
+    active.monitored = Set(monitored);
+    Ok(active.update(db).await?)
+}
+
+pub async fn list_monitored(db: &DatabaseConnection) -> DbResult<Vec<Artist>> {
+    Ok(Artists::find()
+        .filter(artist::Column::Monitored.eq(true))
+        .order_by_asc(artist::Column::Name)
+        .all(db)
+        .await?)
+}
+
+pub async fn update_last_checked(db: &DatabaseConnection, id: i32) -> DbResult<Artist> {
+    let existing = get_by_id(db, id).await?;
+    let mut active: ActiveModel = existing.into();
+    active.last_checked_at = Set(Some(Utc::now().naive_utc()));
+    Ok(active.update(db).await?)
+}

src/queries/mod.rs

@@ -2,5 +2,7 @@ pub mod albums;
 pub mod artists;
 pub mod cache;
 pub mod downloads;
+pub mod playlists;
 pub mod tracks;
+pub mod users;
 pub mod wanted;

src/queries/playlists.rs

@@ -0,0 +1,178 @@
+use chrono::Utc;
+use sea_orm::*;
+
+use crate::entities::playlist::{self, ActiveModel, Entity as Playlists, Model as Playlist};
+use crate::entities::playlist_track::{
+    self, ActiveModel as TrackActiveModel, Entity as PlaylistTracks,
+};
+use crate::entities::track::{Entity as Tracks, Model as Track};
+use crate::error::{DbError, DbResult};
+
+pub async fn create(
+    db: &DatabaseConnection,
+    name: &str,
+    description: Option<&str>,
+    user_id: Option<i32>,
+    track_ids: &[i32],
+) -> DbResult<Playlist> {
+    let now = Utc::now().naive_utc();
+    let active = ActiveModel {
+        name: Set(name.to_string()),
+        description: Set(description.map(String::from)),
+        user_id: Set(user_id),
+        created_at: Set(now),
+        updated_at: Set(now),
+        ..Default::default()
+    };
+    let playlist = active.insert(db).await?;
+
+    // Insert tracks with positions
+    for (pos, track_id) in track_ids.iter().enumerate() {
+        let pt = TrackActiveModel {
+            playlist_id: Set(playlist.id),
+            track_id: Set(*track_id),
+            position: Set(pos as i32),
+            ..Default::default()
+        };
+        pt.insert(db).await?;
+    }
+
+    Ok(playlist)
+}
+
+pub async fn list(db: &DatabaseConnection, user_id: Option<i32>) -> DbResult<Vec<Playlist>> {
+    let mut query = Playlists::find().order_by_desc(playlist::Column::CreatedAt);
+    if let Some(uid) = user_id {
+        query = query.filter(playlist::Column::UserId.eq(uid));
+    }
+    Ok(query.all(db).await?)
+}
+
+pub async fn get_by_id(db: &DatabaseConnection, id: i32) -> DbResult<Playlist> {
+    Playlists::find_by_id(id)
+        .one(db)
+        .await?
+        .ok_or_else(|| DbError::NotFound(format!("playlist id={id}")))
+}
+
+pub async fn get_tracks(db: &DatabaseConnection, playlist_id: i32) -> DbResult<Vec<Track>> {
+    // Get playlist_tracks ordered by position, then join with tracks
+    let pt_list = PlaylistTracks::find()
+        .filter(playlist_track::Column::PlaylistId.eq(playlist_id))
+        .order_by_asc(playlist_track::Column::Position)
+        .all(db)
+        .await?;
+
+    let mut tracks = Vec::with_capacity(pt_list.len());
+    for pt in pt_list {
+        if let Some(track) = Tracks::find_by_id(pt.track_id).one(db).await? {
+            tracks.push(track);
+        }
+    }
+    Ok(tracks)
+}
+
+pub async fn get_track_count(db: &DatabaseConnection, playlist_id: i32) -> DbResult<u64> {
+    let count = PlaylistTracks::find()
+        .filter(playlist_track::Column::PlaylistId.eq(playlist_id))
+        .count(db)
+        .await?;
+    Ok(count)
+}
+
+pub async fn update(
+    db: &DatabaseConnection,
+    id: i32,
+    name: Option<&str>,
+    description: Option<&str>,
+) -> DbResult<Playlist> {
+    let existing = get_by_id(db, id).await?;
+    let mut active: ActiveModel = existing.into();
+    if let Some(n) = name {
+        active.name = Set(n.to_string());
+    }
+    if let Some(d) = description {
+        active.description = Set(Some(d.to_string()));
+    }
+    active.updated_at = Set(Utc::now().naive_utc());
+    Ok(active.update(db).await?)
+}
+
+pub async fn delete(db: &DatabaseConnection, id: i32) -> DbResult<()> {
+    // playlist_tracks cascade-deleted by FK
+    Playlists::delete_by_id(id).exec(db).await?;
+    Ok(())
+}
+
+pub async fn add_track(db: &DatabaseConnection, playlist_id: i32, track_id: i32) -> DbResult<()> {
+    // Get max position for this playlist
+    let max_pos = PlaylistTracks::find()
+        .filter(playlist_track::Column::PlaylistId.eq(playlist_id))
+        .order_by_desc(playlist_track::Column::Position)
+        .one(db)
+        .await?
+        .map(|pt| pt.position)
+        .unwrap_or(-1);
+
+    let pt = TrackActiveModel {
+        playlist_id: Set(playlist_id),
+        track_id: Set(track_id),
+        position: Set(max_pos + 1),
+        ..Default::default()
+    };
+    pt.insert(db).await?;
+    Ok(())
+}
+
+pub async fn remove_track(
+    db: &DatabaseConnection,
+    playlist_id: i32,
+    track_id: i32,
+) -> DbResult<()> {
+    // Delete the playlist_track row
+    PlaylistTracks::delete_many()
+        .filter(playlist_track::Column::PlaylistId.eq(playlist_id))
+        .filter(playlist_track::Column::TrackId.eq(track_id))
+        .exec(db)
+        .await?;
+
+    // Renumber remaining positions
+    let remaining = PlaylistTracks::find()
+        .filter(playlist_track::Column::PlaylistId.eq(playlist_id))
+        .order_by_asc(playlist_track::Column::Position)
+        .all(db)
+        .await?;
+
+    for (i, pt) in remaining.into_iter().enumerate() {
+        let mut active: TrackActiveModel = pt.into();
+        active.position = Set(i as i32);
+        active.update(db).await?;
+    }
+
+    Ok(())
+}
+
+pub async fn reorder_tracks(
+    db: &DatabaseConnection,
+    playlist_id: i32,
+    track_ids: Vec<i32>,
+) -> DbResult<()> {
+    // Delete all playlist_tracks for this playlist
+    PlaylistTracks::delete_many()
+        .filter(playlist_track::Column::PlaylistId.eq(playlist_id))
+        .exec(db)
+        .await?;
+
+    // Re-insert with positions matching the vec order
+    for (pos, track_id) in track_ids.iter().enumerate() {
+        let pt = TrackActiveModel {
+            playlist_id: Set(playlist_id),
+            track_id: Set(*track_id),
+            position: Set(pos as i32),
+            ..Default::default()
+        };
+        pt.insert(db).await?;
+    }
+
+    Ok(())
+}

src/queries/tracks.rs

@@ -1,4 +1,5 @@
 use chrono::Utc;
+use sea_orm::sea_query::Expr;
 use sea_orm::*;
 
 use crate::entities::track::{self, ActiveModel, Entity as Tracks, Model as Track};
@@ -121,3 +122,66 @@ pub async fn delete(db: &DatabaseConnection, id: i32) -> DbResult<()> {
     Tracks::delete_by_id(id).exec(db).await?;
     Ok(())
 }
+
+/// Get tracks matching a genre (case-insensitive).
+pub async fn get_by_genre(db: &DatabaseConnection, genre: &str) -> DbResult<Vec<Track>> {
+    let pattern = format!("%{genre}%");
+    Ok(Tracks::find()
+        .filter(Expr::cust_with_values(
+            "LOWER(genre) LIKE LOWER(?)",
+            [pattern],
+        ))
+        .all(db)
+        .await?)
+}
+
+/// Get tracks by artist MusicBrainz ID (via the artist table).
+pub async fn get_by_artist_mbid(db: &DatabaseConnection, mbid: &str) -> DbResult<Vec<Track>> {
+    use crate::entities::artist;
+
+    // Find artist with this MBID
+    let artist = artist::Entity::find()
+        .filter(artist::Column::MusicbrainzId.eq(mbid))
+        .one(db)
+        .await?;
+
+    if let Some(a) = artist {
+        Ok(Tracks::find()
+            .filter(track::Column::ArtistId.eq(a.id))
+            .all(db)
+            .await?)
+    } else {
+        Ok(vec![])
+    }
+}
+
+/// Get random tracks.
+pub async fn get_random(db: &DatabaseConnection, count: u64) -> DbResult<Vec<Track>> {
+    Ok(Tracks::find()
+        .order_by(Expr::cust("RANDOM()"), Order::Asc)
+        .limit(count)
+        .all(db)
+        .await?)
+}
+
+/// Get tracks added within the last N days.
+pub async fn get_recent(db: &DatabaseConnection, days: u32, limit: u64) -> DbResult<Vec<Track>> {
+    let cutoff = Utc::now().naive_utc() - chrono::Duration::days(i64::from(days));
+    Ok(Tracks::find()
+        .filter(track::Column::AddedAt.gte(cutoff))
+        .order_by_desc(track::Column::AddedAt)
+        .limit(limit)
+        .all(db)
+        .await?)
+}
+
+/// Get tracks by artist name (case-insensitive match).
+pub async fn get_by_artist_name(db: &DatabaseConnection, name: &str) -> DbResult<Vec<Track>> {
+    Ok(Tracks::find()
+        .filter(Expr::cust_with_values(
+            "LOWER(artist) = LOWER(?)",
+            [name.to_string()],
+        ))
+        .all(db)
+        .await?)
+}

src/queries/users.rs

@@ -0,0 +1,80 @@
+use chrono::Utc;
+use sea_orm::*;
+
+use crate::entities::user::{self, ActiveModel, Entity as Users, Model as User, UserRole};
+use crate::error::{DbError, DbResult};
+
+pub async fn create(
+    db: &DatabaseConnection,
+    username: &str,
+    password_hash: &str,
+    role: UserRole,
+) -> DbResult<User> {
+    let now = Utc::now().naive_utc();
+    let active = ActiveModel {
+        username: Set(username.to_string()),
+        password_hash: Set(password_hash.to_string()),
+        role: Set(role),
+        created_at: Set(now),
+        updated_at: Set(now),
+        ..Default::default()
+    };
+    Ok(active.insert(db).await?)
+}
+
+pub async fn find_by_username(db: &DatabaseConnection, username: &str) -> DbResult<Option<User>> {
+    Ok(Users::find()
+        .filter(user::Column::Username.eq(username))
+        .one(db)
+        .await?)
+}
+
+pub async fn get_by_id(db: &DatabaseConnection, id: i32) -> DbResult<User> {
+    Users::find_by_id(id)
+        .one(db)
+        .await?
+        .ok_or_else(|| DbError::NotFound(format!("user id={id}")))
+}
+
+pub async fn list(db: &DatabaseConnection) -> DbResult<Vec<User>> {
+    Ok(Users::find()
+        .order_by_asc(user::Column::Username)
+        .all(db)
+        .await?)
+}
+
+pub async fn delete(db: &DatabaseConnection, id: i32) -> DbResult<()> {
+    Users::delete_by_id(id).exec(db).await?;
+    Ok(())
+}
+
+pub async fn count(db: &DatabaseConnection) -> DbResult<u64> {
+    Ok(Users::find().count(db).await?)
+}
+
+/// Set the Subsonic password for a user. Stored as plaintext per the Subsonic protocol.
+pub async fn set_subsonic_password(
+    db: &DatabaseConnection,
+    user_id: i32,
+    password: &str,
+) -> DbResult<User> {
+    let existing = get_by_id(db, user_id).await?;
+    let mut active: ActiveModel = existing.into();
+    active.subsonic_password = Set(Some(password.to_string()));
+    active.updated_at = Set(Utc::now().naive_utc());
+    Ok(active.update(db).await?)
+}
+
+/// Assign all orphaned wanted items (user_id IS NULL) to the given user.
+pub async fn adopt_orphaned_wanted_items(db: &DatabaseConnection, user_id: i32) -> DbResult<u64> {
+    use crate::entities::wanted_item;
+    let result = wanted_item::Entity::update_many()
+        .col_expr(
+            wanted_item::Column::UserId,
+            sea_orm::sea_query::Expr::value(user_id),
+        )
+        .filter(wanted_item::Column::UserId.is_null())
+        .exec(db)
+        .await?;
+    Ok(result.rows_affected)
+}

src/queries/wanted.rs

@@ -7,23 +7,26 @@ use crate::entities::wanted_item::{
 };
 use crate::error::{DbError, DbResult};
 
-pub async fn add(
+pub struct AddWantedItem<'a> {
-    db: &DatabaseConnection,
+    pub item_type: ItemType,
-    item_type: ItemType,
+    pub name: &'a str,
-    name: &str,
+    pub musicbrainz_id: Option<&'a str>,
-    musicbrainz_id: Option<&str>,
+    pub artist_id: Option<i32>,
-    artist_id: Option<i32>,
+    pub album_id: Option<i32>,
-    album_id: Option<i32>,
+    pub track_id: Option<i32>,
-    track_id: Option<i32>,
+    pub user_id: Option<i32>,
-) -> DbResult<WantedItem> {
+}
+
+pub async fn add(db: &DatabaseConnection, item: AddWantedItem<'_>) -> DbResult<WantedItem> {
     let now = Utc::now().naive_utc();
     let active = ActiveModel {
-        item_type: Set(item_type),
+        item_type: Set(item.item_type),
-        name: Set(name.to_string()),
+        name: Set(item.name.to_string()),
-        musicbrainz_id: Set(musicbrainz_id.map(String::from)),
+        musicbrainz_id: Set(item.musicbrainz_id.map(String::from)),
-        artist_id: Set(artist_id),
+        artist_id: Set(item.artist_id),
-        album_id: Set(album_id),
+        album_id: Set(item.album_id),
-        track_id: Set(track_id),
+        track_id: Set(item.track_id),
+        user_id: Set(item.user_id),
         status: Set(WantedStatus::Wanted),
         added_at: Set(now),
         updated_at: Set(now),
@@ -35,11 +38,15 @@ pub async fn add(
 pub async fn list(
     db: &DatabaseConnection,
     status_filter: Option<WantedStatus>,
+    user_id: Option<i32>,
 ) -> DbResult<Vec<WantedItem>> {
     let mut query = WantedItems::find();
     if let Some(status) = status_filter {
         query = query.filter(wanted_item::Column::Status.eq(status));
     }
+    if let Some(uid) = user_id {
+        query = query.filter(wanted_item::Column::UserId.eq(uid));
+    }
     Ok(query.all(db).await?)
 }
 

tests/integration.rs

@@ -167,12 +167,15 @@ async fn test_wanted_items_lifecycle() {
     // Add wanted item
     let item = queries::wanted::add(
         conn,
-        ItemType::Artist,
+        queries::wanted::AddWantedItem {
-        "Radiohead",
+            item_type: ItemType::Artist,
-        None,
+            name: "Radiohead",
-        Some(artist.id),
+            musicbrainz_id: None,
-        None,
+            artist_id: Some(artist.id),
-        None,
+            album_id: None,
+            track_id: None,
+            user_id: None,
+        },
     )
     .await
     .unwrap();
@@ -180,12 +183,12 @@ async fn test_wanted_items_lifecycle() {
     assert_eq!(item.item_type, ItemType::Artist);
 
     // List with filter
-    let wanted = queries::wanted::list(conn, Some(WantedStatus::Wanted))
+    let wanted = queries::wanted::list(conn, Some(WantedStatus::Wanted), None)
         .await
         .unwrap();
     assert_eq!(wanted.len(), 1);
 
-    let downloaded = queries::wanted::list(conn, Some(WantedStatus::Downloaded))
+    let downloaded = queries::wanted::list(conn, Some(WantedStatus::Downloaded), None)
         .await
         .unwrap();
     assert!(downloaded.is_empty());
@@ -198,7 +201,7 @@ async fn test_wanted_items_lifecycle() {
 
     // Remove
     queries::wanted::remove(conn, item.id).await.unwrap();
-    let all = queries::wanted::list(conn, None).await.unwrap();
+    let all = queries::wanted::list(conn, None, None).await.unwrap();
     assert!(all.is_empty());
 }