models

type BlockRange struct {
	Prev *ton.BlockIDExt // previous block (nil for unspecified:likely the first block in localnet)
	To   *ton.BlockIDExt // target block to process up to
}

type Filter struct {
	ID            int64            // ID is a unique identifier for the filter.
	Name          string           // Name is a human-readable name for the filter, used for identification purposes.
	Address       *address.Address // specifies the source address for which logs are being filtered.
	MsgType       tlb.MsgType      // Message type to determine how to index
	EventSig      uint32           // EventSig is a identifier for the event log(topic in external out messages, opcode in internal messages).
	StartingSeqNo uint32           // StartingSeqNo defines the starting sequence number for log polling.
	LogRetention  time.Duration    // LogRetention period for logs. 0 = keep forever.
	MaxLogsKept   int64            // Maximum logs to retain per filter. 0 = unlimited.
}

type FilterIndex map[string][]*Filter

type FilterKey struct {
	Address  *address.Address
	MsgType  tlb.MsgType
	EventSig uint32
}

type Log struct {
	ID           int64            // Unique identifier for the log entry.
	FilterID     int64            // Identifier of the filter that matched this log.
	ChainID      string           // ChainID of the blockchain where the log was generated.
	Address      *address.Address // Source contract address associated with the log entry.
	EventSig     uint32           // EventSig is a identifier for the event log(topic in external out messages, opcode in internal messages).
	Data         *cell.Cell       // Event msg body containing the log data.
	TxHash       TxHash           // Transaction hash for uniqueness within the blockchain.
	TxLT         uint64           // Logical time (LT) of the transaction, used for ordering and uniqueness.
	TxTimestamp  time.Time        // Timestamp of the transaction that generated the log.
	Block        *ton.BlockIDExt  // Shard block metadata
	MCBlockSeqno uint32           // Masterchain block sequence number
	MsgLT        uint64           // Message logical time for ordering
	MsgIndex     int64            // Index of the message within the transaction (0, 1, 2, ...)
	ExpiresAt    *time.Time       // Pre-computed expiration time (tx_timestamp + retention). nil = no expiry.
}

type RawLog struct {
	Tx    *tlb.Transaction
	Block *tlb.Block
	Data  *cell.Cell
	Topic uint32
}

type ReplayStatus int

type Tx struct {
	Transaction  *tlb.Transaction // raw TON transaction from blockchain
	Block        *ton.BlockIDExt  // shard block metadata (workchain 0)
	MCBlockSeqno uint32           // masterchain block seqno that finalized this shard block
}

type TxHash [32]byte // transaction hash

type TypedLog[T any] struct {
	Log
	TypedData T // Parsed event data from the log's cell data(on query execution)
}