everpay_sync

package

v1.0.1 Latest Latest Go to latest Published: Jul 4, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrNotNeedSync = errors.New("not need sync")
)

This section is empty.

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

function: sync everpay rollup txs to arseeding

func New(dsn string, seedUrl string) *EverPaySync

func (e *EverPaySync) FetchArIds()

func (e *EverPaySync) PostToArseeding()

func (e *EverPaySync) Run()

type RollupArId struct {
	gorm.Model
	ArId string `gorm:"index:idx01"`
	Post bool
}

type Wdb struct {
	Db *gorm.DB
}

func NewWdb(dsn string) *Wdb

func (w *Wdb) GetArIds(fromId int) ([]RollupArId, error)

func (w *Wdb) GetLastPostTx() (RollupArId, error)

func (w *Wdb) GetNeedPostTxs() ([]RollupArId, error)

func (w *Wdb) Insert(arId string) error

func (w *Wdb) UpdatePosted(arId string) error