Compare commits

..

42 Commits

Author SHA1 Message Date
1df00952e4 Update repositories and remove Gitlab CI configuration.
All checks were successful
continuous-integration/drone/push Build is passing
2022-11-22 14:07:10 -06:00
db43d95cf7 Fix indentation.
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/tag Build is passing
2022-11-22 13:59:51 -06:00
89fcced31e Update CI build configuration. 2022-11-22 13:55:55 -06:00
1c11f279ec Bump version and use correct features in docs.rs builds. 2022-11-22 13:52:19 -06:00
f854e386a6 Re-add support for speech-dispatcher 0.9. 2022-11-22 13:49:54 -06:00
1ba40e898b Merge branch 'master' into 'master'
Fix missing size_t on latest stable

See merge request ndarilek/speech-dispatcher-rs!7
2022-10-19 14:40:39 +00:00
Tait Hoyem
bcf7025f14 Fix missing size_t on latest stable 2022-10-16 15:10:24 -06:00
2239c2539a Publish with features compatible for Rust CI image. 2022-09-07 12:13:55 -05:00
2ea85bc1bd Bump version and drop support for 0.9. 2022-09-07 11:43:22 -05:00
0efdccc9aa Merge branch '32bit' into 'master'
Fix msg_id and client_id being size_t in C

Closes #5

See merge request ndarilek/speech-dispatcher-rs!5
2022-09-07 14:53:43 +00:00
e770c73e67 Merge branch 'voice_type' into 'master'
Fix voice_type signedness change

Closes #4

See merge request ndarilek/speech-dispatcher-rs!6
2022-09-07 14:48:56 +00:00
Samuel Thibault
8ff6902148 Fix voice_type signedness change
The signedness changed happened in speech-dispatcher 0.11, not in
speech-dispatcher 0.10.2.

Closes #4
2022-09-07 15:54:53 +02:00
Samuel Thibault
29f990e19b Fix msg_id and client_id being size_t in C
instead of u64 which is only valid on 64bit architectures.

Fixes #5
2022-09-07 15:31:10 +02:00
6a6bc3f805 Add Drone/cargo-release/git-cliff configuration. 2022-09-04 09:15:13 -05:00
a50a6a4bdd Should now build with default features. 2022-08-29 16:36:33 -05:00
d6f9043e60 Add support for speech-dispatcher 0.10.2 and bump version. 2022-08-29 16:29:57 -05:00
4e1b79cb84 Don't build with default features on docs.rs. 2022-06-13 10:17:18 -05:00
8c69d78411 And of course Cargo complains about my feature name only at publication time. Fixed. 2022-03-10 13:27:50 -06:00
0ba2937a8a Update CI since build environment doesn't run a newer speech-dispatcher. 2022-03-10 13:13:19 -06:00
be9e4592ec And another... 2022-03-10 13:00:17 -06:00
6aacce2d73 Feature mismatch. 2022-03-10 12:58:56 -06:00
bbae5dc983 Add 0.10 feature. 2022-03-10 12:54:53 -06:00
c6b90a7a24 Cast values for compatibility with newer speech-dispatcher. 2022-03-10 12:29:27 -06:00
ee6aba7a97 Cast to u32. 2022-03-10 12:17:10 -06:00
36f82b78f3 Bump version. 2022-03-10 11:40:18 -06:00
729aaf5255 Soundness fixes for cloning Connection. 2022-03-10 11:39:42 -06:00
2618393758 Relicense and bump version. 2022-02-05 09:15:15 -06:00
82090cb48d Bump versions. 2022-01-27 10:29:10 -06:00
3709573305 Use Voice directly to avoid messing with stringly-typed voice names. 2022-01-27 10:26:12 -06:00
911e98d9ec Clean up example. 2022-01-27 10:21:53 -06:00
8434bfca64 Bump edition. 2022-01-27 10:06:41 -06:00
0dc9205b36 Merge branch 'lv' into 'master'
Add support for listing voices

See merge request ndarilek/speech-dispatcher-rs!2
2022-01-27 16:01:45 +00:00
Malloc Voidstar
143147036c
Add support for listing voices
Rebased on top of the result changes.
2022-01-10 18:26:02 -08:00
2879284030 Bump version. 2022-01-10 10:31:14 -06:00
5dfc99c6d7 Merge branch 'return-results' into 'master'
Change all bool-returns to Results

See merge request ndarilek/speech-dispatcher-rs!4
2022-01-10 16:26:29 +00:00
Malloc Voidstar
83b1ac5a76
Change SpeechDispatcherError to Error, format
Also lowercase Display strings to be in line with https://rust-lang.github.io/api-guidelines/interoperability.html#examples-of-error-messages
2021-12-06 10:58:29 -08:00
Malloc Voidstar
7d3edccdda
Convert all bool-returns to Results
Additionally:
* Make open2 fallible too
* Use a Result the entire time in open and open2, instead of going from Option to Result
* Specify c_int instead of i32 since apparently the size "may differ on some esoteric systems"; I suspect it won't compile on whatever those are but might as well improve the situation
* Avoid a maybe-possible panic in get_voice_type. Probably can't happen but I'm not 100% certain, so I made it fallible
* Add a missing null check to get_language
2021-12-06 10:57:04 -08:00
91098c0f01 Merge branch 'unused' into 'master'
Remove unused gcc dependency

See merge request ndarilek/speech-dispatcher-rs!3
2021-12-06 15:04:29 +00:00
Malloc Voidstar
675b569b32
Remove unused gcc dependency 2021-12-04 13:50:25 -08:00
e0170aa011 Bump version. 2021-12-02 09:11:26 -06:00
3b025dc0f9 Merge branch 'fix-types' into 'master'
Fix build on ARM

See merge request ndarilek/speech-dispatcher-rs!1
2021-12-02 15:09:21 +00:00
Malloc Voidstar
67a8c19410
Fix build on ARM
Differences in signedness were preventing builds.
2021-12-02 05:34:32 -08:00
9 changed files with 555 additions and 265 deletions

27
.drone.yml Normal file
View File

@ -0,0 +1,27 @@
kind: pipeline
type: docker
name: default
steps:
- name: test
image: rust
commands:
- rustup component add clippy rustfmt
- apt-get update -qq
- apt-get install -qqy llvm-dev libclang-dev clang libspeechd-dev
- cargo fmt --all --check
- cargo test --no-default-features --features 0_10
- cargo clippy --no-default-features --features 0_10
- name: release
image: rust
commands:
- apt-get update -qq
- apt-get install -qqy llvm-dev libclang-dev clang libspeechd-dev
- cargo publish --no-default-features --features 0_10 --manifest-path speech-dispatcher-sys/Cargo.toml || true
- cargo publish --no-default-features --features 0_10 --manifest-path speech-dispatcher/Cargo.toml
when:
ref:
- refs/tags/v*
environment:
CARGO_REGISTRY_TOKEN:
from_secret: cargo_registry_token

View File

@ -1,25 +0,0 @@
image: rust
stages:
- test
- publish
before_script:
- apt-get update
- apt-get install -y libspeechd-dev llvm-dev libclang-dev clang
test:
stage: test
script:
- cargo test
publish:
stage: publish
script:
- cargo login $CARGO_TOKEN
- cargo package --manifest-path speech-dispatcher-sys/Cargo.toml
- cargo publish --manifest-path speech-dispatcher-sys/Cargo.toml || true
- cargo package --manifest-path speech-dispatcher/Cargo.toml
- cargo publish --manifest-path speech-dispatcher/Cargo.toml
only:
- tags

60
cliff.toml Normal file
View File

@ -0,0 +1,60 @@
# configuration file for git-cliff (0.1.0)
[changelog]
# changelog header
header = """
# Changelog\n
All notable changes to this project will be documented in this file.\n
"""
# template for the changelog body
# https://tera.netlify.app/docs/#introduction
body = """
{% if version %}\
## Version {{ version | trim_start_matches(pat="v") }} - {{ timestamp | date(format="%Y-%m-%d") }}
{% else %}\
## Unreleased
{% endif %}\
{% for group, commits in commits | group_by(attribute="group") %}
### {{ group | upper_first }}
{% for commit in commits %}
- {% if commit.breaking %}[**breaking**] {% endif %}{{ commit.message | upper_first }}\
{% endfor %}
{% endfor %}\n
"""
# remove the leading and trailing whitespace from the template
trim = true
# changelog footer
footer = """
<!-- generated by git-cliff -->
"""
[git]
# parse the commits based on https://www.conventionalcommits.org
conventional_commits = true
# filter out the commits that are not conventional
filter_unconventional = true
# regex for parsing and grouping commits
commit_parsers = [
{ message = "^feat", group = "Features"},
{ message = "^fix", group = "Bug Fixes"},
{ message = "^doc", group = "Documentation"},
{ message = "^perf", group = "Performance"},
{ message = "^refactor", group = "Refactor"},
{ message = "^style", group = "Styling"},
{ message = "^test", group = "Testing"},
{ message = "^chore\\(release\\): prepare for", skip = true},
{ message = "^chore", group = "Miscellaneous Tasks"},
{ body = ".*security", group = "Security"},
]
# filter out the commits that are not matched by commit parsers
filter_commits = false
# glob pattern for matching git tags
tag_pattern = "v[0-9]*"
# regex for skipping tags
skip_tags = ""
# regex for ignoring tags
ignore_tags = ""
# sort the tags chronologically
date_order = false
# sort the commits inside sections by oldest/newest order
sort_commits = "oldest"

View File

@ -1,13 +1,17 @@
[package] [package]
name = "speech-dispatcher-sys" name = "speech-dispatcher-sys"
version = "0.5.2" version = "0.7.0"
authors = ["Nolan Darilek <nolan@thewordnerd.info>"] authors = ["Nolan Darilek <nolan@thewordnerd.info>"]
repository = "https://gitlab.com/ndarilek/speech-dispatcher-rs" repository = "https://dev.thewordnerd.info/nolan/speech-dispatcher-rs"
description = "speech-dispatcher system bindings" description = "speech-dispatcher system bindings"
license = "LGPL-2.1" license = "LGPL-2.1 OR MIT OR Apache-2.0"
edition = "2018" edition = "2021"
[build-dependencies] [build-dependencies]
bindgen = ">= 0.54" bindgen = ">= 0.54"
gcc = "0.3"
[package.metadata.release]
tag-prefix = ""
publish = false
push = false
pre-release-hook = ["git-cliff", "-o", "CHANGELOG.md", "--tag", "{{version}}"]

View File

@ -1,12 +1,29 @@
[package] [package]
name = "speech-dispatcher" name = "speech-dispatcher"
version = "0.8.0" version = "0.16.0"
authors = ["Nolan Darilek <nolan@thewordnerd.info>"] authors = ["Nolan Darilek <nolan@thewordnerd.info>"]
repository = "https://gitlab.com/ndarilek/speech-dispatcher-rs" repository = "https://dev.thewordnerd.info/nolan/speech-dispatcher-rs"
description = "Rusty interface to the speech-dispatcher speech synthesis library" description = "Rusty interface to the speech-dispatcher speech synthesis library"
license = "LGPL-2.1" license = "LGPL-2.1 OR MIT OR Apache-2.0"
edition = "2018" edition = "2021"
[features]
0_11 = ["0_10"]
0_10 = []
0_9 = []
default = ["0_11"]
[dependencies] [dependencies]
lazy_static = "1" lazy_static = "1"
speech-dispatcher-sys = { version = "0.5", path = "../speech-dispatcher-sys" } speech-dispatcher-sys = { version = "0.7", path = "../speech-dispatcher-sys" }
libc = "0.2.125"
[package.metadata.docs.rs]
no-default-features = true
features = ["0_9"]
[package.metadata.release]
tag-prefix = ""
publish = false
push = false
pre-release-hook = ["git-cliff", "-o", "CHANGELOG.md", "--tag", "{{version}}"]

View File

@ -0,0 +1,42 @@
use speech_dispatcher::*;
use std::io;
fn main() -> Result<(), Box<dyn std::error::Error>> {
let connection = speech_dispatcher::Connection::open(
"hello_world",
"hello_world",
"hello_world",
Mode::Threaded,
)?;
connection.on_begin(Some(Box::new(|msg_id, client_id| {
println!("Beginning {} from {}", msg_id, client_id)
})));
connection.on_end(Some(Box::new(|msg_id, client_id| {
println!("Ending {} from {}", msg_id, client_id)
})));
let connection_clone = connection.clone();
drop(connection);
connection_clone.say(
Priority::Important,
format!(
"Hello, world at rate {} from client {}.",
connection_clone.get_voice_rate(),
connection_clone.client_id()
),
);
connection_clone.set_voice_rate(100)?;
connection_clone.say(Priority::Important, "This is faster.");
connection_clone.set_voice_rate(0)?;
connection_clone.set_spelling(true)?;
connection_clone.say(Priority::Important, "This is spelled.");
connection_clone.set_spelling(false)?;
connection_clone.set_punctuation(Punctuation::All)?;
connection_clone.say(
Priority::Important,
"This statement, unlike others, has punctuation that is spoken!",
);
connection_clone.set_punctuation(Punctuation::None)?;
let mut _input = String::new();
io::stdin().read_line(&mut _input).unwrap();
Ok(())
}

View File

@ -22,18 +22,18 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
connection.client_id() connection.client_id()
), ),
); );
connection.set_voice_rate(100); connection.set_voice_rate(100)?;
connection.say(Priority::Important, "This is faster."); connection.say(Priority::Important, "This is faster.");
connection.set_voice_rate(0); connection.set_voice_rate(0)?;
connection.set_spelling(true); connection.set_spelling(true)?;
connection.say(Priority::Important, "This is spelled."); connection.say(Priority::Important, "This is spelled.");
connection.set_spelling(false); connection.set_spelling(false)?;
connection.set_punctuation(Punctuation::All); connection.set_punctuation(Punctuation::All)?;
connection.say( connection.say(
Priority::Important, Priority::Important,
"This statement, unlike others, has punctuation that is spoken!", "This statement, unlike others, has punctuation that is spoken!",
); );
connection.set_punctuation(Punctuation::None); connection.set_punctuation(Punctuation::None)?;
let mut _input = String::new(); let mut _input = String::new();
io::stdin().read_line(&mut _input).unwrap(); io::stdin().read_line(&mut _input).unwrap();
Ok(()) Ok(())

View File

@ -0,0 +1,29 @@
use speech_dispatcher::*;
fn main() -> Result<(), Box<dyn std::error::Error>> {
let connection = Connection::open("list_voices", "list_voices", "list_voices", Mode::Threaded)?;
let modules = connection.list_output_modules()?;
println!("Modules available: {:?}", modules);
for module in modules {
if connection.set_output_module(&module).is_ok() {
println!("Listing voices for module {module}");
} else {
println!("Failed to set output module to {module}");
continue;
};
let voices = connection.list_synthesis_voices()?;
for voice in voices {
if let Some(variant) = voice.variant {
println!(
" Name: {} / Language: {} / Variant: {variant}",
voice.name, voice.language
);
} else {
println!(" Name: {} / Language: {}", voice.name, voice.language);
}
}
}
// Use connection.set_synthesis_voice(voice) to set the voice to use.
Ok(())
}

View File

@ -1,11 +1,13 @@
#![allow(non_upper_case_globals)] #![allow(non_upper_case_globals)]
use libc::size_t;
use std::{ use std::{
collections::HashMap, collections::HashMap,
ffi::{CStr, CString}, ffi::{CStr, CString},
fmt, fmt,
marker::Send, marker::Send,
sync::Mutex, os::raw::{c_char, c_int},
sync::{Arc, Mutex},
}; };
use lazy_static::lazy_static; use lazy_static::lazy_static;
@ -31,18 +33,46 @@ pub enum Priority {
#[derive(Clone, Copy, Debug)] #[derive(Clone, Copy, Debug)]
#[repr(u32)] #[repr(u32)]
pub enum VoiceType { pub enum VoiceType {
Male1 = SPDVoiceType::SPD_MALE1, Male1 = SPDVoiceType::SPD_MALE1 as u32,
Male2 = SPDVoiceType::SPD_MALE2, Male2 = SPDVoiceType::SPD_MALE2 as u32,
Male3 = SPDVoiceType::SPD_MALE3, Male3 = SPDVoiceType::SPD_MALE3 as u32,
Female1 = SPDVoiceType::SPD_FEMALE1, Female1 = SPDVoiceType::SPD_FEMALE1 as u32,
Female2 = SPDVoiceType::SPD_FEMALE2, Female2 = SPDVoiceType::SPD_FEMALE2 as u32,
Female3 = SPDVoiceType::SPD_FEMALE3, Female3 = SPDVoiceType::SPD_FEMALE3 as u32,
ChildMale = SPDVoiceType::SPD_CHILD_MALE, ChildMale = SPDVoiceType::SPD_CHILD_MALE as u32,
ChildFemale = SPDVoiceType::SPD_CHILD_FEMALE, ChildFemale = SPDVoiceType::SPD_CHILD_FEMALE as u32,
} }
#[derive(Clone, Debug)] #[derive(Clone, Debug, Hash, PartialEq)]
pub struct Connection(pub *mut SPDConnection, u64); pub struct Voice {
/// The name of this voice. Unique with regards to the output module it came from.
pub name: String,
/// The language of this voice. Probably a BCP 47 language tag.
pub language: String,
/// The variant of this language, if present. Loosely defined.
pub variant: Option<String>,
}
impl Voice {
/// Convert a SPDVoice to a Voice. Only fails if the fields are non-Unicode.
/// Does not check that the pointers are non-null, caller must ensure that.
unsafe fn try_from(v: &SPDVoice) -> Result<Self, std::str::Utf8Error> {
// SPDVoice fields appear to all be ASCII.
let name = CStr::from_ptr(v.name).to_str()?.to_owned();
let language = CStr::from_ptr(v.language).to_str()?.to_owned();
let variant = CStr::from_ptr(v.variant).to_str()?;
let variant = if variant == "none" {
None
} else {
Some(variant.to_owned())
};
Ok(Self {
name,
language,
variant,
})
}
}
pub type Address = SPDConnectionAddress; pub type Address = SPDConnectionAddress;
@ -69,8 +99,10 @@ pub enum Notification {
#[repr(u32)] #[repr(u32)]
pub enum Punctuation { pub enum Punctuation {
All = SPDPunctuation::SPD_PUNCT_ALL, All = SPDPunctuation::SPD_PUNCT_ALL,
None = SPDPunctuation::SPD_PUNCT_NONE, #[cfg(feature = "0_10")]
Most = SPDPunctuation::SPD_PUNCT_MOST,
Some = SPDPunctuation::SPD_PUNCT_SOME, Some = SPDPunctuation::SPD_PUNCT_SOME,
None = SPDPunctuation::SPD_PUNCT_NONE,
} }
#[derive(Clone, Copy, Debug)] #[derive(Clone, Copy, Debug)]
@ -81,18 +113,22 @@ pub enum CapitalLetters {
Icon = SPDCapitalLetters::SPD_CAP_ICON, Icon = SPDCapitalLetters::SPD_CAP_ICON,
} }
fn i32_to_bool(v: i32) -> bool { /// Converts a `0` to a success and everything else to an error.
v == 1 fn c_int_to_result(r: c_int) -> Result<(), Error> {
match r {
0 => Ok(()),
_ => Err(Error::OperationFailed),
}
} }
#[derive(Default)] #[derive(Default)]
struct Callbacks { struct Callbacks {
begin: Option<Box<dyn FnMut(u64, u64)>>, begin: Option<Box<dyn FnMut(size_t, size_t)>>,
end: Option<Box<dyn FnMut(u64, u64)>>, end: Option<Box<dyn FnMut(size_t, size_t)>>,
index_mark: Option<Box<dyn FnMut(u64, u64, String)>>, index_mark: Option<Box<dyn FnMut(size_t, size_t, String)>>,
cancel: Option<Box<dyn FnMut(u64, u64)>>, cancel: Option<Box<dyn FnMut(size_t, size_t)>>,
pause: Option<Box<dyn FnMut(u64, u64)>>, pause: Option<Box<dyn FnMut(size_t, size_t)>>,
resume: Option<Box<dyn FnMut(u64, u64)>>, resume: Option<Box<dyn FnMut(size_t, size_t)>>,
} }
unsafe impl Send for Callbacks {} unsafe impl Send for Callbacks {}
@ -100,13 +136,13 @@ unsafe impl Send for Callbacks {}
unsafe impl Sync for Callbacks {} unsafe impl Sync for Callbacks {}
lazy_static! { lazy_static! {
static ref callbacks: Mutex<HashMap<u64, Callbacks>> = { static ref callbacks: Mutex<HashMap<size_t, Callbacks>> = {
let m = HashMap::new(); let m = HashMap::new();
Mutex::new(m) Mutex::new(m)
}; };
} }
unsafe extern "C" fn cb(msg_id: u64, client_id: u64, state: u32) { unsafe extern "C" fn cb(msg_id: size_t, client_id: size_t, state: u32) {
let state = match state { let state = match state {
SPDNotificationType_SPD_EVENT_BEGIN => Notification::Begin, SPDNotificationType_SPD_EVENT_BEGIN => Notification::Begin,
SPDNotificationType_SPD_EVENT_END => Notification::End, SPDNotificationType_SPD_EVENT_END => Notification::End,
@ -130,7 +166,7 @@ unsafe extern "C" fn cb(msg_id: u64, client_id: u64, state: u32) {
} }
} }
unsafe extern "C" fn cb_im(msg_id: u64, client_id: u64, state: u32, index_mark: *mut i8) { unsafe extern "C" fn cb_im(msg_id: size_t, client_id: size_t, state: u32, index_mark: *mut c_char) {
let index_mark = CStr::from_ptr(index_mark); let index_mark = CStr::from_ptr(index_mark);
let index_mark = index_mark.to_string_lossy().to_string(); let index_mark = index_mark.to_string_lossy().to_string();
let state = match state { let state = match state {
@ -149,28 +185,36 @@ unsafe extern "C" fn cb_im(msg_id: u64, client_id: u64, state: u32, index_mark:
} }
#[derive(Debug)] #[derive(Debug)]
pub enum SpeechDispatcherError { pub enum Error {
/// speech-dispatcher failed to initialize. Ensure speech-dispatcher is actually working on
/// your system; for example, does the command `spd-say hello` work?
InitializationError, InitializationError,
/// The operation failed
OperationFailed,
} }
impl std::error::Error for SpeechDispatcherError {} impl std::error::Error for Error {}
impl fmt::Display for SpeechDispatcherError { impl fmt::Display for Error {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result { fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
use SpeechDispatcherError::*; use Error::*;
match self { match self {
InitializationError => write!(f, "Failed to initialize"), InitializationError => write!(f, "failed to initialize"),
OperationFailed => write!(f, "operation failed"),
} }
} }
} }
#[derive(Clone, Debug)]
pub struct Connection(pub Arc<*mut SPDConnection>, size_t);
impl Connection { impl Connection {
pub fn open<S: Into<String>>( pub fn open<S: Into<String>>(
client_name: S, client_name: S,
connection_name: S, connection_name: S,
user_name: S, user_name: S,
mode: Mode, mode: Mode,
) -> Result<Self, SpeechDispatcherError> { ) -> Result<Self, Error> {
let clientname = CString::new(client_name.into()).unwrap(); let clientname = CString::new(client_name.into()).unwrap();
let connectionname = CString::new(connection_name.into()).unwrap(); let connectionname = CString::new(connection_name.into()).unwrap();
let username = CString::new(user_name.into()).unwrap(); let username = CString::new(user_name.into()).unwrap();
@ -182,18 +226,14 @@ impl Connection {
mode as u32, mode as u32,
); );
if c.is_null() { if c.is_null() {
None Err(Error::InitializationError)
} else { } else {
Some(Self::setup_connection(c)) Ok(Self::setup_connection(c))
} }
}; };
if let Some(connection) = connection { let mut c = Self(Arc::new(connection?), 0);
let mut c = Self(connection, 0); c.setup()?;
c.setup();
Ok(c) Ok(c)
} else {
Err(SpeechDispatcherError::InitializationError)
}
} }
pub unsafe fn open2<S: Into<String>>( pub unsafe fn open2<S: Into<String>>(
@ -203,7 +243,7 @@ impl Connection {
mode: Mode, mode: Mode,
address: *mut Address, address: *mut Address,
autospawn: bool, autospawn: bool,
) -> Self { ) -> Result<Self, Error> {
let auto_spawn = if autospawn { 1 } else { 0 }; let auto_spawn = if autospawn { 1 } else { 0 };
let error_result = vec![CString::new("").unwrap().into_raw()].as_mut_ptr(); let error_result = vec![CString::new("").unwrap().into_raw()].as_mut_ptr();
let clientname = CString::new(client_name.into()).unwrap(); let clientname = CString::new(client_name.into()).unwrap();
@ -219,11 +259,15 @@ impl Connection {
auto_spawn, auto_spawn,
error_result, error_result,
); );
Self::setup_connection(c) if c.is_null() {
Err(Error::InitializationError)
} else {
Ok(Self::setup_connection(c))
}
}; };
let mut c = Self(connection, 0); let mut c = Self(Arc::new(connection?), 0);
c.setup(); c.setup()?;
c Ok(c)
} }
unsafe fn setup_connection(c: *mut SPDConnection) -> *mut SPDConnection { unsafe fn setup_connection(c: *mut SPDConnection) -> *mut SPDConnection {
@ -236,7 +280,7 @@ impl Connection {
c c
} }
fn setup(&mut self) { fn setup(&mut self) -> Result<(), Error> {
let client_id = self.send_data("HISTORY GET CLIENT_ID\r\n", true); let client_id = self.send_data("HISTORY GET CLIENT_ID\r\n", true);
if let Some(client_id) = client_id { if let Some(client_id) = client_id {
let client_id: Vec<&str> = client_id.split("\r\n").collect(); let client_id: Vec<&str> = client_id.split("\r\n").collect();
@ -244,24 +288,26 @@ impl Connection {
if let Some(client_id) = client_id { if let Some(client_id) = client_id {
let client_id: Vec<&str> = client_id.split("-").collect(); let client_id: Vec<&str> = client_id.split("-").collect();
if let Some(client_id) = client_id.get(1) { if let Some(client_id) = client_id.get(1) {
if let Ok(client_id) = client_id.parse::<u64>() { if let Ok(client_id) = client_id.parse::<size_t>() {
self.1 = client_id; self.1 = client_id;
} }
} }
} }
} }
callbacks.lock().unwrap().insert(self.1, Default::default()); callbacks.lock().unwrap().insert(self.1, Default::default());
self.set_notification_on(Notification::All); self.set_notification_on(Notification::All)
.map_err(|_| Error::InitializationError)?;
Ok(())
} }
pub fn close(&self) { pub fn close(&self) {
unsafe { spd_close(self.0) }; unsafe { spd_close(*self.0) };
} }
pub fn say<S: Into<String>>(&self, priority: Priority, text: S) -> Option<u64> { pub fn say<S: Into<String>>(&self, priority: Priority, text: S) -> Option<u64> {
let text: String = text.into(); let text: String = text.into();
let param = CString::new(text).unwrap(); let param = CString::new(text).unwrap();
let rv = unsafe { spd_say(self.0, priority as u32, param.as_ptr()) }; let rv = unsafe { spd_say(*self.0, priority as u32, param.as_ptr()) };
if rv != -1 { if rv != -1 {
Some(rv as u64) Some(rv as u64)
} else { } else {
@ -272,7 +318,7 @@ impl Connection {
pub fn sayf<S: Into<String>>(&self, priority: Priority, format: S) -> Option<i32> { pub fn sayf<S: Into<String>>(&self, priority: Priority, format: S) -> Option<i32> {
let format: String = format.into(); let format: String = format.into();
let param = CString::new(format).unwrap(); let param = CString::new(format).unwrap();
let rv = unsafe { spd_sayf(self.0, priority as u32, param.as_ptr()) }; let rv = unsafe { spd_sayf(*self.0, priority as u32, param.as_ptr()) };
if rv != -1 { if rv != -1 {
Some(rv) Some(rv)
} else { } else {
@ -280,107 +326,120 @@ impl Connection {
} }
} }
pub fn stop(&self) -> bool { pub fn stop(&self) -> Result<(), Error> {
let v = unsafe { spd_stop(self.0) }; let v = unsafe { spd_stop(*self.0) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn stop_all(&self) -> bool { pub fn stop_all(&self) -> Result<(), Error> {
let v = unsafe { spd_stop_all(self.0) }; let v = unsafe { spd_stop_all(*self.0) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn stop_uid(&self, target_uid: i32) -> bool { pub fn stop_uid(&self, target_uid: i32) -> Result<(), Error> {
let v = unsafe { spd_stop_uid(self.0, target_uid) }; let v = unsafe { spd_stop_uid(*self.0, target_uid) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn cancel(&self) -> bool { pub fn cancel(&self) -> Result<(), Error> {
let v = unsafe { spd_cancel(self.0) }; let v = unsafe { spd_cancel(*self.0) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn cancel_all(&self) -> bool { pub fn cancel_all(&self) -> Result<(), Error> {
let v = unsafe { spd_cancel_all(self.0) }; let v = unsafe { spd_cancel_all(*self.0) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn cancel_uid(&self, target_uid: i32) -> bool { pub fn cancel_uid(&self, target_uid: i32) -> Result<(), Error> {
let v = unsafe { spd_cancel_uid(self.0, target_uid) }; let v = unsafe { spd_cancel_uid(*self.0, target_uid) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn pause(&self) -> bool { pub fn pause(&self) -> Result<(), Error> {
let v = unsafe { spd_pause(self.0) }; let v = unsafe { spd_pause(*self.0) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn pause_all(&self) -> bool { pub fn pause_all(&self) -> Result<(), Error> {
let v = unsafe { spd_pause_all(self.0) }; let v = unsafe { spd_pause_all(*self.0) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn pause_uid(&self, target_uid: i32) -> bool { pub fn pause_uid(&self, target_uid: i32) -> Result<(), Error> {
let v = unsafe { spd_pause_uid(self.0, target_uid) }; let v = unsafe { spd_pause_uid(*self.0, target_uid) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn resume(&self) -> bool { pub fn resume(&self) -> Result<(), Error> {
let v = unsafe { spd_resume(self.0) }; let v = unsafe { spd_resume(*self.0) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn resume_all(&self) -> bool { pub fn resume_all(&self) -> Result<(), Error> {
let v = unsafe { spd_resume_all(self.0) }; let v = unsafe { spd_resume_all(*self.0) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn resume_uid(&self, target_uid: i32) -> bool { pub fn resume_uid(&self, target_uid: i32) -> Result<(), Error> {
let v = unsafe { spd_resume_uid(self.0, target_uid) }; let v = unsafe { spd_resume_uid(*self.0, target_uid) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn key<S: Into<String>>(&self, priority: Priority, key_name: S) -> bool { pub fn key<S: Into<String>>(&self, priority: Priority, key_name: S) -> Result<(), Error> {
let param = CString::new(key_name.into()).unwrap(); let param = CString::new(key_name.into()).unwrap();
let v = unsafe { spd_key(self.0, priority as u32, param.as_ptr()) }; let v = unsafe { spd_key(*self.0, priority as u32, param.as_ptr()) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn char<S: Into<String>>(&self, priority: Priority, char: S) -> bool { pub fn char<S: Into<String>>(&self, priority: Priority, char: S) -> Result<(), Error> {
let param = CString::new(char.into()).unwrap(); let param = CString::new(char.into()).unwrap();
let v = unsafe { spd_char(self.0, priority as u32, param.as_ptr()) }; let v = unsafe { spd_char(*self.0, priority as u32, param.as_ptr()) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn wchar(&self, priority: Priority, wchar: i32) -> bool { pub fn wchar(&self, priority: Priority, wchar: i32) -> Result<(), Error> {
let v = unsafe { spd_wchar(self.0, priority as u32, wchar) }; let v = unsafe { spd_wchar(*self.0, priority as u32, wchar as wchar_t) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn sound_icon<S: Into<String>>(&self, priority: Priority, icon_name: S) -> bool { pub fn sound_icon<S: Into<String>>(
&self,
priority: Priority,
icon_name: S,
) -> Result<(), Error> {
let param = CString::new(icon_name.into()).unwrap(); let param = CString::new(icon_name.into()).unwrap();
let v = unsafe { spd_char(self.0, priority as u32, param.as_ptr()) }; let v = unsafe { spd_char(*self.0, priority as u32, param.as_ptr()) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_voice_type(&self, voice_type: VoiceType) -> bool { pub fn set_voice_type(&self, voice_type: VoiceType) -> Result<(), Error> {
let v = unsafe { spd_set_voice_type(self.0, voice_type as u32) }; #[cfg(all(any(feature = "0_9", feature = "0_10"), not(feature = "0_11")))]
i32_to_bool(v) let v = unsafe { spd_set_voice_type(*self.0, voice_type as u32) };
#[cfg(all(not(feature = "0_9"), any(feature = "0_11", not(feature = "0_10"))))]
let v = unsafe { spd_set_voice_type(*self.0, voice_type as i32) };
c_int_to_result(v)
} }
pub fn set_voice_type_all(&self, voice_type: VoiceType) -> bool { pub fn set_voice_type_all(&self, voice_type: VoiceType) -> Result<(), Error> {
let v = unsafe { spd_set_voice_type_all(self.0, voice_type as u32) }; #[cfg(all(any(feature = "0_9", feature = "0_10"), not(feature = "0_11")))]
i32_to_bool(v) let v = unsafe { spd_set_voice_type_all(*self.0, voice_type as u32) };
#[cfg(all(not(feature = "0_9"), any(feature = "0_11", not(feature = "0_10"))))]
let v = unsafe { spd_set_voice_type_all(*self.0, voice_type as i32) };
c_int_to_result(v)
} }
pub fn set_voice_type_uid(&self, voice_type: VoiceType, target_uid: u32) -> bool { pub fn set_voice_type_uid(&self, voice_type: VoiceType, target_uid: u32) -> Result<(), Error> {
let v = unsafe { spd_set_voice_type_uid(self.0, voice_type as u32, target_uid) }; #[cfg(all(any(feature = "0_9", feature = "0_10"), not(feature = "0_11")))]
i32_to_bool(v) let v = unsafe { spd_set_voice_type_uid(*self.0, voice_type as u32, target_uid) };
#[cfg(all(not(feature = "0_9"), any(feature = "0_11", not(feature = "0_10"))))]
let v = unsafe { spd_set_voice_type_uid(*self.0, voice_type as i32, target_uid) };
c_int_to_result(v)
} }
pub fn get_voice_type(&self) -> VoiceType { pub fn get_voice_type(&self) -> Result<VoiceType, Error> {
let v = unsafe { spd_get_voice_type(self.0) }; let v = unsafe { spd_get_voice_type(*self.0) };
match v { Ok(match v {
SPDVoiceType::SPD_MALE1 => VoiceType::Male1, SPDVoiceType::SPD_MALE1 => VoiceType::Male1,
SPDVoiceType::SPD_MALE2 => VoiceType::Male2, SPDVoiceType::SPD_MALE2 => VoiceType::Male2,
SPDVoiceType::SPD_MALE3 => VoiceType::Male3, SPDVoiceType::SPD_MALE3 => VoiceType::Male3,
@ -389,213 +448,234 @@ impl Connection {
SPDVoiceType::SPD_FEMALE3 => VoiceType::Female3, SPDVoiceType::SPD_FEMALE3 => VoiceType::Female3,
SPDVoiceType::SPD_CHILD_MALE => VoiceType::ChildMale, SPDVoiceType::SPD_CHILD_MALE => VoiceType::ChildMale,
SPDVoiceType::SPD_CHILD_FEMALE => VoiceType::ChildFemale, SPDVoiceType::SPD_CHILD_FEMALE => VoiceType::ChildFemale,
_ => panic!("Invalid voice type"), _ => return Err(Error::OperationFailed), // can this happen?
} })
} }
pub fn set_synthesis_voice<S: Into<String>>(&self, voice_name: S) -> bool { pub fn set_synthesis_voice(&self, voice: &Voice) -> Result<(), Error> {
let param = CString::new(voice.name.clone()).unwrap();
let v = unsafe { spd_set_synthesis_voice(*self.0, param.as_ptr()) };
c_int_to_result(v)
}
pub fn set_synthesis_voice_all<S: Into<String>>(&self, voice_name: S) -> Result<(), Error> {
let param = CString::new(voice_name.into()).unwrap(); let param = CString::new(voice_name.into()).unwrap();
let v = unsafe { spd_set_synthesis_voice(self.0, param.as_ptr()) }; let v = unsafe { spd_set_synthesis_voice_all(*self.0, param.as_ptr()) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_synthesis_voice_all<S: Into<String>>(&self, voice_name: S) -> bool { pub fn set_synthesis_voice_uid<S: Into<String>>(
&self,
voice_name: S,
target_uid: u32,
) -> Result<(), Error> {
let param = CString::new(voice_name.into()).unwrap(); let param = CString::new(voice_name.into()).unwrap();
let v = unsafe { spd_set_synthesis_voice_all(self.0, param.as_ptr()) }; let v = unsafe { spd_set_synthesis_voice_uid(*self.0, param.as_ptr(), target_uid) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_synthesis_voice_uid<S: Into<String>>(&self, voice_name: S, target_uid: u32) -> bool { pub fn set_data_mode(&self, mode: DataMode) -> Result<(), Error> {
let param = CString::new(voice_name.into()).unwrap(); let v = unsafe { spd_set_data_mode(*self.0, mode as u32) };
let v = unsafe { spd_set_synthesis_voice_uid(self.0, param.as_ptr(), target_uid) }; c_int_to_result(v)
i32_to_bool(v)
} }
pub fn set_data_mode(&self, mode: DataMode) -> bool { pub fn set_notification_on(&self, notification: Notification) -> Result<(), Error> {
let v = unsafe { spd_set_data_mode(self.0, mode as u32) }; let v = unsafe { spd_set_notification_on(*self.0, notification as u32) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_notification_on(&self, notification: Notification) -> bool { pub fn set_notification_off(&self, notification: Notification) -> Result<(), Error> {
let v = unsafe { spd_set_notification_on(self.0, notification as u32) }; let v = unsafe { spd_set_notification_off(*self.0, notification as u32) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_notification_off(&self, notification: Notification) -> bool { pub fn set_notification<S: Into<String>>(
let v = unsafe { spd_set_notification_off(self.0, notification as u32) }; &self,
i32_to_bool(v) notification: Notification,
} state: S,
) -> Result<(), Error> {
pub fn set_notification<S: Into<String>>(&self, notification: Notification, state: S) -> bool {
let param = CString::new(state.into()).unwrap(); let param = CString::new(state.into()).unwrap();
let v = unsafe { spd_set_notification(self.0, notification as u32, param.as_ptr()) }; let v = unsafe { spd_set_notification(*self.0, notification as u32, param.as_ptr()) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_voice_rate(&self, rate: i32) -> bool { pub fn set_voice_rate(&self, rate: i32) -> Result<(), Error> {
let v = unsafe { spd_set_voice_rate(self.0, rate) }; let v = unsafe { spd_set_voice_rate(*self.0, rate) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_voice_rate_all(&self, rate: i32) -> bool { pub fn set_voice_rate_all(&self, rate: i32) -> Result<(), Error> {
let v = unsafe { spd_set_voice_rate_all(self.0, rate) }; let v = unsafe { spd_set_voice_rate_all(*self.0, rate) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_voice_rate_uid(&self, rate: i32, target_uid: u32) -> bool { pub fn set_voice_rate_uid(&self, rate: i32, target_uid: u32) -> Result<(), Error> {
let v = unsafe { spd_set_voice_rate_uid(self.0, rate, target_uid) }; let v = unsafe { spd_set_voice_rate_uid(*self.0, rate, target_uid) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn get_voice_rate(&self) -> i32 { pub fn get_voice_rate(&self) -> i32 {
unsafe { spd_get_voice_rate(self.0) } unsafe { spd_get_voice_rate(*self.0) }
} }
pub fn set_voice_pitch(&self, pitch: i32) -> bool { pub fn set_voice_pitch(&self, pitch: i32) -> Result<(), Error> {
let v = unsafe { spd_set_voice_pitch(self.0, pitch) }; let v = unsafe { spd_set_voice_pitch(*self.0, pitch) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_voice_pitch_all(&self, pitch: i32) -> bool { pub fn set_voice_pitch_all(&self, pitch: i32) -> Result<(), Error> {
let v = unsafe { spd_set_voice_pitch_all(self.0, pitch) }; let v = unsafe { spd_set_voice_pitch_all(*self.0, pitch) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_voice_pitch_uid(&self, pitch: i32, target_uid: u32) -> bool { pub fn set_voice_pitch_uid(&self, pitch: i32, target_uid: u32) -> Result<(), Error> {
let v = unsafe { spd_set_voice_pitch_uid(self.0, pitch, target_uid) }; let v = unsafe { spd_set_voice_pitch_uid(*self.0, pitch, target_uid) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn get_voice_pitch(&self) -> i32 { pub fn get_voice_pitch(&self) -> i32 {
unsafe { spd_get_voice_pitch(self.0) } unsafe { spd_get_voice_pitch(*self.0) }
} }
pub fn set_volume(&self, volume: i32) -> bool { pub fn set_volume(&self, volume: i32) -> Result<(), Error> {
let v = unsafe { spd_set_volume(self.0, volume) }; let v = unsafe { spd_set_volume(*self.0, volume) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_volume_all(&self, volume: i32) -> bool { pub fn set_volume_all(&self, volume: i32) -> Result<(), Error> {
let v = unsafe { spd_set_volume_all(self.0, volume) }; let v = unsafe { spd_set_volume_all(*self.0, volume) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_volume_uid(&self, volume: i32, target_uid: u32) -> bool { pub fn set_volume_uid(&self, volume: i32, target_uid: u32) -> Result<(), Error> {
let v = unsafe { spd_set_volume_uid(self.0, volume, target_uid) }; let v = unsafe { spd_set_volume_uid(*self.0, volume, target_uid) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn get_volume(&self) -> i32 { pub fn get_volume(&self) -> i32 {
unsafe { spd_get_volume(self.0) } unsafe { spd_get_volume(*self.0) }
} }
pub fn set_punctuation(&self, punctuation: Punctuation) -> bool { pub fn set_punctuation(&self, punctuation: Punctuation) -> Result<(), Error> {
let v = unsafe { spd_set_punctuation(self.0, punctuation as u32) }; let v = unsafe { spd_set_punctuation(*self.0, punctuation as u32) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_punctuation_all(&self, punctuation: Punctuation) -> bool { pub fn set_punctuation_all(&self, punctuation: Punctuation) -> Result<(), Error> {
let v = unsafe { spd_set_punctuation_all(self.0, punctuation as u32) }; let v = unsafe { spd_set_punctuation_all(*self.0, punctuation as u32) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_punctuation_uid(&self, punctuation: Punctuation, target_uid: u32) -> bool { pub fn set_punctuation_uid(
let v = unsafe { spd_set_punctuation_uid(self.0, punctuation as u32, target_uid) }; &self,
i32_to_bool(v) punctuation: Punctuation,
target_uid: u32,
) -> Result<(), Error> {
let v = unsafe { spd_set_punctuation_uid(*self.0, punctuation as u32, target_uid) };
c_int_to_result(v)
} }
pub fn set_capital_letters(&self, capital_letters: CapitalLetters) -> bool { pub fn set_capital_letters(&self, capital_letters: CapitalLetters) -> Result<(), Error> {
let v = unsafe { spd_set_capital_letters(self.0, capital_letters as u32) }; let v = unsafe { spd_set_capital_letters(*self.0, capital_letters as u32) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_capital_letters_all(&self, capital_letters: CapitalLetters) -> bool { pub fn set_capital_letters_all(&self, capital_letters: CapitalLetters) -> Result<(), Error> {
let v = unsafe { spd_set_capital_letters_all(self.0, capital_letters as u32) }; let v = unsafe { spd_set_capital_letters_all(*self.0, capital_letters as u32) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_capital_letters_uid( pub fn set_capital_letters_uid(
&self, &self,
capital_letters: CapitalLetters, capital_letters: CapitalLetters,
target_uid: u32, target_uid: u32,
) -> bool { ) -> Result<(), Error> {
let v = unsafe { spd_set_capital_letters_uid(self.0, capital_letters as u32, target_uid) }; let v = unsafe { spd_set_capital_letters_uid(*self.0, capital_letters as u32, target_uid) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_spelling(&self, spelling: bool) -> bool { pub fn set_spelling(&self, spelling: bool) -> Result<(), Error> {
let s = if spelling { let s = if spelling {
SPDSpelling::SPD_SPELL_ON SPDSpelling::SPD_SPELL_ON
} else { } else {
SPDSpelling::SPD_SPELL_OFF SPDSpelling::SPD_SPELL_OFF
}; };
let v = unsafe { spd_set_spelling(self.0, s) }; let v = unsafe { spd_set_spelling(*self.0, s) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_spelling_all(&self, spelling: bool) -> bool { pub fn set_spelling_all(&self, spelling: bool) -> Result<(), Error> {
let s = if spelling { let s = if spelling {
SPDSpelling::SPD_SPELL_ON SPDSpelling::SPD_SPELL_ON
} else { } else {
SPDSpelling::SPD_SPELL_OFF SPDSpelling::SPD_SPELL_OFF
}; };
let v = unsafe { spd_set_spelling_all(self.0, s) }; let v = unsafe { spd_set_spelling_all(*self.0, s) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_spelling_uid(&self, spelling: bool, target_uid: u32) -> bool { pub fn set_spelling_uid(&self, spelling: bool, target_uid: u32) -> Result<(), Error> {
let s = if spelling { let s = if spelling {
SPDSpelling::SPD_SPELL_ON SPDSpelling::SPD_SPELL_ON
} else { } else {
SPDSpelling::SPD_SPELL_OFF SPDSpelling::SPD_SPELL_OFF
}; };
let v = unsafe { spd_set_spelling_uid(self.0, s, target_uid) }; let v = unsafe { spd_set_spelling_uid(*self.0, s, target_uid) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_language<S: Into<String>>(&self, language: S) -> bool { pub fn set_language<S: Into<String>>(&self, language: S) -> Result<(), Error> {
let param = CString::new(language.into()).unwrap(); let param = CString::new(language.into()).unwrap();
let v = unsafe { spd_set_language(self.0, param.as_ptr()) }; let v = unsafe { spd_set_language(*self.0, param.as_ptr()) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_language_all<S: Into<String>>(&self, language: S) -> bool { pub fn set_language_all<S: Into<String>>(&self, language: S) -> Result<(), Error> {
let param = CString::new(language.into()).unwrap(); let param = CString::new(language.into()).unwrap();
let v = unsafe { spd_set_language_all(self.0, param.as_ptr()) }; let v = unsafe { spd_set_language_all(*self.0, param.as_ptr()) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_language_uid<S: Into<String>>(&self, language: S, target_uid: u32) -> bool { pub fn set_language_uid<S: Into<String>>(
&self,
language: S,
target_uid: u32,
) -> Result<(), Error> {
let param = CString::new(language.into()).unwrap(); let param = CString::new(language.into()).unwrap();
let v = unsafe { spd_set_language_uid(self.0, param.as_ptr(), target_uid) }; let v = unsafe { spd_set_language_uid(*self.0, param.as_ptr(), target_uid) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn get_language(&self) -> &str { pub fn get_language(&self) -> Result<&str, Error> {
let v = unsafe { CStr::from_ptr(spd_get_language(self.0)) }; let language = unsafe { spd_get_language(*self.0) };
v.to_str().unwrap() if language.is_null() {
Err(Error::OperationFailed)
} else {
let language = unsafe { CStr::from_ptr(language) };
language.to_str().map_err(|_| Error::OperationFailed)
}
} }
pub fn set_output_module<S: Into<String>>(&self, output_module: S) -> bool { pub fn set_output_module<S: Into<String>>(&self, output_module: S) -> Result<(), Error> {
let param = CString::new(output_module.into()).unwrap(); let param = CString::new(output_module.into()).unwrap();
let v = unsafe { spd_set_output_module(self.0, param.as_ptr()) }; let v = unsafe { spd_set_output_module(*self.0, param.as_ptr()) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_output_module_all<S: Into<String>>(&self, output_module: S) -> bool { pub fn set_output_module_all<S: Into<String>>(&self, output_module: S) -> Result<(), Error> {
let param = CString::new(output_module.into()).unwrap(); let param = CString::new(output_module.into()).unwrap();
let v = unsafe { spd_set_output_module_all(self.0, param.as_ptr()) }; let v = unsafe { spd_set_output_module_all(*self.0, param.as_ptr()) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn set_output_module_uid<S: Into<String>>( pub fn set_output_module_uid<S: Into<String>>(
&self, &self,
output_module: S, output_module: S,
target_uid: u32, target_uid: u32,
) -> bool { ) -> Result<(), Error> {
let param = CString::new(output_module.into()).unwrap(); let param = CString::new(output_module.into()).unwrap();
let v = unsafe { spd_set_output_module_uid(self.0, param.as_ptr(), target_uid) }; let v = unsafe { spd_set_output_module_uid(*self.0, param.as_ptr(), target_uid) };
i32_to_bool(v) c_int_to_result(v)
} }
pub fn send_data<S: Into<String>>(&self, data: S, wait_for_reply: bool) -> Option<String> { pub fn send_data<S: Into<String>>(&self, data: S, wait_for_reply: bool) -> Option<String> {
@ -605,7 +685,7 @@ impl Connection {
SPD_NO_REPLY as i32 SPD_NO_REPLY as i32
}; };
let data = CString::new(data.into()).unwrap(); let data = CString::new(data.into()).unwrap();
let rv = unsafe { spd_send_data(self.0, data.as_ptr(), wfr) }; let rv = unsafe { spd_send_data(*self.0, data.as_ptr(), wfr) };
if rv.is_null() { if rv.is_null() {
None None
} else { } else {
@ -614,7 +694,7 @@ impl Connection {
} }
} }
pub fn on_begin(&self, f: Option<Box<dyn FnMut(u64, u64)>>) { pub fn on_begin(&self, f: Option<Box<dyn FnMut(size_t, size_t)>>) {
if let Ok(mut cbs) = callbacks.lock() { if let Ok(mut cbs) = callbacks.lock() {
let cb = cbs.get_mut(&self.1); let cb = cbs.get_mut(&self.1);
if let Some(cb) = cb { if let Some(cb) = cb {
@ -623,7 +703,7 @@ impl Connection {
} }
} }
pub fn on_end(&self, f: Option<Box<dyn FnMut(u64, u64)>>) { pub fn on_end(&self, f: Option<Box<dyn FnMut(size_t, size_t)>>) {
if let Ok(mut cbs) = callbacks.lock() { if let Ok(mut cbs) = callbacks.lock() {
let cb = cbs.get_mut(&self.1); let cb = cbs.get_mut(&self.1);
if let Some(cb) = cb { if let Some(cb) = cb {
@ -632,7 +712,7 @@ impl Connection {
} }
} }
pub fn on_cancel(&self, f: Option<Box<dyn FnMut(u64, u64)>>) { pub fn on_cancel(&self, f: Option<Box<dyn FnMut(size_t, size_t)>>) {
if let Ok(mut cbs) = callbacks.lock() { if let Ok(mut cbs) = callbacks.lock() {
let cb = cbs.get_mut(&self.1); let cb = cbs.get_mut(&self.1);
if let Some(cb) = cb { if let Some(cb) = cb {
@ -641,7 +721,7 @@ impl Connection {
} }
} }
pub fn on_pause(&self, f: Option<Box<dyn FnMut(u64, u64)>>) { pub fn on_pause(&self, f: Option<Box<dyn FnMut(size_t, size_t)>>) {
if let Ok(mut cbs) = callbacks.lock() { if let Ok(mut cbs) = callbacks.lock() {
let cb = cbs.get_mut(&self.1); let cb = cbs.get_mut(&self.1);
if let Some(cb) = cb { if let Some(cb) = cb {
@ -650,7 +730,7 @@ impl Connection {
} }
} }
pub fn on_resume(&self, f: Option<Box<dyn FnMut(u64, u64)>>) { pub fn on_resume(&self, f: Option<Box<dyn FnMut(size_t, size_t)>>) {
if let Ok(mut cbs) = callbacks.lock() { if let Ok(mut cbs) = callbacks.lock() {
let cb = cbs.get_mut(&self.1); let cb = cbs.get_mut(&self.1);
if let Some(cb) = cb { if let Some(cb) = cb {
@ -659,7 +739,7 @@ impl Connection {
} }
} }
pub fn on_index_mark(&self, f: Option<Box<dyn FnMut(u64, u64, String)>>) { pub fn on_index_mark(&self, f: Option<Box<dyn FnMut(size_t, size_t, String)>>) {
if let Ok(mut cbs) = callbacks.lock() { if let Ok(mut cbs) = callbacks.lock() {
let cb = cbs.get_mut(&self.1); let cb = cbs.get_mut(&self.1);
if let Some(cb) = cb { if let Some(cb) = cb {
@ -668,16 +748,72 @@ impl Connection {
} }
} }
pub fn client_id(&self) -> u64 { pub fn list_synthesis_voices(&self) -> Result<Vec<Voice>, Error> {
let start = unsafe { spd_list_synthesis_voices(*self.0) };
let slice = unsafe { null_term_array_ptr_to_slice(start) }.ok_or(Error::OperationFailed)?;
let voices = unsafe {
slice
.iter()
.map(|v| v.read())
.flat_map(|v| {
if v.name.is_null() || v.language.is_null() || v.variant.is_null() {
None
} else {
Voice::try_from(&v).ok()
}
})
.collect()
};
unsafe {
free_spd_voices(start);
}
Ok(voices)
}
pub fn list_output_modules(&self) -> Result<Vec<String>, Error> {
let start = unsafe { spd_list_modules(*self.0) };
let slice = unsafe { null_term_array_ptr_to_slice(start) }.ok_or(Error::OperationFailed)?;
let modules = unsafe {
slice
.iter()
.flat_map(|v| CStr::from_ptr(*v).to_str().ok().map(String::from))
.collect()
};
unsafe {
free_spd_modules(start);
}
Ok(modules)
}
pub fn client_id(&self) -> size_t {
self.1 self.1
} }
} }
/// Interpret a null-terminated array of pointers as a slice of pointers.
/// None of the pointers will be null if this returns Some.
unsafe fn null_term_array_ptr_to_slice<'a, T>(start: *mut *mut T) -> Option<&'a [*mut T]> {
if start.is_null() {
return None;
}
let mut current = start;
let mut len = 0;
while !current.read().is_null() {
len += 1;
current = current.add(1);
}
Some(std::slice::from_raw_parts(start, len))
}
unsafe impl Send for Connection {} unsafe impl Send for Connection {}
impl Drop for Connection { impl Drop for Connection {
fn drop(&mut self) { fn drop(&mut self) {
if Arc::strong_count(&self.0) <= 1 {
self.close(); self.close();
callbacks.lock().unwrap().remove(&self.1); callbacks.lock().unwrap().remove(&self.1);
} }
} }
}