feat: impl SpeakerService

[ras0q]

No description provided.

[H1rono]

migration書いて

[H1rono]

// load_all_speaker_phones

use futures::TryStreamExt;

let speaker_phones = todo!();
for sp in speaker_phones {
    let rx = event_service.subscribe_messages().await?;
    task.spawn(|_token| async move {
        while let Some(message) = rx.try_next().await? {
            if todo!("spのアクセス範囲内にmessage.positionが含まれ ない") {
                continue;
            }
            traq_message_service.send_message(message).await?;
        }
    });
}

大体こうです

[H1rono]

spawn内で?が使えないかもなので、その時は↓

match send_message(...).await {
    Ok(_) => { ... }
    Err(e) => {
        tracing::error!(...);
        return;
    }
}

[H1rono]

#81 継続