22 lines
614 B
Python
22 lines
614 B
Python
from __future__ import annotations
|
|
|
|
from typing import Dict, List
|
|
from ..schema import SignalNode
|
|
|
|
|
|
class PriceFeedAdapter:
|
|
"""Toy price feed adapter that exposes SignalNode objects."""
|
|
|
|
def __init__(self, feed_name: str = "toy-price-feed") -> None:
|
|
self.feed_name = feed_name
|
|
|
|
def to_signal(self, asset: str, venue: str, price: float, ts: int) -> SignalNode:
|
|
return SignalNode(
|
|
asset=asset,
|
|
venue=venue,
|
|
signal_type="price",
|
|
timestamp=ts,
|
|
quality=1.0,
|
|
metadata={"feed": self.feed_name, "price": price},
|
|
)
|