offchainmetadata

type Config struct {
	Logger *slog.Logger
	Store  Store
	// HTTPClient customizes fetch requests. When private addresses are not
	// allowed, New clones the client and replaces unsafe transport dial hooks.
	HTTPClient            *http.Client
	Interval              time.Duration
	RequestTimeout        time.Duration
	UserAgent             string
	IPFSGatewayURL        string
	BatchSize             int
	MaxBytes              int64
	AllowPrivateAddresses bool
}

type Fetcher struct {
	// contains filtered or unexported fields
}

type PoolMetadataFields struct {
	Name        string
	Description string
	Ticker      string
	Homepage    string
}

type Store interface {
	EnsureOffchainMetadataPointers(
		ctx context.Context,
		now time.Time,
		txn types.Txn,
	) (int, error)
	GetOffchainMetadataFetchBatch(
		ctx context.Context,
		limit int,
		now time.Time,
		txn types.Txn,
	) ([]models.OffchainMetadata, error)
	SetOffchainMetadataFetchResult(
		ctx context.Context,
		doc *models.OffchainMetadata,
		txn types.Txn,
	) error
}

type TokenRegistryConfig struct {
	Logger *slog.Logger
	Store  TokenRegistryStore
	// HTTPClient customizes the download. When private addresses are not
	// allowed, NewTokenRegistrySync clones the client and replaces unsafe
	// transport dial hooks, exactly as the per-URL fetcher does.
	HTTPClient *http.Client
	// SourceURL overrides the network-derived registry source, for operators
	// running a mirror. Empty selects by Network.
	SourceURL string
	// Network selects the default registry source; anything other than
	// "mainnet" uses the IOG testnet registry.
	Network        string
	UserAgent      string
	Interval       time.Duration
	RequestTimeout time.Duration
	// MaxBytes caps the compressed download; MaxEntryBytes caps one mapping.
	MaxBytes      int64
	MaxEntryBytes int64
	// StoreLogos opts into persisting base64 logo payloads, which are
	// roughly 90% of registry bytes. Off by default.
	StoreLogos bool
	// AllowPrivateAddresses permits fetching private, loopback, and
	// link-local addresses. Leave false for the default SSRF guard.
	AllowPrivateAddresses bool
}

type TokenRegistryStore interface {
	UpsertTokenRegistryEntries(
		ctx context.Context,
		entries []models.TokenRegistryEntry,
		syncedAt time.Time,
		txn types.Txn,
	) (int, error)
	PruneTokenRegistryEntriesBefore(
		ctx context.Context,
		cutoff time.Time,
		txn types.Txn,
	) (int, error)
	GetSyncState(key string, txn types.Txn) (string, error)
	SetSyncState(key, value string, txn types.Txn) error
}

type TokenRegistrySync struct {
	// contains filtered or unexported fields
}