spiel 0.1.0

A pure-Rust Spiel format parser, client, and proxy implementation.
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65

use std::{error::Error, os::fd::AsFd, time::Duration};

use spiel::client::ProviderProxy;
use tokio::{io::ErrorKind, net::UnixStream, time::timeout};
use zbus::{names::OwnedBusName, zvariant::Fd};

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
	let session = zbus::Connection::session().await?;
	let s = zbus::fdo::DBusProxy::new(&session).await?;
	let mut active = OwnedBusName::try_from("org.espeak.Speech.Provider")?;
	for i in s.list_activatable_names().await? {
		if i.contains("Speech.Provider") {
			println!("SP: {i:?}");
			active = i;
		}
	}
	println!("AC: {active}");
	for i in s.interfaces().await? {
		println!("INT: {i:?}");
	}
	let prov = ProviderProxy::new(
		&session,
		active.clone(),
		"/".to_owned() + &active.as_str().replace(".", "/"),
	)
	.await?;
	println!("Name: {:?}", prov.name().await?);
	for i in prov.voices().await? {
		println!("{i:?}");
	}
	let (read, write) = UnixStream::pair()?;
	prov.synthesize(
		Fd::Borrowed(write.as_fd()),
		"This is a test using Spiel! Wahahaa!",
		"m6",
		1.0,
		1.0,
		false,
		"en-US",
	)
	.await?;
	loop {
		// Wait for the socket to be readable
		let _ = timeout(Duration::from_secs(1), read.readable()).await?;

		let mut buf = Vec::with_capacity(4096);

		// Try to read data, this may still fail with `WouldBlock`
		// if the readiness event is a false positive.
		match read.try_read_buf(&mut buf) {
			Ok(0) => break,
			Ok(n) => {
				println!("read {n} bytes");
			}
			Err(ref e) if e.kind() == ErrorKind::WouldBlock => {
				continue;
			}
			Err(e) => {
				return Err(e.into());
			}
		}
	}
	Ok(())
}