가격 읽기

컨트랙트에서

두 가지 모양이 있고 같은 라운드를 보유합니다. 레지스트리는 모든 읽기를 feedId로 키잉하고, 피드별 어댑터는 하나의 feedId를 주소에 고정하므로 Chainlink를 상대로 쓰인 소비자는 피드 id에 대해 아무것도 알 필요가 없습니다.

// The adapter: what an existing Chainlink consumer already calls.
AggregatorV3Interface feed = AggregatorV3Interface(adapter);
(, int256 answer,, uint256 updatedAt,) = feed.latestRoundData();
uint8 decimals = feed.decimals();          // 8 on every feed today - read it anyway

// The registry: one address for all 33 feeds, keyed by the hash of the symbol.
bytes32 feedId = keccak256(bytes("XAU/USD"));
(, int256 gold,, uint256 goldUpdatedAt,) = registry.latestRoundData(feedId);
uint8 state = registry.status(feedId);     // 1 open, 2 closed
uint64 observedAt = registry.latestObservedAt(feedId);

Chainlink 소비자가 이것에 기대기 전에 알아야 할 여섯 가지입니다.

• One adapter per feed, holding no data: it stores the registry address and its own feedId and forwards every call. Rounds live in the registry.
• startedAt equals updatedAt. Every round is a single transmission, as an OCR feed reports it, and answeredInRound equals roundId because no round is ever carried over.
• updatedAt is the block timestamp of the publishing transaction, not the time the price was observed. The observation time is observedAt(feedId, roundId) on the registry, which usually LEADS updatedAt - that is why it is kept off the Chainlink tuple, where startedAt <= updatedAt is assumed.
• The adapter emits no events. A consumer watching AnswerUpdated on it sees nothing; the registry emits FeedUpdated(feedId, ...) instead, and feedId is indexed.
• version() returns 2, which is this layer's version and not a Chainlink aggregator version.
• latestRoundData() on a feed that has never been written reverts with Error("No data present"), bubbled from the registry unchanged. The legacy latestAnswer() does not revert - it reads the ring at index 0 and returns 0, which is exactly the zero a consumer must not treat as a price.

직접 검사하는 소비자는 어댑터보다 레지스트리를 원합니다. 상태와 관측 시각이 Chainlink 튜플에 없기 때문입니다.

interface IPickleFeeds {
    function latestRoundData(bytes32 feedId)
        external view returns (uint80, int256, uint256, uint256, uint80);
    function status(bytes32 feedId) external view returns (uint8);
    function decimals(bytes32 feedId) external view returns (uint8);
}

uint8 constant STATUS_OPEN = 1;
uint8 constant STATUS_CLOSED = 2;

/// maxAge is YOUR tolerance, in seconds, and it only applies while the market is open.
function priceOf(IPickleFeeds registry, bytes32 feedId, uint256 maxAge)
    internal view returns (int256 answer, uint8 decimals)
{
    uint256 updatedAt;
    // Reverts with Error("No data present") when the feed has never been written.
    (, answer,, updatedAt,) = registry.latestRoundData(feedId);
    require(answer > 0, "feed: non-positive answer");

    uint8 state = registry.status(feedId);
    require(state == STATUS_OPEN || state == STATUS_CLOSED, "feed: status unknown");
    // A closed market's last print is the right price for as long as it is closed.
    if (state == STATUS_OPEN) {
        require(block.timestamp - updatedAt <= maxAge, "feed: stale");
    }
    decimals = registry.decimals(feedId);
}

레지스트리의 읽기 함수

• latestRoundData(bytes32 feedId) returns (uint80 roundId, int256 answer, uint256 startedAt, uint256 updatedAt, uint80 answeredInRound)
• getRoundData(bytes32 feedId, uint80 roundId) returns (uint80, int256, uint256, uint256, uint80)
• latestAnswer(bytes32 feedId) returns (int256)
• latestTimestamp(bytes32 feedId) returns (uint256)
• latestRound(bytes32 feedId) returns (uint256)
• observedAt(bytes32 feedId, uint80 roundId) returns (uint64)
• latestObservedAt(bytes32 feedId) returns (uint64)
• status(bytes32 feedId) returns (uint8)
• source(bytes32 feedId) returns (uint8)
• decimals(bytes32 feedId) returns (uint8)
• description(bytes32 feedId) returns (string)
• symbol(bytes32 feedId) returns (string)
• feed(bytes32 feedId) returns (FeedView)
• feeds(uint256 offset, uint256 limit) returns (FeedView[])
• feedCount() returns (uint256)
• feedIdAt(uint256 index) returns (bytes32)
• adapterOf(bytes32 feedId) returns (address)
• adapterAddress(bytes32 feedId) returns (address)
• version() returns (uint256)

어댑터의 읽기 함수

• decimals() returns (uint8)
• description() returns (string)
• version() returns (uint256)
• latestRoundData() returns (uint80 roundId, int256 answer, uint256 startedAt, uint256 updatedAt, uint80 answeredInRound)
• getRoundData(uint80 roundId) returns (uint80, int256, uint256, uint256, uint80)
• latestAnswer() returns (int256)
• latestTimestamp() returns (uint256)
• latestRound() returns (uint256)
• symbol() returns (string)

이 사이트에는 어느 주소도 찍혀 있지 않습니다. 주소 해석하기가 체인에서 그것을 얻는 방법입니다.

답과 그 소수 자리

답은 부동소수도 wei도 아닌 고정 소수점 정수입니다. 제네시스 집합의 모든 피드는 decimals = 8을 갖고 있으므로, 415012345678이라는 답은 4150.12345678입니다. 그 필드는 0에서 18까지 허용하고 피드마다 다르므로, 8을 소비자에 컴파일해 넣지 말고 피드에서 읽으십시오.

// answer arrives as a decimal string, because it does not fit a JS number safely.
const { answer, decimals, price } = result;         // "415012345678", 8, "4150.12345678"
const scaled = BigInt(answer);                       // keep it integral
const human = Number(scaled) / 10 ** decimals;       // only for display

// price is the same number pre-formatted with exactly `decimals` digits.
// Never parseFloat(answer) and never compare two feeds without rescaling both.

JSON-RPC로

세 개의 메서드이며, 전부 키도 계정도 필요 없는 평범한 읽기입니다. 다른 모든 메서드와 함께 JSON-RPC 레퍼런스에 실려 있습니다. 아래는 그것들이 이 레이어에 대해 답하는 내용입니다.

curl -s $RPC_URL -H 'content-type: application/json' \
  -d '{"jsonrpc":"2.0","id":1,"method":"pickle_price","params":["AAPL-USD"]}'

# -> {"jsonrpc":"2.0","id":1,"result":{
#      "symbol":"AAPL/USD","feedId":"0x...","adapter":"0x...","decimals":8,
#      "roundId":184,"answer":"23144000000","price":"231.44000000",
#      "updatedAt":1758470400,"observedAt":1758470396,
#      "status":2,"statusName":"closed","source":2,"sourceName":"pyth",
#      "ageSecs":51840,"staleAfterSecs":330,"staleOnchain":false, ... }}
#
# staleOnchain is FALSE at fourteen hours old, because the market is closed.

피드 객체

오라클 서비스에서

그것이 체인에 더해 주는 것은 풀이 과정입니다. 어느 거래소가 신선했는지, 어느 것이 중앙값에 포함되었는지, 각각이 거기서 얼마나 떨어져 있었는지, 그리고 피드가 왜 발표하지 않는지입니다. 가격이 없을 때 그 이유가 있는 곳이 여기입니다.

포트 둘, 청중 둘입니다. 읽기 API는 3005에서 답하고, 노드가 폴링하는 배치는 3006의 별도 리스너이며 본문 바이트 그대로의 HMAC을 X-Pickle-Batch-Hmac에 실어 나릅니다. 공개 리스너에 /v1/publish를 물으면 그 라우트가 있다고 인정하는 대신 404로 답합니다. 모든 오류 본문은 고정된 문자열입니다. 경로도, 상류도, 예외 텍스트도 없습니다.

피드 뷰가 체인 너머로 담는 것

신선도

staleOnchain은 노드가 그 규칙들을 여러분 대신 적용한 것이며, 봉인 시각이 아니라 요청 시각의 벽시계를 씁니다. 편의 기능입니다. 컨트랙트 안의 소비자에게는 그런 필드가 없으므로 updatedAt을 자기 허용치와 비교해야 하며, 그것이 위의 예제가 하는 검사입니다.

모든 경우에 정직한 신호는 updatedAt입니다. 발표가 멈추면 그저 나아가기를 멈추기 때문입니다. 기댈 만한 온체인 나이 검사는 없습니다. There is deliberately no on-chain age check on observedAt. The node replays its write-ahead log with the restart-time timestamp, so a rule of the form block.timestamp - observedAt <= maxAge would fail every replayed update. Freshness is enforced by the publisher, which does not submit a stale aggregate, and by you, through updatedAt - which simply stops advancing when publication stops.

서비스는 stale과 함께 reason을 보고하며, 그 이유들은 따로 다룰 값어치가 있습니다. too_few_sources는 거래소가 빠졌다는 뜻이고, cross_check_diverged는 거래소들과 두 번째 소스가 어긋나서 피드가 일부러 침묵한다는 뜻이며, market_closed는 아무 문제도 없다는 뜻입니다. 각각이 어떻게 생기는지는 가격이 만들어지는 방식에 있습니다.

시장 개장 시간

Each feed with a Pyth leg carries a schedule: a time zone, seven day patterns starting Monday, and a list of dated overrides for holidays and half-days. It is resolved against the real time-zone database, so a market opens at 09:30 local whatever the daylight-saving offset that day.

The upstream also reports whether the market is open right now. That flag wins while its poll is fresh and no scheduled transition has passed since - it knows about a halt or an unlisted holiday that the schedule does not. Otherwise the schedule decides.

The status machinery applies to a feed whose price comes from the second source, which is every real-world feed. A feed publishing an exchange median reports status open, and that is consistent rather than a gap: all thirteen of them are crypto pairs whose schedule is open every day, all day.

소비자에게 그것은 세 가지를 뜻합니다. 주식 피드는 오래된 것이 아니면서도 이틀 반 동안 정당하게 변하지 않을 수 있습니다. 순진한 신선도 검사는 주말마다 모든 실물 자산 피드를, 그리고 밤마다 그 하나하나를 거부합니다. 그리고 지금 아무도 만들고 있지 않은 가격으로 청산되어서는 안 되는 포지션이라면 status를 읽고 그것이 2인 동안에는 움직이기를 거부해야 합니다. 옳지만 멈춰 있는 그대로의 가격으로 움직이는 대신에 말입니다.

const feed = result;                       // one feed object

if (feed.roundId === 0) throw new Error("never written");
if (feed.statusName === "unknown") throw new Error("status not established");

const closed = feed.statusName === "closed";
if (!closed && feed.staleOnchain) throw new Error("stale while open");

// closed === true is a valid, current price for a market that is not trading.
// Decide deliberately whether your product acts on it.

라운드, 히스토리, 건너뜀

Rounds live in a fixed-size ring per feed rather than an append-only history. Round r sits at index r % capacity, is readable while latestRound - r < capacity, and is overwritten afterwards.

getRoundData on an evicted round reverts with "No data present", not with a zero answer. A feed with capacity 1,024 keeps its last 1,024 rounds and no more, so an indexer that wants full history reads the FeedUpdated logs rather than paging the ring.

updateMany never reverts on a bad item. One stale or out-of-range feed in a batch of sixty must not cost the other fifty-nine their round, so a bad item is skipped with a FeedSkipped(feedId, reason) log and the rest are written. Only a malformed batch - mismatched array lengths, over maxBatch, or a sender that is not the publisher - reverts.

건너뛴 항목은 FeedSkipped 로그로만 보입니다. 라운드는 나아가지 않고 이전 답이 그대로 섭니다. 그러므로 피드 하나를 지켜보는 소비자는 피드 id를 인덱싱된 토픽으로 삼아 FeedUpdated를 지켜보아야 하며 - 어댑터가 발행하지 않는 이벤트입니다 - 긴 침묵은 결코 오지 않을 오류를 기다리는 대신 있는 그대로 받아들여야 합니다.