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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86

/* This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at http://mozilla.org/MPL/2.0/. */

#![allow(unknown_lints)]
#![warn(rust_2018_idioms)]
// Let's allow these in the FFI code, since it's usually just a coincidence if
// the closure is small.
#![allow(clippy::redundant_closure)]

use ffi_support::{ExternError, HandleError};
use sync_manager::Result as MgrResult;

#[no_mangle]
pub extern "C" fn sync_manager_set_places(_places_api_handle: u64, error: &mut ExternError) {
    ffi_support::call_with_result(error, || -> MgrResult<()> {
        log::debug!("sync_manager_set_places");
        let api = places_ffi::APIS
            .get_u64(_places_api_handle, |api| -> Result<_, HandleError> {
                Ok(std::sync::Arc::clone(api))
            })?;
        sync_manager::set_places(api);
        Ok(())
    })
}

#[no_mangle]
pub extern "C" fn sync_manager_set_logins(_logins_handle: u64, error: &mut ExternError) {
    ffi_support::call_with_result(error, || -> MgrResult<()> {
        log::debug!("sync_manager_set_logins");
        let api = logins_ffi::ENGINES.get_u64(_logins_handle, |api| -> Result<_, HandleError> {
            Ok(std::sync::Arc::clone(api))
        })?;
        sync_manager::set_logins(api);
        Ok(())
    })
}

#[no_mangle]
pub extern "C" fn sync_manager_set_tabs(_tabs_handle: u64, error: &mut ExternError) {
    ffi_support::call_with_result(error, || -> MgrResult<()> {
        log::debug!("sync_manager_set_tabs");
        let api = tabs_ffi::ENGINES.get_u64(_tabs_handle, |api| -> Result<_, HandleError> {
            Ok(std::sync::Arc::clone(api))
        })?;
        sync_manager::set_tabs(api);
        Ok(())
    })
}

#[no_mangle]
pub extern "C" fn sync_manager_disconnect(error: &mut ExternError) {
    ffi_support::call_with_output(error, || {
        log::debug!("sync_manager_disconnect");
        sync_manager::disconnect()
    });
}

unsafe fn get_buffer<'a>(data: *const u8, len: i32) -> &'a [u8] {
    assert!(len >= 0, "Bad buffer len: {}", len);
    if len == 0 {
        // This will still fail, but as a bad protobuf format.
        &[]
    } else {
        assert!(!data.is_null(), "Unexpected null data pointer");
        std::slice::from_raw_parts(data, len as usize)
    }
}
/// # Safety
/// Reads pointer, thus unsafe.
#[no_mangle]
pub unsafe extern "C" fn sync_manager_sync(
    params_data: *const u8,
    params_len: i32,
    error: &mut ExternError,
) -> ffi_support::ByteBuffer {
    ffi_support::call_with_result(error, || {
        log::debug!("sync_manager_sync");
        let buffer = get_buffer(params_data, params_len);
        let params: sync_manager::msg_types::SyncParams = prost::Message::decode(buffer)?;
        sync_manager::sync(params)
    })
}

ffi_support::define_string_destructor!(sync_manager_destroy_string);
ffi_support::define_bytebuffer_destructor!(sync_manager_destroy_bytebuffer);