e_midi 0.1.13

An interactive/CLI/library MIDI player with advanced playback options, looping, and scan modes.
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

//! MusicSyncPublisher: Publishes PlaySongAtHeartbeat messages via iceoryx2
//!
//! Provides lock-free, zero-copy publishing of music sync messages for synchronized playback

use iceoryx2::port::publisher::Publisher;
use iceoryx2::prelude::*;
use iceoryx2::service::ipc::Service;
use std::sync::Arc;

use e_midi_shared::ipc_protocol::PlaySongAtHeartbeat;

use super::music_sync_subscriber::E_MIDI_MUSIC_SYNC_SERVICE;

#[derive(Debug)]
pub struct MusicSyncPublisher {
    publisher: Publisher<Service, PlaySongAtHeartbeat, ()>,
}

impl MusicSyncPublisher {
    /// Create a new music sync publisher
    pub fn new() -> Result<Self, String> {
        let node = NodeBuilder::new()
            .create::<Service>()
            .map_err(|e| format!("Node creation failed: {e:?}"))?;
        let service = node
            .service_builder(&ServiceName::new(E_MIDI_MUSIC_SYNC_SERVICE).map_err(|e| format!("Invalid service name: {e:?}"))?)
            .publish_subscribe::<PlaySongAtHeartbeat>()
            .open_or_create()
            .map_err(|e| format!("Failed to create/open service: {e:?}"))?;
        let publisher = service
            .publisher_builder()
            .create()
            .map_err(|e| format!("Failed to create publisher: {e:?}"))?;
        Ok(Self { publisher })
    }

    /// Publish a PlaySongAtHeartbeat message (zero-copy)
    pub fn publish(&mut self, msg: &PlaySongAtHeartbeat) -> Result<(), String> {
        self.publisher.send_copy(*msg)
            .map(|_| ())
            .map_err(|e| format!("Failed to publish: {e:?}"))
    }
}

unsafe impl Send for MusicSyncPublisher {}
unsafe impl Sync for MusicSyncPublisher {}