defi-tracker-lifecycle 0.1.5

Pure-logic crate for DeFi order lifecycle tracking on Solana — classification, correlation, and state machine logic
Documentation 
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

/// A decoded Solana instruction row as produced by the upstream indexer.
#[derive(serde::Deserialize)]
pub struct RawInstruction {
    /// Database row id.
    pub id: i64,
    /// Transaction signature (base58).
    pub signature: String,
    /// Position of this instruction within the transaction.
    pub instruction_index: i32,
    /// Hierarchical instruction path within the transaction (for example `"4.1"`).
    #[serde(default)]
    pub instruction_path: Option<String>,
    /// Top-level program that was invoked.
    pub program_id: String,
    /// Innermost program if this is a CPI; equals `program_id` otherwise.
    pub inner_program_id: String,
    /// Carbon-decoded instruction discriminator name (e.g. `"OpenDca"`).
    pub instruction_name: String,
    /// Parsed account list, if available.
    pub accounts: Option<serde_json::Value>,
    /// Parsed instruction arguments, if available.
    pub args: Option<serde_json::Value>,
    /// Solana slot in which the transaction landed.
    pub slot: i64,
}

/// A decoded Solana event (log) row as produced by the upstream indexer.
#[derive(serde::Deserialize)]
pub struct RawEvent {
    /// Database row id.
    pub id: i64,
    /// Transaction signature (base58).
    pub signature: String,
    /// Position of this event within the transaction logs.
    pub event_index: i32,
    /// Hierarchical event path within the transaction (for example `"4.1"`).
    #[serde(default)]
    pub event_path: Option<String>,
    /// Top-level program that was invoked.
    pub program_id: String,
    /// Innermost program if this is a CPI; equals `program_id` otherwise.
    pub inner_program_id: String,
    /// Carbon-decoded event discriminator name (e.g. `"FilledEvent"`).
    pub event_name: String,
    /// Parsed event fields as `{"EventName": {..}}` JSON.
    pub fields: Option<serde_json::Value>,
    /// Solana slot in which the transaction landed.
    pub slot: i64,
}

impl RawEvent {
    /// Returns the parent instruction path for this event, if `event_path` is present.
    pub fn parent_instruction_path(&self) -> Option<&str> {
        self.event_path
            .as_deref()
            .map(Self::parent_instruction_path_from)
    }

    /// Strips the final nested segment from an event path to recover the parent instruction path.
    pub fn parent_instruction_path_from(event_path: &str) -> &str {
        event_path
            .rsplit_once('.')
            .map_or(event_path, |(instruction_path, _)| instruction_path)
    }
}

/// Caller-supplied context needed to resolve certain events.
///
/// Kamino `OrderDisplayEvent` carries no order PDA in its payload.
/// The caller should use raw path metadata when available to pre-fetch the
/// exact order PDA from the matching instruction, then pass the result here
/// so the adapter can correlate the event.
pub struct ResolveContext {
    /// Order PDAs extracted from instruction accounts for the same transaction.
    /// Required for Kamino `OrderDisplayEvent`; `None` causes `Uncorrelated`.
    pub pre_fetched_order_pdas: Option<Vec<String>>,
}