mirror of
https://github.com/logos-blockchain/logos-execution-zone.git
synced 2026-05-14 03:59:30 +00:00
101 lines
3.2 KiB
Rust
101 lines
3.2 KiB
Rust
use std::{ffi::c_char, path::PathBuf};
|
|
|
|
use tokio::runtime::Runtime;
|
|
|
|
use crate::{IndexerServiceFFI, api::PointerResult, errors::OperationStatus};
|
|
|
|
pub type InitializedIndexerServiceFFIResult = PointerResult<IndexerServiceFFI, OperationStatus>;
|
|
|
|
/// Creates and starts an indexer based on the provided
|
|
/// configuration file path.
|
|
///
|
|
/// # Arguments
|
|
///
|
|
/// - `config_path`: A pointer to a string representing the path to the configuration file.
|
|
/// - `port`: Number representing a port, on which indexers RPC will start.
|
|
///
|
|
/// # Returns
|
|
///
|
|
/// An `InitializedIndexerServiceFFIResult` containing either a pointer to the
|
|
/// initialized `IndexerServiceFFI` or an error code.
|
|
#[unsafe(no_mangle)]
|
|
pub extern "C" fn start_indexer(
|
|
config_path: *const c_char,
|
|
port: u16,
|
|
) -> InitializedIndexerServiceFFIResult {
|
|
setup_indexer(config_path, port).map_or_else(
|
|
InitializedIndexerServiceFFIResult::from_error,
|
|
InitializedIndexerServiceFFIResult::from_value,
|
|
)
|
|
}
|
|
|
|
/// Initializes and starts an indexer based on the provided
|
|
/// configuration file path.
|
|
///
|
|
/// # Arguments
|
|
///
|
|
/// - `config_path`: A pointer to a string representing the path to the configuration file.
|
|
/// - `port`: Number representing a port, on which indexers RPC will start.
|
|
///
|
|
/// # Returns
|
|
///
|
|
/// A `Result` containing either the initialized `IndexerServiceFFI` or an
|
|
/// error code.
|
|
fn setup_indexer(
|
|
config_path: *const c_char,
|
|
port: u16,
|
|
) -> Result<IndexerServiceFFI, OperationStatus> {
|
|
let user_config_path = PathBuf::from(
|
|
unsafe { std::ffi::CStr::from_ptr(config_path) }
|
|
.to_str()
|
|
.map_err(|e| {
|
|
log::error!("Could not convert the config path to string: {e}");
|
|
OperationStatus::InitializationError
|
|
})?,
|
|
);
|
|
let config = indexer_service::IndexerConfig::from_path(&user_config_path).map_err(|e| {
|
|
log::error!("Failed to read config: {e}");
|
|
OperationStatus::InitializationError
|
|
})?;
|
|
|
|
let rt = Runtime::new().unwrap();
|
|
|
|
let indexer_handle = rt
|
|
.block_on(indexer_service::run_server(config, port))
|
|
.map_err(|e| {
|
|
log::error!("Could not start indexer service: {e}");
|
|
OperationStatus::InitializationError
|
|
})?;
|
|
|
|
Ok(IndexerServiceFFI::new(indexer_handle, rt))
|
|
}
|
|
|
|
/// Stops and frees the resources associated with the given indexer service.
|
|
///
|
|
/// # Arguments
|
|
///
|
|
/// - `indexer`: A pointer to the `IndexerServiceFFI` instance to be stopped.
|
|
///
|
|
/// # Returns
|
|
///
|
|
/// An `OperationStatus` indicating success or failure.
|
|
///
|
|
/// # Safety
|
|
///
|
|
/// The caller must ensure that:
|
|
/// - `indexer` is a valid pointer to a `IndexerServiceFFI` instance
|
|
/// - The `IndexerServiceFFI` instance was created by this library
|
|
/// - The pointer will not be used after this function returns
|
|
#[unsafe(no_mangle)]
|
|
pub unsafe extern "C" fn stop_indexer(indexer: *mut IndexerServiceFFI) -> OperationStatus {
|
|
if indexer.is_null() {
|
|
log::error!("Attempted to stop a null indexer pointer. This is a bug. Aborting.");
|
|
return OperationStatus::NullPointer;
|
|
}
|
|
|
|
let indexer = unsafe { Box::from_raw(indexer) };
|
|
drop(indexer);
|
|
|
|
OperationStatus::Ok
|
|
}
|