sms-receiver 1.0.0

Library for receiving SMS messages.
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

use crate::kdeconnect_client::{
    Connection, ConversationMessage, ConversationMessageCreated, ConversationMessageUpdated,
};
use std::time::Duration;

pub struct SMS<'a> {
    conversation_proxy: dbus::blocking::Proxy<'a, &'a dbus::blocking::Connection>,
    _sms_proxy: dbus::blocking::Proxy<'a, &'a dbus::blocking::Connection>,
}

impl<'a> SMS<'a> {
    pub fn new(connection: &'a Connection, device_id: &str) -> Self {
        Self {
            conversation_proxy: connection.0.with_proxy(
                "org.kde.kdeconnect",
                format!("/modules/kdeconnect/devices/{}", device_id),
                Duration::from_millis(5000),
            ),
            _sms_proxy: connection.0.with_proxy(
                "org.kde.kdeconnect",
                format!("/modules/kdeconnect/devices/{}/sms", device_id),
                Duration::from_millis(5000),
            ),
        }
    }

    pub fn on_conversation_created<F>(&self, mut f: F) -> Result<dbus::channel::Token, dbus::Error>
    where
        F: FnMut(ConversationMessage) -> () + Send + 'static,
    {
        self.conversation_proxy.match_signal(
            move |data: ConversationMessageCreated,
                  _: &dbus::blocking::Connection,
                  _: &dbus::Message| {
                f(data.0);
                true
            },
        )
    }

    pub fn on_conversation_updated<F>(&self, mut f: F) -> Result<dbus::channel::Token, dbus::Error>
    where
        F: FnMut(ConversationMessage) -> () + Send + 'static,
    {
        self.conversation_proxy.match_signal(
            move |data: ConversationMessageUpdated,
                  _: &dbus::blocking::Connection,
                  _: &dbus::Message| {
                f(data.0);
                true
            },
        )
    }
}