Compiling stream_server v0.2.0 (/home/senke/Documents/veza/veza-stream-server) error[E0425]: cannot find function `create_test_listener` in this scope --> src/core/sync.rs:1152:28 | 1152 | let mut listener = create_test_listener(listener_id, Some(0)); // Helper from existing tests | ^^^^^^^^^^^^^^^^^^^^ not found in this scope | note: function `crate::core::sync::tests::create_test_listener` exists but is inaccessible --> src/core/sync.rs:935:5 | 935 | fn create_test_listener(id: Uuid, position_ms: Option) -> Listener { | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ not accessible warning: unused import: `DecodedAudio` --> src/audio/pipeline.rs:12:49 | 12 | use crate::codecs::{AudioDecoder, AudioEncoder, DecodedAudio, DecoderInfo, EncoderInfo}; | ^^^^^^^^^^^^ | = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default warning: unused import: `AppError` --> src/audio/pipeline.rs:13:20 | 13 | use crate::error::{AppError, Result as AppResult}; | ^^^^^^^^ warning: unused import: `std::sync::Arc` --> src/audio/pipeline.rs:14:5 | 14 | use std::sync::Arc; | ^^^^^^^^^^^^^^ warning: unused import: `std::time::Duration` --> src/audio/pipeline.rs:16:5 | 16 | use std::time::Duration; | ^^^^^^^^^^^^^^^^^^^ warning: unused imports: `Deserialize` and `Serialize` --> src/audio/realtime.rs:4:13 | 4 | use serde::{Deserialize, Serialize}; | ^^^^^^^^^^^ ^^^^^^^^^ warning: unused import: `SystemTime` --> src/audio/realtime.rs:11:36 | 11 | use std::time::{Duration, Instant, SystemTime}; | ^^^^^^^^^^ warning: unused import: `effects::*` --> src/audio/mod.rs:12:9 | 12 | pub use effects::*; | ^^^^^^^^^^ warning: unused import: `std::collections::hash_map::DefaultHasher` --> src/cache/audio_cache.rs:2:5 | 2 | use std::collections::hash_map::DefaultHasher; | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ warning: unused import: `std::time::Duration` --> src/cache/audio_cache.rs:330:9 | 330 | use std::time::Duration; | ^^^^^^^^^^^^^^^^^^^ warning: unused imports: `AudioSampleFormat`, `CodecQuality`, and `LatencyMode` --> src/codecs/flac.rs:2:33 | 2 | AudioDecoder, AudioEncoder, AudioSampleFormat, CodecQuality, DecodedAudio, DecoderConfig, | ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^ 3 | DecoderInfo, EncoderConfig, EncoderInfo, EncoderMetrics, LatencyMode, | ^^^^^^^^^^^ warning: unused imports: `Deserialize` and `Serialize` --> src/codecs/flac.rs:6:13 | 6 | use serde::{Deserialize, Serialize}; | ^^^^^^^^^^^ ^^^^^^^^^ warning: unused import: `std::collections::HashMap` --> src/codecs/flac.rs:14:5 | 14 | use std::collections::HashMap; | ^^^^^^^^^^^^^^^^^^^^^^^^^ warning: unused import: `SystemTime` --> src/codecs/flac.rs:15:26 | 15 | use std::time::{Instant, SystemTime}; | ^^^^^^^^^^ warning: unused imports: `AudioFrame`, `CodecConfig`, `DecodingResult`, and `EncodingResult` --> src/codecs/mp3.rs:19:33 | 19 | AudioDecoder, AudioEncoder, AudioFrame, CodecConfig, CodecQuality, DecoderConfig, | ^^^^^^^^^^ ^^^^^^^^^^^ 20 | DecodingResult, EncoderConfig, EncodingResult, | ^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^ warning: unused import: `mpsc` --> src/core/buffer.rs:15:19 | 15 | use tokio::sync::{mpsc, Mutex}; | ^^^^ warning: unused import: `mpsc` --> src/core/stream.rs:10:30 | 10 | use tokio::sync::{broadcast, mpsc}; | ^^^^ warning: unused imports: `RwLock as TokioRwLock` and `mpsc` --> src/core/sync.rs:18:30 | 18 | use tokio::sync::{broadcast, mpsc, RwLock as TokioRwLock}; | ^^^^ ^^^^^^^^^^^^^^^^^^^^^ warning: unused imports: `Error as LapinError` and `ExchangeKind` --> src/event_bus.rs:3:5 | 3 | Error as LapinError, ExchangeKind, | ^^^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^ warning: unused import: `UNIX_EPOCH` --> src/monitoring/alerting.rs:7:39 | 7 | use std::time::{Duration, SystemTime, UNIX_EPOCH}; | ^^^^^^^^^^ warning: unused import: `Instant` --> src/monitoring/prometheus_metrics.rs:3:27 | 3 | use std::time::{Duration, Instant}; | ^^^^^^^ warning: unused imports: `Deserialize` and `Serialize` --> src/monitoring/prometheus_metrics.rs:6:13 | 6 | use serde::{Deserialize, Serialize}; | ^^^^^^^^^^^ ^^^^^^^^^ warning: unused import: `Duration` --> src/monitoring/tracing_module.rs:4:17 | 4 | use std::time::{Duration, SystemTime}; | ^^^^^^^^ warning: unused import: `SystemHealth` --> src/monitoring/mod.rs:27:35 | 27 | use health_checks::{HealthConfig, SystemHealth}; | ^^^^^^^^^^^^ warning: private item shadows public glob re-export --> src/monitoring/mod.rs:27:21 | 27 | use health_checks::{HealthConfig, SystemHealth}; | ^^^^^^^^^^^^ | note: the name `HealthConfig` in the type namespace is supposed to be publicly re-exported here --> src/monitoring/mod.rs:14:9 | 14 | pub use health_checks::*; | ^^^^^^^^^^^^^^^^ note: but the private item here shadows it --> src/monitoring/mod.rs:27:21 | 27 | use health_checks::{HealthConfig, SystemHealth}; | ^^^^^^^^^^^^ = note: `#[warn(hidden_glob_reexports)]` on by default warning: private item shadows public glob re-export --> src/monitoring/mod.rs:27:35 | 27 | use health_checks::{HealthConfig, SystemHealth}; | ^^^^^^^^^^^^ | note: the name `SystemHealth` in the type namespace is supposed to be publicly re-exported here --> src/monitoring/mod.rs:14:9 | 14 | pub use health_checks::*; | ^^^^^^^^^^^^^^^^ note: but the private item here shadows it --> src/monitoring/mod.rs:27:35 | 27 | use health_checks::{HealthConfig, SystemHealth}; | ^^^^^^^^^^^^ warning: private item shadows public glob re-export --> src/monitoring/mod.rs:28:5 | 28 | use tracing_module::TracingConfig; | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ | note: the name `TracingConfig` in the type namespace is supposed to be publicly re-exported here --> src/monitoring/mod.rs:17:9 | 17 | pub use tracing_module::*; | ^^^^^^^^^^^^^^^^^ note: but the private item here shadows it --> src/monitoring/mod.rs:28:5 | 28 | use tracing_module::TracingConfig; | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ warning: unused import: `IntoResponse` --> src/routes/encoding.rs:14:16 | 14 | response::{IntoResponse, Response}, | ^^^^^^^^^^^^ warning: unused import: `Deserialize` --> src/routes/encoding.rs:17:13 | 17 | use serde::{Deserialize, Serialize}; | ^^^^^^^^^^^ warning: unused import: `crate::core::encoding_service::EncodingService` --> src/routes/encoding.rs:86:9 | 86 | use crate::core::encoding_service::EncodingService; | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ warning: unused import: `sync::Arc` --> src/routes/api.rs:8:49 | 8 | use std::{collections::HashMap, time::Duration, sync::Arc}; | ^^^^^^^^^ warning: unused import: `axum::extract::ws::WebSocketUpgrade` --> src/streaming/websocket.rs:822:9 | 822 | use axum::extract::ws::WebSocketUpgrade; | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ warning: unused import: `axum::http::HeaderMap` --> src/streaming/websocket.rs:823:9 | 823 | use axum::http::HeaderMap; | ^^^^^^^^^^^^^^^^^^^^^ warning: unused import: `std::sync::Arc` --> src/streaming/websocket.rs:824:9 | 824 | use std::sync::Arc; | ^^^^^^^^^^^^^^ warning: unused import: `tokio::sync::broadcast` --> src/streaming/websocket_transport.rs:82:9 | 82 | use tokio::sync::broadcast; | ^^^^^^^^^^^^^^^^^^^^^^ warning: unused imports: `Deserialize` and `Serialize` --> src/structured_logging.rs:12:13 | 12 | use serde::{Deserialize, Serialize}; | ^^^^^^^^^^^ ^^^^^^^^^ warning: unused import: `std::time::Duration` --> src/structured_logging.rs:15:5 | 15 | use std::time::Duration; | ^^^^^^^^^^^^^^^^^^^ warning: unused import: `format::Writer` --> src/structured_logging.rs:22:17 | 22 | fmt::{self, format::Writer, time::ChronoUtc}, | ^^^^^^^^^^^^^^ warning: unused import: `uuid::Uuid` --> src/structured_logging.rs:182:9 | 182 | use uuid::Uuid; | ^^^^^^^^^^ warning: unused imports: `Duration as TokioDuration` and `sleep` --> src/utils/metrics.rs:433:23 | 433 | use tokio::time::{sleep, Duration as TokioDuration}; | ^^^^^ ^^^^^^^^^^^^^^^^^^^^^^^^^ warning: unused import: `std::collections::HashMap` --> src/lib.rs:25:5 | 25 | use std::collections::HashMap; | ^^^^^^^^^^^^^^^^^^^^^^^^^ warning: unused import: `tokio::sync::RwLock` --> src/lib.rs:28:5 | 28 | use tokio::sync::RwLock; | ^^^^^^^^^^^^^^^^^^^ warning: unused import: `super::*` --> src/lib.rs:161:9 | 161 | use super::*; | ^^^^^^^^ warning: unused variable: `user_id` --> src/auth/token_validator.rs:256:21 | 256 | if let Some(user_id) = user_id { | ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_user_id` | = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default warning: unused variable: `sample_rate` --> src/codecs/mp3.rs:766:13 | 766 | let sample_rate = | ^^^^^^^^^^^ | help: if this is intentional, prefix it with an underscore | 766 | let _sample_rate = | + help: you might have meant to pattern match on the similarly named constant `BRANCHES` | 766 - let sample_rate = 766 + let transcoding::pipeline::queue::PriorityQueue::next_job::{closure#0}::BRANCHES = | warning: unused variable: `chunk` --> src/core/buffer.rs:453:25 | 453 | if let Some(ref chunk) = chunk { | ^^^^^ help: if this is intentional, prefix it with an underscore: `_chunk` warning: unused variable: `drift_samples` --> src/core/sync.rs:464:38 | 464 | SyncState::Calibrating { ref drift_samples, ref rtt_samples } => { | ^^^^^^^^^^^^^^^^^ help: try ignoring the field: `drift_samples: _` warning: unused variable: `rtt_samples` --> src/core/sync.rs:464:57 | 464 | SyncState::Calibrating { ref drift_samples, ref rtt_samples } => { | ^^^^^^^^^^^^^^^ help: try ignoring the field: `rtt_samples: _` warning: variable does not need to be mutable --> src/core/sync.rs:444:13 | 444 | let mut listener = match listeners_map.get(&listener_id) { | ----^^^^^^^^ | | | help: remove this `mut` | = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default warning: variable `success_count` is assigned to, but never used --> src/core/sync.rs:416:17 | 416 | let mut success_count = 0; | ^^^^^^^^^^^^^ | = note: consider using `_success_count` instead warning: variable `error_count` is assigned to, but never used --> src/core/sync.rs:417:17 | 417 | let mut error_count = 0; | ^^^^^^^^^^^ | = note: consider using `_error_count` instead warning: unused variable: `encoding_service` --> src/routes/encoding.rs:83:11 | 83 | State(encoding_service): State, | ^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_encoding_service` warning: unused variable: `data` --> src/streaming/websocket.rs:372:43 | 372 | ... Message::Ping(data) => { | ^^^^ help: if this is intentional, prefix it with an underscore: `_data` warning: unused variable: `conn` --> src/streaming/websocket.rs:374:45 | 374 | ... if let Some(conn) = | ^^^^ help: if this is intentional, prefix it with an underscore: `_conn` warning: unused variable: `global_sender_clone` --> src/streaming/websocket.rs:326:13 | 326 | let global_sender_clone = self.global_sender.clone(); | ^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_global_sender_clone` warning: unused variable: `ping_id` --> src/streaming/websocket.rs:541:42 | 541 | WebSocketCommand::SyncPong { ping_id, client_timestamp } => { | ^^^^^^^ help: try ignoring the field: `ping_id: _` warning: unused variable: `token` --> src/streaming/websocket.rs:786:9 | 786 | let token = params.token.or_else(|| { | ^^^^^ help: if this is intentional, prefix it with an underscore: `_token` warning: unused import: `AudioEffect` --> src/audio/pipeline.rs:11:29 | 11 | use crate::audio::effects::{AudioEffect, EffectsChain}; | ^^^^^^^^^^^ warning: unused import: `Hasher` --> src/cache/audio_cache.rs:3:23 | 3 | use std::hash::{Hash, Hasher}; | ^^^^^^ warning: unused import: `super` --> src/structured_logging.rs:179:9 | 179 | use super::*; | ^^^^^ warning: unused variable: `config` --> src/codecs/mp3.rs:579:16 | 579 | pub fn new(config: DecoderConfig) -> Result { | ^^^^^^ help: if this is intentional, prefix it with an underscore: `_config` warning: unused variable: `resource` --> src/error.rs:449:34 | 449 | AppError::NotFound { resource } => StreamError::FileNotFound, | ^^^^^^^^ help: try ignoring the field: `resource: _` warning: unused variable: `err` --> src/error.rs:513:13 | 513 | fn from(err: serde_json::Error) -> Self { | ^^^ help: if this is intentional, prefix it with an underscore: `_err` For more information about this error, try `rustc --explain E0425`. warning: `stream_server` (lib test) generated 62 warnings error: could not compile `stream_server` (lib test) due to 1 previous error; 62 warnings emitted