Skip to content

Commit

Permalink
[server] update tests
Browse files Browse the repository at this point in the history
  • Loading branch information
tsirysndr committed Aug 25, 2024
1 parent ac329c3 commit 7ba2ee7
Showing 1 changed file with 7 additions and 63 deletions.
70 changes: 7 additions & 63 deletions server/src/tests/library.rs
Original file line number Diff line number Diff line change
Expand Up @@ -19,18 +19,10 @@ use super::setup_new_params;

#[tokio::test]
async fn scan() {
let (_backend, _audio_format, cmd_tx, _cmd_rx, tracklist, db, addr, url) =
let (_backend, _audio_format, cmd_tx, _cmd_rx, tracklist, db, addr, url, user_data) =
setup_new_params(7070).await;
let (tx, rx) = oneshot::channel();
let jh = tokio::spawn(async move {
let user_data = UserData::new(State {
player_cmd_tx: Arc::clone(&cmd_tx),
tracklist: Arc::clone(&tracklist),
db: db.clone(),
addons: vec![],
addon_capabilities: vec![],
});

Server::builder()
.accept_http1(true)
.add_service(tonic_web::enable(LibraryServiceServer::new(Library::new(
Expand All @@ -52,18 +44,10 @@ async fn scan() {

#[tokio::test]
async fn search() {
let (_backend, _audio_format, cmd_tx, _cmd_rx, tracklist, db, addr, url) =
let (_backend, _audio_format, cmd_tx, _cmd_rx, tracklist, db, addr, url, user_data) =
setup_new_params(7071).await;
let (tx, rx) = oneshot::channel();
let jh = tokio::spawn(async move {
let user_data = UserData::new(State {
player_cmd_tx: Arc::clone(&cmd_tx),
tracklist: Arc::clone(&tracklist),
db: db.clone(),
addons: vec![],
addon_capabilities: vec![],
});

Server::builder()
.accept_http1(true)
.add_service(tonic_web::enable(LibraryServiceServer::new(Library::new(
Expand All @@ -82,18 +66,10 @@ async fn search() {

#[tokio::test]
async fn get_artists() -> Result<(), Box<dyn std::error::Error>> {
let (_backend, _audio_format, cmd_tx, _cmd_rx, tracklist, db, addr, url) =
let (_backend, _audio_format, cmd_tx, _cmd_rx, tracklist, db, addr, url, user_data) =
setup_new_params(6072).await;
let (tx, rx) = oneshot::channel();
let jh = tokio::spawn(async move {
let user_data = UserData::new(State {
player_cmd_tx: Arc::clone(&cmd_tx),
tracklist: Arc::clone(&tracklist),
db: db.clone(),
addons: vec![],
addon_capabilities: vec![],
});

Server::builder()
.accept_http1(true)
.add_service(tonic_web::enable(LibraryServiceServer::new(Library::new(
Expand Down Expand Up @@ -126,18 +102,10 @@ async fn get_artists() -> Result<(), Box<dyn std::error::Error>> {

#[tokio::test]
async fn get_albums() {
let (_backend, _audio_format, cmd_tx, _cmd_rx, tracklist, db, addr, url) =
let (_backend, _audio_format, cmd_tx, _cmd_rx, tracklist, db, addr, url, user_data) =
setup_new_params(5073).await;
let (tx, rx) = oneshot::channel();
let jh = tokio::spawn(async move {
let user_data = UserData::new(State {
player_cmd_tx: Arc::clone(&cmd_tx),
tracklist: Arc::clone(&tracklist),
db: db.clone(),
addons: vec![],
addon_capabilities: vec![],
});

Server::builder()
.accept_http1(true)
.add_service(tonic_web::enable(LibraryServiceServer::new(Library::new(
Expand Down Expand Up @@ -166,18 +134,10 @@ async fn get_albums() {

#[tokio::test]
async fn get_tracks() {
let (_backend, _audio_format, cmd_tx, _cmd_rx, tracklist, db, addr, url) =
let (_backend, _audio_format, cmd_tx, _cmd_rx, tracklist, db, addr, url, user_data) =
setup_new_params(7074).await;
let (tx, rx) = oneshot::channel();
let jh = tokio::spawn(async move {
let user_data = UserData::new(State {
player_cmd_tx: Arc::clone(&cmd_tx),
tracklist: Arc::clone(&tracklist),
db: db.clone(),
addons: vec![],
addon_capabilities: vec![],
});

Server::builder()
.accept_http1(true)
.add_service(tonic_web::enable(LibraryServiceServer::new(Library::new(
Expand Down Expand Up @@ -224,18 +184,10 @@ async fn get_tracks() {

#[tokio::test]
async fn get_track_details() {
let (_backend, _audio_format, cmd_tx, _cmd_rx, tracklist, db, addr, url) =
let (_backend, _audio_format, cmd_tx, _cmd_rx, tracklist, db, addr, url, user_data) =
setup_new_params(7075).await;
let (tx, rx) = oneshot::channel::<()>();
let jh = tokio::spawn(async move {
let user_data = UserData::new(State {
player_cmd_tx: Arc::clone(&cmd_tx),
tracklist: Arc::clone(&tracklist),
db: db.clone(),
addons: vec![],
addon_capabilities: vec![],
});

Server::builder()
.accept_http1(true)
.add_service(tonic_web::enable(LibraryServiceServer::new(Library::new(
Expand Down Expand Up @@ -269,18 +221,10 @@ async fn get_track_details() {

#[tokio::test]
async fn get_album_details() {
let (_backend, _audio_format, cmd_tx, _cmd_rx, tracklist, db, addr, url) =
let (_backend, _audio_format, cmd_tx, _cmd_rx, tracklist, db, addr, url, user_data) =
setup_new_params(7076).await;
let (tx, rx) = oneshot::channel::<()>();
let jh = tokio::spawn(async move {
let user_data = UserData::new(State {
player_cmd_tx: Arc::clone(&cmd_tx),
tracklist: Arc::clone(&tracklist),
db: db.clone(),
addons: vec![],
addon_capabilities: vec![],
});

Server::builder()
.accept_http1(true)
.add_service(tonic_web::enable(LibraryServiceServer::new(Library::new(
Expand Down

0 comments on commit 7ba2ee7

Please sign in to comment.