concord 2.5.0

A terminal user interface client for Discord
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74

use tokio::sync::mpsc;

use super::{STREAM_BROADCAST_FEATURE_DISABLED, StreamCaptureTarget, preview::StreamPreviewFrame};

pub(super) const STREAM_CAPTURE_WIDTH: u32 = 1280;
pub(super) const STREAM_CAPTURE_HEIGHT: u32 = 720;
pub(super) const STREAM_CAPTURE_FPS: u32 = 30;
pub(super) const STREAM_CAPTURE_BITRATE: u32 = 6_000_000;

// Keep the broadcast runtime interface stable in reduced builds. Capture
// startup always fails before either of these values can be constructed.
#[derive(Debug)]
pub(super) struct EncodedStreamFrame {
    pub(super) timestamp: u32,
    pub(super) annex_b: Vec<u8>,
    pub(super) is_keyframe: bool,
}

pub(super) struct StreamCaptureHandle;

#[derive(Clone, Default)]
pub(super) struct StreamCaptureCancellation;

pub(super) struct PreparedStreamCapture {
    pub(super) handle: StreamCaptureHandle,
    pub(super) frames: mpsc::Receiver<Result<EncodedStreamFrame, String>>,
    pub(super) preview_frames: Option<mpsc::Receiver<StreamPreviewFrame>>,
    pub(super) errors: mpsc::UnboundedReceiver<String>,
}

impl StreamCaptureHandle {
    pub(super) fn request_keyframe(&self) {
        // Disabled builds never construct a capture handle.
    }

    pub(super) async fn shutdown(self) {
        // Disabled builds never construct a capture handle.
    }
}

impl StreamCaptureCancellation {
    pub(super) fn cancel(&self) {
        // Disabled builds never start a capture preparation task.
    }

    #[cfg(test)]
    pub(super) fn is_cancelled(&self) -> bool {
        true
    }
}

pub(crate) fn list_stream_capture_targets() -> Result<Vec<StreamCaptureTarget>, String> {
    Err(STREAM_BROADCAST_FEATURE_DISABLED.to_owned())
}

pub(super) fn prepare_stream_capture(
    _target: StreamCaptureTarget,
    _cancellation: StreamCaptureCancellation,
) -> Result<PreparedStreamCapture, String> {
    Err(STREAM_BROADCAST_FEATURE_DISABLED.to_owned())
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn capture_targets_report_the_disabled_feature() {
        assert_eq!(
            list_stream_capture_targets(),
            Err(STREAM_BROADCAST_FEATURE_DISABLED.to_owned())
        );
    }
}