streak-api 0.1.7

API for interacting with the STREAK directional markets protocol on Solana
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

//! Price-chain settlement helper for `AdminInstantSettlement`.
//!
//! Reads the open reference from `Treasury::last_close_*`, reads the Pyth close price,
//! resolves UP/DOWN, emits `PeriodSettled`, and writes the close price back to Treasury.
//! All market pool math and USDC distribution happen off-chain.

use steel::*;

use crate::consts::PYTH_BTC_USD_FEED_ID;
use crate::error::StreakError;
use crate::event::PeriodSettled;
use crate::pyth::{load_fresh_price, outcome_from_open_close, Price};
use crate::state::Treasury;

pub struct SettlementResult {
    pub outcome: u8,
    pub close_px: Price,
    pub open_px: Price,
}

/// Read open from Treasury, read close from Pyth, return outcome + both prices.
/// Returns `Err(GenesisNotSet)` if the price chain has not been seeded.
pub fn resolve_settlement(
    treasury: &Treasury,
    pyth_price_feed_info: &AccountInfo<'_>,
    unix_timestamp: i64,
) -> Result<SettlementResult, ProgramError> {
    if treasury.last_close_price == 0 {
        return Err(StreakError::GenesisNotSet.into());
    }

    let open_px = Price {
        price: treasury.last_close_price,
        conf: 0,
        expo: treasury.last_close_expo,
        publish_time: treasury.last_close_publish_time,
    };

    let close_px = load_fresh_price(pyth_price_feed_info, &PYTH_BTC_USD_FEED_ID, unix_timestamp)?;
    let outcome = outcome_from_open_close(open_px, close_px)?;

    Ok(SettlementResult { outcome, close_px, open_px })
}

/// Write close price back to Treasury and emit the `PeriodSettled` event.
pub fn commit_settlement(
    treasury: &mut Treasury,
    result: SettlementResult,
    series_id: u16,
    period: u64,
) {
    PeriodSettled {
        series_id,
        outcome: result.outcome,
        _pad: [0; 5],
        period,
        close_price: result.close_px.price,
        close_expo: result.close_px.expo,
        _pad2: [0; 4],
        close_publish_time: result.close_px.publish_time,
        open_price: result.open_px.price,
        open_expo: result.open_px.expo,
        _pad3: [0; 4],
    }
    .log();

    treasury.last_close_price = result.close_px.price;
    treasury.last_close_expo = result.close_px.expo;
    treasury.last_close_publish_time = result.close_px.publish_time;
}

/// UP outcome constant (close > open).
pub const SIDE_UP: u8 = 0;
/// DOWN outcome constant (close <= open, including ties).
pub const SIDE_DOWN: u8 = 1;