model

Documentation

Index

• Constants
• type AdvanceInput
• type CompletionStatus
• type ConvenienceFilter
• type ConvenienceNotice
• type ConvenienceVoucher
• type ConvertedInput
• type DecoderInterface
• type Input
• type InputEdge
• type OutputEdge
• type ProcessOutputData
• type RepoSynchronizer
• type Report
• type SynchronizerFetch

Constants

const DESTINATION = "Destination"

const EXECUTED = "Executed"

const FALSE = "false"

const INPUT_INDEX = "InputIndex"

const NOTICE_SELECTOR = "c258d6e5"

const VOUCHER_SELECTOR = "ef615e2f"

Types

type AdvanceInput

type AdvanceInput struct {
	Index                  int              `db:"input_index"`
	Status                 CompletionStatus `db:"status"`
	MsgSender              common.Address   `db:"msg_sender"`
	Payload                []byte           `db:"payload"`
	BlockNumber            uint64           `db:"block_number"`
	BlockTimestamp         time.Time        `db:"block_timestamp"`
	PrevRandao             string           `db:"prev_randao"`
	AppContract            common.Address   `db:"app_contract"`
	Vouchers               []ConvenienceVoucher
	Notices                []ConvenienceNotice
	Reports                []Report
	Exception              []byte
	EspressoBlockNumber    uint64    `db:"espresso_block_number"`
	EspressoBlockTimestamp time.Time `db:"espresso_block_timestamp"`
}

Rollups advance input type.

type CompletionStatus

type CompletionStatus int

Completion status for inputs.

const (
	CompletionStatusUnprocessed CompletionStatus = iota
	CompletionStatusAccepted
	CompletionStatusRejected
	CompletionStatusException
)

type ConvenienceFilter

type ConvenienceFilter struct {
	Field *string              `json:"field,omitempty"`
	Eq    *string              `json:"eq,omitempty"`
	Ne    *string              `json:"ne,omitempty"`
	Gt    *string              `json:"gt,omitempty"`
	Gte   *string              `json:"gte,omitempty"`
	Lt    *string              `json:"lt,omitempty"`
	Lte   *string              `json:"lte,omitempty"`
	In    []*string            `json:"in,omitempty"`
	Nin   []*string            `json:"nin,omitempty"`
	And   []*ConvenienceFilter `json:"and,omitempty"`
	Or    []*ConvenienceFilter `json:"or,omitempty"`
}

type ConvenienceNotice

type ConvenienceNotice struct {
	Payload     string `db:"payload"`
	InputIndex  uint64 `db:"input_index"`
	OutputIndex uint64 `db:"output_index"`
}

type ConvenienceVoucher

type ConvenienceVoucher struct {
	Destination common.Address `db:"destination"`
	Payload     string         `db:"payload"`
	InputIndex  uint64         `db:"input_index"`
	OutputIndex uint64         `db:"output_index"`
	Executed    bool           `db:"executed"`
}

Voucher metadata type

type ConvertedInput

type ConvertedInput struct {
	MsgSender      common.Address `json:"msgSender"`
	AppContract    common.Address `json:"app_contract"`
	BlockNumber    *big.Int       `json:"blockNumber"`
	BlockTimestamp int64          `json:"blockTimestamp"`
	PrevRandao     string         `json:"prevRandao"`
	Payload        string         `json:"payload"`
}

type DecoderInterface

type DecoderInterface interface {
	HandleOutputV2(
		ctx context.Context,
		processOutputData ProcessOutputData,
	) error

	HandleInput(
		ctx context.Context,
		input InputEdge,
		status CompletionStatus,
	) error

	HandleReport(
		ctx context.Context,
		index int,
		outputIndex int,
		payload string,
	) error

	GetConvertedInput(output InputEdge) (ConvertedInput, error)

	RetrieveDestination(payload string) (common.Address, error)
}

type Input

type Input interface{}

Rollups input, which can be advance or inspect.

type InputEdge

type InputEdge struct {
	Cursor string `json:"cursor"`
	Node   struct {
		Index int    `json:"index"`
		Blob  string `json:"blob"`
	} `json:"node"`
}

type OutputEdge

type OutputEdge struct {
	Cursor string `json:"cursor"`
	Node   struct {
		Index      int    `json:"index"`
		Blob       string `json:"blob"`
		InputIndex int    `json:"inputIndex"`
	} `json:"node"`
}

type ProcessOutputData

type ProcessOutputData struct {
	OutputIndex uint64 `json:"outputIndex"`
	InputIndex  uint64 `json:"inputIndex"`
	Payload     string `json:"payload"`
	Destination string `json:"destination"`
}

type RepoSynchronizer

type RepoSynchronizer interface {
	GetDB() *sqlx.DB
	CreateTables() error
	Create(ctx context.Context, data *SynchronizerFetch) (*SynchronizerFetch, error)
	Count(ctx context.Context) (uint64, error)
	GetLastFetched(ctx context.Context) (*SynchronizerFetch, error)
}

type Report

type Report struct {
	Index      int
	InputIndex int
	Payload    []byte
}

Rollups report type.

type SynchronizerFetch

type SynchronizerFetch struct {
	Id                   int64  `db:"id"`
	TimestampAfter       uint64 `db:"timestamp_after"`
	IniCursorAfter       string `db:"ini_cursor_after"`
	LogVouchersIds       string `db:"log_vouchers_ids"`
	EndCursorAfter       string `db:"end_cursor_after"`
	IniInputCursorAfter  string `db:"ini_input_cursor_after"`
	EndInputCursorAfter  string `db:"end_input_cursor_after"`
	IniReportCursorAfter string `db:"ini_report_cursor_after"`
	EndReportCursorAfter string `db:"end_report_cursor_after"`
}