Struct RawRequest 

pub struct RawRequest<'a> { /* private fields */ }

Основные пагинаторы и типы контекстов блокирующего API. Блокирующие HTTP-клиенты ISS API. Универсальный builder для произвольных ISS endpoint-ов.

Нужен как низкоуровневый путь для endpoint-ов, которые пока не покрыты строгим типизированным API.

Implementations

impl<'a> RawIssRequestBuilder<'a>

pub fn path(self, path: impl Into<String>) -> Self

Установить endpoint-path относительно /iss/.

Допускаются формы:

• engines
• engines.json
• /iss/engines

Examples found in repository

examples/actual_indexes_dump.rs (line 185)

fn load_board_snapshots_all_pages(
    moex_client: &Client,
    engine: &str,
    market: &str,
    board: &str,
) -> Result<Vec<SecuritySnapshot>, MoexError> {
    let endpoint = format!("engines/{engine}/markets/{market}/boards/{board}/securities.json");
    let mut start = 0_u32;
    let mut snapshots = Vec::new();
    let mut first_secid_on_previous_page = None;
    let limit = BOARD_SNAPSHOTS_PAGE_LIMIT.to_string();

    loop {
        let payload = with_retry(retry_policy(), || {
            moex_client
                .raw()
                .path(endpoint.as_str())
                .only("securities,marketdata")
                .columns("securities", "SECID,LOTSIZE")
                .columns("marketdata", "SECID,LAST")
                .param("start", start.to_string())
                .param("limit", limit.as_str())
                .send_payload()
        })?;

        let (page, first_secid_on_page) = parse_board_snapshots_page(&payload, endpoint.as_str())?;
        if page.is_empty() {
            break;
        }

        if let (Some(previous), Some(current)) =
            (&first_secid_on_previous_page, &first_secid_on_page)
            && previous == current
        {
            break;
        }
        first_secid_on_previous_page = first_secid_on_page;

        let page_len = u32::try_from(page.len()).map_err(|_| MoexError::PaginationOverflow {
            endpoint: endpoint.clone().into_boxed_str(),
            start,
            limit: BOARD_SNAPSHOTS_PAGE_LIMIT,
        })?;

        snapshots.extend(page);
        if page_len < BOARD_SNAPSHOTS_PAGE_LIMIT {
            break;
        }
        start = start
            .checked_add(page_len)
            .ok_or_else(|| MoexError::PaginationOverflow {
                endpoint: endpoint.clone().into_boxed_str(),
                start,
                limit: BOARD_SNAPSHOTS_PAGE_LIMIT,
            })?;
    }

    Ok(snapshots)
}

pub fn param(self, key: impl Into<String>, value: impl Into<String>) -> Self

Добавить query-параметр.

Examples found in repository

examples/actual_indexes_dump.rs (line 189)

fn load_board_snapshots_all_pages(
    moex_client: &Client,
    engine: &str,
    market: &str,
    board: &str,
) -> Result<Vec<SecuritySnapshot>, MoexError> {
    let endpoint = format!("engines/{engine}/markets/{market}/boards/{board}/securities.json");
    let mut start = 0_u32;
    let mut snapshots = Vec::new();
    let mut first_secid_on_previous_page = None;
    let limit = BOARD_SNAPSHOTS_PAGE_LIMIT.to_string();

    loop {
        let payload = with_retry(retry_policy(), || {
            moex_client
                .raw()
                .path(endpoint.as_str())
                .only("securities,marketdata")
                .columns("securities", "SECID,LOTSIZE")
                .columns("marketdata", "SECID,LAST")
                .param("start", start.to_string())
                .param("limit", limit.as_str())
                .send_payload()
        })?;

        let (page, first_secid_on_page) = parse_board_snapshots_page(&payload, endpoint.as_str())?;
        if page.is_empty() {
            break;
        }

        if let (Some(previous), Some(current)) =
            (&first_secid_on_previous_page, &first_secid_on_page)
            && previous == current
        {
            break;
        }
        first_secid_on_previous_page = first_secid_on_page;

        let page_len = u32::try_from(page.len()).map_err(|_| MoexError::PaginationOverflow {
            endpoint: endpoint.clone().into_boxed_str(),
            start,
            limit: BOARD_SNAPSHOTS_PAGE_LIMIT,
        })?;

        snapshots.extend(page);
        if page_len < BOARD_SNAPSHOTS_PAGE_LIMIT {
            break;
        }
        start = start
            .checked_add(page_len)
            .ok_or_else(|| MoexError::PaginationOverflow {
                endpoint: endpoint.clone().into_boxed_str(),
                start,
                limit: BOARD_SNAPSHOTS_PAGE_LIMIT,
            })?;
    }

    Ok(snapshots)
}

pub fn only(self, tables: impl Into<String>) -> Self

Добавить параметр iss.only.

Examples found in repository

examples/actual_indexes_dump.rs (line 186)

fn load_board_snapshots_all_pages(
    moex_client: &Client,
    engine: &str,
    market: &str,
    board: &str,
) -> Result<Vec<SecuritySnapshot>, MoexError> {
    let endpoint = format!("engines/{engine}/markets/{market}/boards/{board}/securities.json");
    let mut start = 0_u32;
    let mut snapshots = Vec::new();
    let mut first_secid_on_previous_page = None;
    let limit = BOARD_SNAPSHOTS_PAGE_LIMIT.to_string();

    loop {
        let payload = with_retry(retry_policy(), || {
            moex_client
                .raw()
                .path(endpoint.as_str())
                .only("securities,marketdata")
                .columns("securities", "SECID,LOTSIZE")
                .columns("marketdata", "SECID,LAST")
                .param("start", start.to_string())
                .param("limit", limit.as_str())
                .send_payload()
        })?;

        let (page, first_secid_on_page) = parse_board_snapshots_page(&payload, endpoint.as_str())?;
        if page.is_empty() {
            break;
        }

        if let (Some(previous), Some(current)) =
            (&first_secid_on_previous_page, &first_secid_on_page)
            && previous == current
        {
            break;
        }
        first_secid_on_previous_page = first_secid_on_page;

        let page_len = u32::try_from(page.len()).map_err(|_| MoexError::PaginationOverflow {
            endpoint: endpoint.clone().into_boxed_str(),
            start,
            limit: BOARD_SNAPSHOTS_PAGE_LIMIT,
        })?;

        snapshots.extend(page);
        if page_len < BOARD_SNAPSHOTS_PAGE_LIMIT {
            break;
        }
        start = start
            .checked_add(page_len)
            .ok_or_else(|| MoexError::PaginationOverflow {
                endpoint: endpoint.clone().into_boxed_str(),
                start,
                limit: BOARD_SNAPSHOTS_PAGE_LIMIT,
            })?;
    }

    Ok(snapshots)
}

pub fn columns( self, table: impl Into<String>, columns: impl Into<String>, ) -> Self

Добавить параметр <table>.columns.

Examples found in repository

examples/actual_indexes_dump.rs (line 187)

fn load_board_snapshots_all_pages(
    moex_client: &Client,
    engine: &str,
    market: &str,
    board: &str,
) -> Result<Vec<SecuritySnapshot>, MoexError> {
    let endpoint = format!("engines/{engine}/markets/{market}/boards/{board}/securities.json");
    let mut start = 0_u32;
    let mut snapshots = Vec::new();
    let mut first_secid_on_previous_page = None;
    let limit = BOARD_SNAPSHOTS_PAGE_LIMIT.to_string();

    loop {
        let payload = with_retry(retry_policy(), || {
            moex_client
                .raw()
                .path(endpoint.as_str())
                .only("securities,marketdata")
                .columns("securities", "SECID,LOTSIZE")
                .columns("marketdata", "SECID,LAST")
                .param("start", start.to_string())
                .param("limit", limit.as_str())
                .send_payload()
        })?;

        let (page, first_secid_on_page) = parse_board_snapshots_page(&payload, endpoint.as_str())?;
        if page.is_empty() {
            break;
        }

        if let (Some(previous), Some(current)) =
            (&first_secid_on_previous_page, &first_secid_on_page)
            && previous == current
        {
            break;
        }
        first_secid_on_previous_page = first_secid_on_page;

        let page_len = u32::try_from(page.len()).map_err(|_| MoexError::PaginationOverflow {
            endpoint: endpoint.clone().into_boxed_str(),
            start,
            limit: BOARD_SNAPSHOTS_PAGE_LIMIT,
        })?;

        snapshots.extend(page);
        if page_len < BOARD_SNAPSHOTS_PAGE_LIMIT {
            break;
        }
        start = start
            .checked_add(page_len)
            .ok_or_else(|| MoexError::PaginationOverflow {
                endpoint: endpoint.clone().into_boxed_str(),
                start,
                limit: BOARD_SNAPSHOTS_PAGE_LIMIT,
            })?;
    }

    Ok(snapshots)
}

pub fn metadata(self, metadata: IssToggle) -> Self

Явно задать iss.meta для текущего raw-запроса.

pub fn data(self, data: IssToggle) -> Self

Добавить параметр iss.data.

pub fn json(self, json: impl Into<String>) -> Self

Добавить параметр iss.json.

pub fn version(self, version: IssToggle) -> Self

Добавить параметр iss.version.

pub fn options(self, options: IssRequestOptions) -> Self

Применить пакет системных iss.*-опций.

pub fn send_response(self) -> Result<RawIssResponse, MoexError>

Выполнить raw-запрос и вернуть полный HTTP-ответ.

В отличие от send_payload, метод не проверяет 2xx и JSON-формат.

pub fn send_payload(self) -> Result<String, MoexError>

Выполнить raw-запрос и вернуть тело ответа как строку.

Examples found in repository

examples/actual_indexes_dump.rs (line 191)

fn load_board_snapshots_all_pages(
    moex_client: &Client,
    engine: &str,
    market: &str,
    board: &str,
) -> Result<Vec<SecuritySnapshot>, MoexError> {
    let endpoint = format!("engines/{engine}/markets/{market}/boards/{board}/securities.json");
    let mut start = 0_u32;
    let mut snapshots = Vec::new();
    let mut first_secid_on_previous_page = None;
    let limit = BOARD_SNAPSHOTS_PAGE_LIMIT.to_string();

    loop {
        let payload = with_retry(retry_policy(), || {
            moex_client
                .raw()
                .path(endpoint.as_str())
                .only("securities,marketdata")
                .columns("securities", "SECID,LOTSIZE")
                .columns("marketdata", "SECID,LAST")
                .param("start", start.to_string())
                .param("limit", limit.as_str())
                .send_payload()
        })?;

        let (page, first_secid_on_page) = parse_board_snapshots_page(&payload, endpoint.as_str())?;
        if page.is_empty() {
            break;
        }

        if let (Some(previous), Some(current)) =
            (&first_secid_on_previous_page, &first_secid_on_page)
            && previous == current
        {
            break;
        }
        first_secid_on_previous_page = first_secid_on_page;

        let page_len = u32::try_from(page.len()).map_err(|_| MoexError::PaginationOverflow {
            endpoint: endpoint.clone().into_boxed_str(),
            start,
            limit: BOARD_SNAPSHOTS_PAGE_LIMIT,
        })?;

        snapshots.extend(page);
        if page_len < BOARD_SNAPSHOTS_PAGE_LIMIT {
            break;
        }
        start = start
            .checked_add(page_len)
            .ok_or_else(|| MoexError::PaginationOverflow {
                endpoint: endpoint.clone().into_boxed_str(),
                start,
                limit: BOARD_SNAPSHOTS_PAGE_LIMIT,
            })?;
    }

    Ok(snapshots)
}

pub fn send_json<T>(self) -> Result<T, MoexError>

where T: DeserializeOwned,

Выполнить raw-запрос и декодировать JSON в пользовательский тип.

pub fn send_table<T>( self, table: impl Into<String>, ) -> Result<Vec<T>, MoexError>

where T: DeserializeOwned,

Выполнить raw-запрос и декодировать строки выбранной ISS-таблицы в пользовательский тип.