Struct AccountServiceImpl 

pub struct AccountServiceImpl<T: IgHttpClient> { /* private fields */ }

Implementation of the account service

Implementations

impl<T: IgHttpClient> AccountServiceImpl<T>

pub fn new(config: Arc<Config>, client: Arc<T>) -> Self

Creates a new instance of the account service

pub fn get_config(&self) -> Arc<Config>

Gets the current configuration

Returns

• The current configuration as an Arc<Config>

pub fn set_config(&mut self, config: Arc<Config>)

Sets a new configuration

Arguments

• config - The new configuration to use

Trait Implementations

impl<T: IgHttpClient + 'static> AccountService for AccountServiceImpl<T>

fn get_positions_w_filter<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, filter: &'life1 str, session: &'life2 IgSession, ) -> Pin<Box<dyn Future<Output = Result<Positions, AppError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Retrieves the current open positions and applies a client-side filter to them.

This function first delegates to get_positions to fetch all open positions and then narrows the result set in-memory using the provided filter. The exact matching logic is implementation-defined for now (based on how the filter predicate is applied within this function).

Logging:

• Emits a debug log before and after fetching/filtering to aid observability.

Arguments:

• filter: A string used to filter the list of positions. The matching semantics depend on the predicate used in this function (e.g., substring match against one or more Position fields).
• session: An authenticated IG session used to authorize the HTTP request.

Returns:

• Ok(Positions): The filtered collection of open positions.
• Err(AppError): If fetching or processing fails. Possible error sources include network issues, deserialization errors, authorization failures, rate limiting, or invalid input.

fn get_accounts<'life0, 'life1, 'async_trait>( &'life0 self, session: &'life1 IgSession, ) -> Pin<Box<dyn Future<Output = Result<AccountInfo, AppError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Gets information about all user accounts

fn get_positions<'life0, 'life1, 'async_trait>( &'life0 self, session: &'life1 IgSession, ) -> Pin<Box<dyn Future<Output = Result<Positions, AppError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Gets open positions

fn get_working_orders<'life0, 'life1, 'async_trait>( &'life0 self, session: &'life1 IgSession, ) -> Pin<Box<dyn Future<Output = Result<WorkingOrders, AppError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Gets working orders

fn get_activity<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, session: &'life1 IgSession, from: &'life2 str, to: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<AccountActivity, AppError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Gets account activity

fn get_activity_with_details<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, session: &'life1 IgSession, from: &'life2 str, to: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<AccountActivity, AppError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Gets detailed account activity

fn get_transactions<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, session: &'life1 IgSession, from: &'life2 str, to: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<TransactionHistory, AppError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Gets transaction history for a given period, handling pagination automatically.