relay

type ArweaveBlock struct {
	// Arweave Blocks with L1 transactions, parsed from Sequencer's txs
	Message *types.MsgArweaveBlock

	// Corresponding block downloaded from Arweave
	Block *arweave.Block

	// Transactions from the block
	Transactions []*arweave.Transaction
}

type ArweaveParser struct {
	*task.Task

	Output chan *Payload
	// contains filtered or unexported fields
}

type Controller struct {
	*task.Task
}

type OneBlockDownloader struct {
	*task.Task

	Output chan *Payload
	// contains filtered or unexported fields
}

type Parser struct {
	*task.Task

	Output chan *Payload
	// contains filtered or unexported fields
}

type Payload struct {
	SequencerBlockHash      string
	SequencerBlockHeight    int64
	SequencerBlockTimestamp int64

	// L2 interactions parsed from Sequencer's txs
	Interactions []*model.Interaction

	// Bundle items that will be sent to bundlr.network
	BundleItems []*model.BundleItem

	// Info about Arweave blocks
	ArweaveBlocks []*ArweaveBlock
}

type Source struct {
	*task.Task

	Output chan *types.Block
	// contains filtered or unexported fields
}

type Store struct {
	*task.Processor[*Payload, *Payload]

	DB *gorm.DB
	// contains filtered or unexported fields
}

type Streamer struct {
	*task.Task

	Output chan *types.Block
	// contains filtered or unexported fields
}

type TransactionOrchestrator struct {
	*task.Task

	Output chan *Payload

	TransactionOutput chan *arweave.Block
	// contains filtered or unexported fields
}