Kieran/zap-stream-core
1
0
Fork 0
mirror of https://github.com/v0l/zap-stream-core.git synced 2025-06-16 17:08:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: add default stream info to stream

Browse Source
This commit is contained in:
Kieran
2025-06-12 17:25:28 +01:00
parent 09577cc2c8
commit a7ff18b34c
3 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
crates/core/src/ingress/rtmp.rs
View File

@ -201,7 +201,9 @@ impl RtmpClient {
self.published_stream = Some(RtmpPublishedStream(app_name, stream_key)); self.published_stream = Some(RtmpPublishedStream(app_name, stream_key));
} }
} }
ServerSessionEvent::PublishStreamFinished { .. } => {} ServerSessionEvent::PublishStreamFinished { .. } => {
// TODO: shutdown pipeline
}
ServerSessionEvent::StreamMetadataChanged { ServerSessionEvent::StreamMetadataChanged {
app_name, app_name,
stream_key, stream_key,

2
crates/core/src/pipeline/runner.rs
View File

@ -32,7 +32,7 @@ use tokio::runtime::Handle;
use uuid::Uuid; use uuid::Uuid;
/// Idle mode timeout in seconds /// Idle mode timeout in seconds
const IDLE_TIMEOUT_SECS: u64 = 600; const IDLE_TIMEOUT_SECS: u64 = 60;
/// Circuit breaker threshold for consecutive decode failures /// Circuit breaker threshold for consecutive decode failures
const DEFAULT_MAX_CONSECUTIVE_FAILURES: u32 = 50; const DEFAULT_MAX_CONSECUTIVE_FAILURES: u32 = 50;

6
crates/zap-stream/src/overseer.rs
View File

@ -371,6 +371,12 @@ impl Overseer for ZapStreamOverseer {
starts: Utc::now(), starts: Utc::now(),
state: UserStreamState::Live, state: UserStreamState::Live,
endpoint_id: Some(endpoint.id), endpoint_id: Some(endpoint.id),
title: user.title.clone(),
summary: user.summary.clone(),
thumb: user.image.clone(),
content_warning: user.content_warning.clone(),
goal: user.goal.clone(),
tags: user.tags.clone(),
..Default::default() ..Default::default()
}; };
let stream_event = self.publish_stream_event(&new_stream, &user.pubkey).await?; let stream_event = self.publish_stream_event(&new_stream, &user.pubkey).await?;