mirror

type AttestedTx struct {
	Pos             Position `json:"pos"`
	Hash            string   `json:"hash"`
	AttestationHash string   `json:"attestation_hash"`
	UserID          int64    `json:"user_id"`
	Cids            []string `json:"cids"`
}

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

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

type Config struct {
	SourceChainID string
	TargetChainID string
	// StartHeight is where a first run begins, when no cursor is saved.
	StartHeight int64
	// MaxInflight bounds transactions submitted but not yet committed.
	MaxInflight int
	// CommitTimeoutBlocks is how long a submitted transaction may stay
	// uncommitted before it is resubmitted once. Core expires a forwarded
	// transaction from its mempool 10 blocks after admission, so this must be
	// longer than that or a resubmit could race the original.
	CommitTimeoutBlocks int64
	// StartupWaitBlocks is how many target blocks to wait before the first
	// submission. A previous run's in-flight transactions have either
	// committed or expired by then, so the committed check is reliable and
	// nothing is submitted twice.
	StartupWaitBlocks int64
	// SkipTx names transactions, by hash, that an operator has looked at and
	// decided not to mirror. Each is passed over when the mirror reaches it.
	SkipTx []string
	// Attester, when set, answers content-auth refusals by attesting the
	// track's own upload. Nil leaves every refusal a halt.
	Attester     *Attester
	PollInterval time.Duration
	// CursorSaveInterval throttles cursor writes while the mirror is busy.
	CursorSaveInterval time.Duration
}

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

type CursorStore interface {
	// Load returns the saved cursor, and false when none has been saved.
	Load() (Position, bool, error)
	Save(Position) error
}

type DryRunReport struct {
	From, To int64
	Blocks   int64
	// BlocksWithMirrored is how many blocks hold at least one transaction
	// the mirror would send: each costs about one target block when
	// following block by block, and empty blocks cost nothing.
	BlocksWithMirrored int64
	Transactions       int64
	ManageEntity       int64
	Plays              int64
	NotMirrored        int64
	OnTarget           int64
	HashMismatches     []string
}

type FileCursor struct{ Path string }

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

type HaltError struct {
	Pos    Position
	Hash   string
	Reason string
	Err    error
}

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

type Position struct {
	Height int64 `json:"height"`
	Index  int   `json:"index"`
}

type SkippedTx struct {
	Pos  Position `json:"pos"`
	Hash string   `json:"hash"`
}

type Source interface {
	// ChainID is the chain the source serves.
	ChainID(ctx context.Context) (string, error)
	// Tip is the latest block the source can return.
	Tip(ctx context.Context) (int64, error)
	// Block returns the raw transactions of a block, in block order, and the
	// chain ID in its header.
	Block(ctx context.Context, height int64) (chainID string, txs [][]byte, err error)
}

type SplitInfo struct {
	SourceHeight  int64   `json:"source_height"`
	TargetHeights []int64 `json:"target_heights"`
}

type Status struct {
	SourceChainID   string   `json:"source_chain_id"`
	TargetChainID   string   `json:"target_chain_id"`
	SourceTip       int64    `json:"source_tip"`
	Cursor          Position `json:"cursor"`
	LagBlocks       int64    `json:"lag_blocks"`
	Inflight        int      `json:"inflight"`
	Draining        bool     `json:"draining"`
	Submitted       int64    `json:"submitted"`
	Committed       int64    `json:"committed"`
	AlreadyOnTarget int64    `json:"already_on_target"`
	// SplitBlocks counts source blocks whose transactions landed in more than
	// one target block; LastSplit is the most recent.
	SplitBlocks int64      `json:"split_blocks"`
	LastSplit   *SplitInfo `json:"last_split,omitempty"`
	// Skipped lists the operator-skipped transactions the mirror has passed
	// over in this run.
	Skipped []SkippedTx `json:"skipped,omitempty"`
	// Attested lists the attestations the mirror made in this run.
	Attested   []AttestedTx `json:"attested,omitempty"`
	Halted     bool         `json:"halted"`
	HaltReason string       `json:"halt_reason,omitempty"`
	HaltHint   string       `json:"halt_hint,omitempty"`
	LastError  string       `json:"last_error,omitempty"`
	UpdatedAt  time.Time    `json:"updated_at"`
}

type Target interface {
	// Status returns the target's chain ID and current height.
	Status(ctx context.Context) (chainID string, height int64, err error)
	// Forward submits a transaction to the mempool of every target node.
	Forward(ctx context.Context, tx *corev1.SignedTransaction) error
	// Committed reports whether a transaction hash is in a committed block,
	// and the height of that block.
	Committed(ctx context.Context, hash string) (height int64, ok bool, err error)
}

type UploadRecord struct {
	ID          string            `json:"id"`
	OrigFileCID string            `json:"orig_file_cid"`
	Results     map[string]string `json:"results"`
	UserID      sql.NullInt64     `json:"user_id"`
}

type UploadSource interface {
	Upload(ctx context.Context, id string) (*UploadRecord, error)
}