Checking stream_server v0.2.0 (/home/senke/Documents/veza/veza-stream-server)
error: error returned from database: password authentication failed for user "veza_user"
   --> src/core/encoding_pool.rs:104:9
    |
104 | /         sqlx::query!(
105 | |             r#"
106 | |             INSERT INTO stream_jobs (id, track_id, status)
107 | |             VALUES ($1, $2, 'pending')
...   |
110 | |             job.track_id
111 | |         )
    | |_________^
    |
    = note: this error originates in the macro `$crate::sqlx_macros::expand_query` which comes from the expansion of the macro `sqlx::query` (in Nightly builds, run with -Z macro-backtrace for more info)

error: error returned from database: password authentication failed for user "veza_user"
   --> src/core/encoding_pool.rs:366:40
    |
366 |           let job_exists: Option<bool> = sqlx::query_scalar!(
    |  ________________________________________^
367 | |             r#"
368 | |             SELECT EXISTS(SELECT 1 FROM stream_jobs WHERE track_id = $1 ORDER BY created_at DESC LIMIT 1)
369 | |             "#,
370 | |             job.track_id
371 | |         )
    | |_________^
    |
    = note: this error originates in the macro `$crate::sqlx_macros::expand_query` which comes from the expansion of the macro `sqlx::query_scalar` (in Nightly builds, run with -Z macro-backtrace for more info)

error: error returned from database: password authentication failed for user "veza_user"
   --> src/core/encoding_pool.rs:386:13
    |
386 | /             sqlx::query!(
387 | |                 r#"
388 | |                 INSERT INTO stream_segments (track_id, quality, segment_index, path, duration)
389 | |                 VALUES ($1, $2, $3, $4, $5)
...   |
396 | |                 duration
397 | |             )
    | |_____________^
    |
    = note: this error originates in the macro `$crate::sqlx_macros::expand_query` which comes from the expansion of the macro `sqlx::query` (in Nightly builds, run with -Z macro-backtrace for more info)

error: error returned from database: password authentication failed for user "veza_user"
   --> src/core/encoding_pool.rs:409:9
    |
409 | /         sqlx::query!(
410 | |             r#"
411 | |             UPDATE stream_jobs
412 | |             SET updated_at = NOW()
...   |
420 | |             job.track_id
421 | |         )
    | |_________^
    |
    = note: this error originates in the macro `$crate::sqlx_macros::expand_query` which comes from the expansion of the macro `sqlx::query` (in Nightly builds, run with -Z macro-backtrace for more info)

error: error returned from database: password authentication failed for user "veza_user"
   --> src/core/encoding_pool.rs:452:9
    |
452 | /         sqlx::query!(
453 | |             r#"
454 | |             UPDATE stream_jobs
455 | |             SET status = $1, updated_at = NOW()
...   |
464 | |             track_id
465 | |         )
    | |_________^
    |
    = note: this error originates in the macro `$crate::sqlx_macros::expand_query` which comes from the expansion of the macro `sqlx::query` (in Nightly builds, run with -Z macro-backtrace for more info)

error: error returned from database: password authentication failed for user "veza_user"
   --> src/core/encoding_pool.rs:481:9
    |
481 | /         sqlx::query!(
482 | |             r#"
483 | |             UPDATE stream_jobs
484 | |             SET status = 'error', error_message = $1, updated_at = NOW()
...   |
493 | |             track_id
494 | |         )
    | |_________^
    |
    = note: this error originates in the macro `$crate::sqlx_macros::expand_query` which comes from the expansion of the macro `sqlx::query` (in Nightly builds, run with -Z macro-backtrace for more info)

error: error returned from database: password authentication failed for user "veza_user"
  --> src/core/encoding_service.rs:52:21
   |
52 |           let track = sqlx::query!(
   |  _____________________^
53 | |             r#"
54 | |             SELECT t.id, f.storage_path as "source_path!"
55 | |             FROM tracks t
...  |
59 | |             track_id
60 | |         )
   | |_________^
   |
   = note: this error originates in the macro `$crate::sqlx_macros::expand_query` which comes from the expansion of the macro `sqlx::query` (in Nightly builds, run with -Z macro-backtrace for more info)

error: error returned from database: password authentication failed for user "veza_user"
   --> src/core/encoding_service.rs:145:20
    |
145 |           let jobs = sqlx::query!(
    |  ____________________^
146 | |             r#"
147 | |             SELECT status, error_message, created_at, updated_at
148 | |             FROM stream_jobs
...   |
153 | |             track_id
154 | |         )
    | |_________^
    |
    = note: this error originates in the macro `$crate::sqlx_macros::expand_query` which comes from the expansion of the macro `sqlx::query` (in Nightly builds, run with -Z macro-backtrace for more info)

error: error returned from database: password authentication failed for user "veza_user"
   --> src/core/encoding_service.rs:162:24
    |
162 |           let segments = sqlx::query!(
    |  ________________________^
163 | |             r#"
164 | |             SELECT quality, COUNT(*) as segment_count, MAX(segment_index) as max_index
165 | |             FROM stream_segments
...   |
169 | |             track_id
170 | |         )
    | |_________^
    |
    = note: this error originates in the macro `$crate::sqlx_macros::expand_query` which comes from the expansion of the macro `sqlx::query` (in Nightly builds, run with -Z macro-backtrace for more info)

error: error returned from database: password authentication failed for user "veza_user"
   --> src/core/encoding_service.rs:204:24
    |
204 |           let segments = sqlx::query!(
    |  ________________________^
205 | |             r#"
206 | |             SELECT COUNT(DISTINCT quality) as quality_count
207 | |             FROM stream_segments
...   |
210 | |             track_id
211 | |         )
    | |_________^
    |
    = note: this error originates in the macro `$crate::sqlx_macros::expand_query` which comes from the expansion of the macro `sqlx::query` (in Nightly builds, run with -Z macro-backtrace for more info)

error: error returned from database: password authentication failed for user "veza_user"
   --> src/routes/transcode.rs:338:19
    |
338 |       let job_row = sqlx::query!(
    |  ___________________^
339 | |         r#"
340 | |         SELECT id, track_id, status, created_at, updated_at, error_message
341 | |         FROM stream_jobs
...   |
344 | |         job_id
345 | |     )
    | |_____^
    |
    = note: this error originates in the macro `$crate::sqlx_macros::expand_query` which comes from the expansion of the macro `sqlx::query` (in Nightly builds, run with -Z macro-backtrace for more info)

error: error returned from database: password authentication failed for user "veza_user"
   --> src/routes/transcode.rs:357:25
    |
357 |       let segments_rows = sqlx::query!(
    |  _________________________^
358 | |         r#"
359 | |         SELECT segment_index, path, duration, created_at
360 | |         FROM stream_segments
...   |
364 | |         job.track_id
365 | |     )
    | |_____^
    |
    = note: this error originates in the macro `$crate::sqlx_macros::expand_query` which comes from the expansion of the macro `sqlx::query` (in Nightly builds, run with -Z macro-backtrace for more info)

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 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 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 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 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: `master_time`
   --> src/core/sync.rs:451:9
    |
451 |         master_time: MasterTime,
    |         ^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_master_time`

warning: unused variable: `encoding_service`
  --> src/routes/encoding.rs:83:11
   |
83 |     State(encoding_service): State<EncodingService>,
   |           ^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_encoding_service`

warning: unused variable: `data`
   --> src/streaming/websocket.rs:363:43
    |
363 | ...                   Message::Ping(data) => {
    |                                     ^^^^ help: if this is intentional, prefix it with an underscore: `_data`

warning: unused variable: `conn`
   --> src/streaming/websocket.rs:365:45
    |
365 | ...                   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:317:13
    |
317 |         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:532:42
    |
532 |             WebSocketCommand::SyncPong { ping_id, client_timestamp } => {
    |                                          ^^^^^^^ help: try ignoring the field: `ping_id: _`

warning: unused variable: `token`
   --> src/streaming/websocket.rs:777:9
    |
777 |     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<Self, AppError> {
    |                ^^^^^^ 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`

warning: `stream_server` (lib) generated 51 warnings
error: could not compile `stream_server` (lib) due to 12 previous errors; 51 warnings emitted