Compare commits

...

6 commits

3 changed files with 27 additions and 13 deletions

View file

@ -29,10 +29,14 @@ jobs:
- name: 🧪 Test - name: 🧪 Test
run: | run: |
echo "${{ secrets.RUSTYPIPE_CACHE }}" > rustypipe_cache.json printf "$RUSTYPIPE_CACHE" > rustypipe_cache.json
ls
head -n 1 rustypipe_cache.json
RUST_LOG=debug cargo test --package rustypipe --test youtube --features rss -- user_login --exact --nocapture
cargo nextest run --config-file ~/.config/nextest.toml --profile ci --retries 2 --features rss --workspace cargo nextest run --config-file ~/.config/nextest.toml --profile ci --retries 2 --features rss --workspace
env: env:
ALL_PROXY: "http://warpproxy:8124" ALL_PROXY: "http://warpproxy:8124"
RUSTYPIPE_CACHE: "${{ secrets.RUSTYPIPE_CACHE }}"
- name: 💌 Upload test report - name: 💌 Upload test report
if: always() if: always()

View file

@ -605,17 +605,17 @@ impl RustyPipeBuilder {
Box::new(FileStorage::new(cache_file)) Box::new(FileStorage::new(cache_file))
}); });
let mut cdata = storage let mut cdata = if let Some(data) = storage.as_ref().and_then(|storage| storage.read()) {
.as_ref() match serde_json::from_str::<CacheData>(&data) {
.and_then(|storage| storage.read()) Ok(data) => data,
.and_then(|data| match serde_json::from_str::<CacheData>(&data) {
Ok(data) => Some(data),
Err(e) => { Err(e) => {
tracing::error!("Could not deserialize cache. Error: {}", e); tracing::error!("Could not deserialize cache. Error: {}", e);
None CacheData::default()
} }
}) }
.unwrap_or_default(); } else {
CacheData::default()
};
let cache_clients = [ let cache_clients = [
ClientType::Desktop, ClientType::Desktop,

View file

@ -7,6 +7,7 @@ use std::str::FromStr;
use rstest::{fixture, rstest}; use rstest::{fixture, rstest};
use rustypipe::param::{AlbumOrder, LANGUAGES}; use rustypipe::param::{AlbumOrder, LANGUAGES};
use time::{macros::date, OffsetDateTime}; use time::{macros::date, OffsetDateTime};
use tracing_test::traced_test;
use rustypipe::client::{ClientType, RustyPipe, RustyPipeQuery}; use rustypipe::client::{ClientType, RustyPipe, RustyPipeQuery};
use rustypipe::error::{Error, ExtractionError, UnavailabilityReason}; use rustypipe::error::{Error, ExtractionError, UnavailabilityReason};
@ -246,10 +247,10 @@ async fn get_player(
#[case] is_live_content: bool, #[case] is_live_content: bool,
rp: RustyPipe, rp: RustyPipe,
) { ) {
if id == "ZDKQmBWTRnw" && !rp.query().auth_enabled() { // if id == "ZDKQmBWTRnw" && !rp.query().auth_enabled() {
tracing::warn!("unauthenticated; age-limited video cannot be tested"); // tracing::warn!("unauthenticated; age-limited video cannot be tested");
return; // return;
} // }
let player_data = rp.query().player(id).await.unwrap(); let player_data = rp.query().player(id).await.unwrap();
let details = player_data.details; let details = player_data.details;
@ -2675,6 +2676,15 @@ async fn isrc_search_languages(rp: RustyPipe) {
} }
} }
#[rstest]
#[tokio::test]
#[traced_test]
async fn user_login(rp: RustyPipe) {
tracing::debug!("test");
assert!(rp.query().auth_enabled());
rp.user_auth_check_login().await.unwrap();
}
//#TESTUTIL //#TESTUTIL
/// Get the language setting from the environment variable /// Get the language setting from the environment variable