価格を読む

コントラクトから

二つの形があり、どちらも同じラウンドを保持します。レジストリはすべての 読み取りを 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.

feed オブジェクト

オラクルサービスから

チェーンに対してこれが足すのは、計算の過程です。どの取引所が新鮮だったか、どれが中央値に 入ったか、それぞれが中央値からどれだけ離れていたか、そしてなぜフィードが公開していないか。 価格が欠けているとき、理由があるのはここです。

二つのポート、二つの相手。読み取りの 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.

利用者にとってこれは三つのことを意味します。株式のフィードは、陳腐化することなく 2 日半 変わらないままでいられます。素朴な鮮度の検査は、毎週末すべての現実世界フィードを、そして 毎晩それぞれを拒否します。そして、今まさに誰も作っていない価格で清算されてはならない ポジションは、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 をインデックス付きの topic にして FeedUpdated を見張るべきです。 それはアダプターが発行しないイベントです。そして長い沈黙は、決して来ないエラーを待つのでは なく、そのままのものとして扱ってください。