Syndica Dyndexer Runtime

此crate提供对Syndica Dyndexer服务提供的运行时功能进行访问。

示例

一个简单的示例是使用anchor功能，该功能包含一个Anchor事件的解析器，并可以将任何anchor事件作为输出记录

use std::sync::OnceLock;

use syndica_dyndexer_runtime::{processor, record_output, Event, Output};
use syndica_dyndexer_runtime::anchor::AnchorIdl;

const PROGRAM_ADDR: &str = "...";
const PROGRAM_IDL: &[u8] = include_bytes!("path/to/program-idl.json");
static IDL: OnceLock<AnchorIdl> = OnceLock::new();

#[processor]
fn process(event: Event) {
    let idl = IDL.get_or_init(|| AnchorIdl::deserialize(PROGRAM_ADDR, PROGRAM_IDL));

    if let Event::Transaction(transaction) = event {
        let events = idl.parse_events(&transaction);
        let signature = transaction.signature;

        for (idx, event) in events.into_iter().enumerate() {
            record_output(&Output::Object {
                uid: format!("{signature}:{idx}"),
                key: None,
                value: &event.data,
            });
        }
    }
}