djsundog/ffplayout
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

unify tests

Browse Source
This commit is contained in:
jb-alvarado 2024-07-04 08:57:59 +02:00
parent c837124d61
commit 6de2ef7284
3 changed files with 41 additions and 116 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
tests/src/engine_generator.rs
View File

@ -4,7 +4,7 @@ use std::{
};
use chrono::NaiveTime;
use sqlx::{sqlite::SqlitePoolOptions, Pool, Sqlite};
use sqlx::sqlite::SqlitePoolOptions;
use tokio::runtime::Runtime;
use ffplayout::db::handles;
@ -16,7 +16,7 @@ use ffplayout::utils::{
generator::*,
};
async fn memory_db() -> Pool<Sqlite> {
async fn prepare_config() -> (PlayoutConfig, ChannelManager) {
let pool = SqlitePoolOptions::new()
.connect("sqlite::memory:")
.await
@ -34,11 +34,15 @@ async fn memory_db() -> Pool<Sqlite> {
.await
.unwrap();
pool
let config = PlayoutConfig::new(&pool, 1).await;
let channel = handles::select_channel(&pool, &1).await.unwrap();
let manager = ChannelManager::new(Some(pool), channel, config.clone());
(config, manager)
}
fn get_pool() -> Pool<Sqlite> {
Runtime::new().unwrap().block_on(memory_db())
fn get_config() -> (PlayoutConfig, ChannelManager) {
Runtime::new().unwrap().block_on(prepare_config())
}
#[test]
@ -82,10 +86,7 @@ fn test_ordered_list() {
#[test]
#[ignore]
fn test_filler_list() {
let pool = get_pool();
let mut config = Runtime::new()
.unwrap()
.block_on(PlayoutConfig::new(&pool, 1));
let (mut config, _) = get_config();
config.storage.filler = "assets/".into();
@ -97,15 +98,7 @@ fn test_filler_list() {
#[test]
#[ignore]
fn test_generate_playlist_from_folder() {
let pool = get_pool();
let mut config = Runtime::new()
.unwrap()
.block_on(PlayoutConfig::new(&pool, 1));
let channel = Runtime::new()
.unwrap()
.block_on(handles::select_channel(&pool, &1))
.unwrap();
let manager = ChannelManager::new(Some(pool), channel, config.clone());
let (mut config, manager) = get_config();
config.general.generate = Some(vec!["2023-09-11".to_string()]);
config.processing.mode = Playlist;
@ -134,15 +127,7 @@ fn test_generate_playlist_from_folder() {
#[test]
#[ignore]
fn test_generate_playlist_from_template() {
let pool = get_pool();
let mut config = Runtime::new()
.unwrap()
.block_on(PlayoutConfig::new(&pool, 1));
let channel = Runtime::new()
.unwrap()
.block_on(handles::select_channel(&pool, &1))
.unwrap();
let manager = ChannelManager::new(Some(pool), channel, config.clone());
let (mut config, manager) = get_config();
config.general.generate = Some(vec!["2023-09-12".to_string()]);
config.general.template = Some(Template {

94
tests/src/engine_playlist.rs
View File

@ -4,7 +4,7 @@ use std::{
};
use serial_test::serial;
use sqlx::{sqlite::SqlitePoolOptions, Pool, Sqlite};
use sqlx::sqlite::SqlitePoolOptions;
use tokio::runtime::Runtime;
use ffplayout::db::handles;
@ -15,7 +15,7 @@ use ffplayout::utils::config::OutputMode::Null;
use ffplayout::utils::config::{PlayoutConfig, ProcessMode::Playlist};
use ffplayout::vec_strings;
async fn memory_db() -> Pool<Sqlite> {
async fn prepare_config() -> (PlayoutConfig, ChannelManager) {
let pool = SqlitePoolOptions::new()
.connect("sqlite::memory:")
.await
@ -33,11 +33,15 @@ async fn memory_db() -> Pool<Sqlite> {
.await
.unwrap();
pool
let config = PlayoutConfig::new(&pool, 1).await;
let channel = handles::select_channel(&pool, &1).await.unwrap();
let manager = ChannelManager::new(Some(pool), channel, config.clone());
(config, manager)
}
fn get_pool() -> Pool<Sqlite> {
Runtime::new().unwrap().block_on(memory_db())
fn get_config() -> (PlayoutConfig, ChannelManager) {
Runtime::new().unwrap().block_on(prepare_config())
}
fn timed_stop(sec: u64, manager: ChannelManager) {
@ -51,15 +55,7 @@ fn timed_stop(sec: u64, manager: ChannelManager) {
#[test]
#[ignore]
fn test_gen_source() {
let pool = get_pool();
let mut config = Runtime::new()
.unwrap()
.block_on(PlayoutConfig::new(&pool, 1));
let channel = Runtime::new()
.unwrap()
.block_on(handles::select_channel(&pool, &1))
.unwrap();
let manager = ChannelManager::new(Some(pool), channel, config.clone());
let (mut config, manager) = get_config();
config.general.skip_validation = true;
config.mail.recipient = "".into();
@ -105,15 +101,7 @@ fn test_gen_source() {
#[serial]
#[ignore]
fn playlist_missing() {
let pool = get_pool();
let mut config = Runtime::new()
.unwrap()
.block_on(PlayoutConfig::new(&pool, 1));
let channel = Runtime::new()
.unwrap()
.block_on(handles::select_channel(&pool, &1))
.unwrap();
let manager = ChannelManager::new(Some(pool), channel, config.clone());
let (mut config, manager) = get_config();
let manager_clone = manager.clone();
config.general.skip_validation = true;
@ -147,15 +135,7 @@ fn playlist_missing() {
#[serial]
#[ignore]
fn playlist_next_missing() {
let pool = get_pool();
let mut config = Runtime::new()
.unwrap()
.block_on(PlayoutConfig::new(&pool, 1));
let channel = Runtime::new()
.unwrap()
.block_on(handles::select_channel(&pool, &1))
.unwrap();
let manager = ChannelManager::new(Some(pool), channel, config.clone());
let (mut config, manager) = get_config();
let manager_clone = manager.clone();
config.general.skip_validation = true;
@ -189,15 +169,7 @@ fn playlist_next_missing() {
#[serial]
#[ignore]
fn playlist_to_short() {
let pool = get_pool();
let mut config = Runtime::new()
.unwrap()
.block_on(PlayoutConfig::new(&pool, 1));
let channel = Runtime::new()
.unwrap()
.block_on(handles::select_channel(&pool, &1))
.unwrap();
let manager = ChannelManager::new(Some(pool), channel, config.clone());
let (mut config, manager) = get_config();
let manager_clone = manager.clone();
config.general.skip_validation = true;
@ -231,15 +203,7 @@ fn playlist_to_short() {
#[serial]
#[ignore]
fn playlist_init_after_list_end() {
let pool = get_pool();
let mut config = Runtime::new()
.unwrap()
.block_on(PlayoutConfig::new(&pool, 1));
let channel = Runtime::new()
.unwrap()
.block_on(handles::select_channel(&pool, &1))
.unwrap();
let manager = ChannelManager::new(Some(pool), channel, config.clone());
let (mut config, manager) = get_config();
let manager_clone = manager.clone();
config.general.skip_validation = true;
@ -273,15 +237,7 @@ fn playlist_init_after_list_end() {
#[serial]
#[ignore]
fn playlist_change_at_midnight() {
let pool = get_pool();
let mut config = Runtime::new()
.unwrap()
.block_on(PlayoutConfig::new(&pool, 1));
let channel = Runtime::new()
.unwrap()
.block_on(handles::select_channel(&pool, &1))
.unwrap();
let manager = ChannelManager::new(Some(pool), channel, config.clone());
let (mut config, manager) = get_config();
let manager_clone = manager.clone();
config.general.skip_validation = true;
@ -315,15 +271,7 @@ fn playlist_change_at_midnight() {
#[serial]
#[ignore]
fn playlist_change_before_midnight() {
let pool = get_pool();
let mut config = Runtime::new()
.unwrap()
.block_on(PlayoutConfig::new(&pool, 1));
let channel = Runtime::new()
.unwrap()
.block_on(handles::select_channel(&pool, &1))
.unwrap();
let manager = ChannelManager::new(Some(pool), channel, config.clone());
let (mut config, manager) = get_config();
let manager_clone = manager.clone();
config.general.skip_validation = true;
@ -357,15 +305,7 @@ fn playlist_change_before_midnight() {
#[serial]
#[ignore]
fn playlist_change_at_six() {
let pool = get_pool();
let mut config = Runtime::new()
.unwrap()
.block_on(PlayoutConfig::new(&pool, 1));
let channel = Runtime::new()
.unwrap()
.block_on(handles::select_channel(&pool, &1))
.unwrap();
let manager = ChannelManager::new(Some(pool), channel, config.clone());
let (mut config, manager) = get_config();
let manager_clone = manager.clone();
config.general.skip_validation = true;

24
tests/src/lib_utils.rs
View File

@ -1,4 +1,4 @@
use sqlx::{sqlite::SqlitePoolOptions, Pool, Sqlite};
use sqlx::sqlite::SqlitePoolOptions;
use tokio::runtime::Runtime;
#[cfg(test)]
@ -6,11 +6,10 @@ use chrono::prelude::*;
#[cfg(test)]
use ffplayout::db::handles;
use ffplayout::player::utils::*;
use ffplayout::utils::config::PlayoutConfig;
use ffplayout::utils::config::ProcessMode::Playlist;
use ffplayout::player::{controller::ChannelManager, utils::*};
use ffplayout::utils::config::{PlayoutConfig, ProcessMode::Playlist};
async fn memory_db() -> Pool<Sqlite> {
async fn prepare_config() -> (PlayoutConfig, ChannelManager) {
let pool = SqlitePoolOptions::new()
.connect("sqlite::memory:")
.await
@ -28,11 +27,15 @@ async fn memory_db() -> Pool<Sqlite> {
.await
.unwrap();
pool
let config = PlayoutConfig::new(&pool, 1).await;
let channel = handles::select_channel(&pool, &1).await.unwrap();
let manager = ChannelManager::new(Some(pool), channel, config.clone());
(config, manager)
}
fn get_pool() -> Pool<Sqlite> {
Runtime::new().unwrap().block_on(memory_db())
fn get_config() -> (PlayoutConfig, ChannelManager) {
Runtime::new().unwrap().block_on(prepare_config())
}
#[test]
@ -69,10 +72,7 @@ fn get_date_tomorrow() {
#[test]
fn test_delta() {
let pool = get_pool();
let mut config = Runtime::new()
.unwrap()
.block_on(PlayoutConfig::new(&pool, 1));
let (mut config, _) = get_config();
config.mail.recipient = "".into();
config.processing.mode = Playlist;