moq-transport 0.12.2

Media over QUIC
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

use super::{Publisher, SessionError};
use crate::coding::ReasonPhrase;
use crate::message;
use crate::serve;

pub struct TrackStatusRequested {
    publisher: Publisher,
    pub request_msg: message::TrackStatus,
}

impl TrackStatusRequested {
    pub fn new(publisher: Publisher, request_msg: message::TrackStatus) -> Self {
        Self {
            publisher,
            request_msg,
        }
    }

    pub fn respond_error(
        &mut self,
        error_code: u64,
        error_message: &str,
    ) -> Result<(), SessionError> {
        let status_error = message::TrackStatusError {
            id: self.request_msg.id,
            error_code,
            reason_phrase: ReasonPhrase(error_message.to_string()),
        };
        self.publisher.send_message(status_error);
        Ok(())
    }

    pub fn respond_ok(mut self, track: &serve::TrackReader) -> Result<(), SessionError> {
        // Send TrackStatusOk
        self.publisher.send_message(message::TrackStatusOk {
            id: self.request_msg.id,
            track_alias: self.request_msg.id, // TODO SLG does a track alias make sense in track_status response?  Using track_status request id for now
            expires: 0,                       // TODO SLG
            group_order: message::GroupOrder::Ascending, // TODO: resolve correct value from publisher / subscriber prefs
            content_exists: track.largest_location().is_some(),
            largest_location: track.largest_location(),
            params: Default::default(),
        });

        Ok(())
    }
}