warpy_sync

type AssetsCalculator struct {
	*task.Task

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

type BlockDownloader struct {
	*task.Task

	Output        chan *BlockInfoPayload
	OutputPollTxs chan uint64
	// contains filtered or unexported fields
}

type BlockInfoPayload struct {
	Transactions []*types.Transaction
	Height       uint64
	Hash         string
	Timestamp    uint64
}

type Controller struct {
	*task.Task
}

type Input struct {
	Function              string   `json:"function"`
	Points                int64    `json:"points"`
	AdminId               string   `json:"adminId"`
	Members               []Member `json:"members"`
	NoBoost               bool     `json:"noBoost"`
	Cap                   int64    `json:"cap"`
	InitialCapInteraction bool     `json:"initialCapInteraction"`
}

type InteractionPayload struct {
	FromAddress string
	Points      int64
}

type LastSyncedBlockPayload struct {
	Height    uint64
	Hash      string
	Timestamp uint64
}

type Member struct {
	Id     string   `json:"id"`
	Roles  []string `json:"roles"`
	TxId   string   `json:"txId"`
	Points int64    `json:"points"`
}

type MethodType int

type PollerDeposit struct {
	*task.Task

	Output chan *[]InteractionPayload
	// contains filtered or unexported fields
}

type Prices struct {
	Bnb  float64
	Btc  float64
	Sei  float64
	Aero float64
}

type SommelierTransactionPayload struct {
	Transaction *types.Transaction
	FromAddress string
	Block       *BlockInfoPayload
	Method      *abi.Method
	ParsedInput []byte
	Input       map[string]interface{}
	Assets      float64
}

type Store struct {
	*task.Processor[*LastSyncedBlockPayload, *LastSyncedBlockPayload]
	// contains filtered or unexported fields
}

type StoreDeposit struct {
	*task.Task
	// contains filtered or unexported fields
}

type SyncerDelta struct {
	*task.Task

	Output                   chan *LastSyncedBlockPayload
	OutputInteractionPayload chan *[]InteractionPayload
	// contains filtered or unexported fields
}

type SyncerDeposit struct {
	*task.Task

	Output                   chan *LastSyncedBlockPayload
	OutputTransactionPayload chan *SommelierTransactionPayload
	// contains filtered or unexported fields
}

type Writer struct {
	*task.Task
	// contains filtered or unexported fields
}