farcaster

Documentation

Index

• func NewSource(config *config.Module, checkpoint *engine.Checkpoint, ...) (engine.DataSource, error)
• type Option
  • func NewOption(n network.Network, parameters *config.Parameters) (*Option, error)
• type State
• type Task
  • func (t Task) BuildActivity(options ...activityx.Option) (*activityx.Activity, error)
  • func (t Task) GetNetwork() network.Network
  • func (t Task) GetTimestamp() uint64
  • func (t Task) ID() string
  • func (t Task) Validate() error

Functions

func NewSource

func NewSource(config *config.Module, checkpoint *engine.Checkpoint, databaseClient database.Client) (engine.DataSource, error)

Types

type Option

type Option struct {
	APIKey *string `json:"api_key" mapstructure:"api_key"`
	// TimestampStart is the Farcaster seconds timestamp that the worker should start from.
	TimestampStart *big.Int `json:"timestamp_start" mapstructure:"timestamp_start"`
}

func NewOption

func NewOption(n network.Network, parameters *config.Parameters) (*Option, error)

type State

type State struct {
	EventID           uint64 `json:"event_id"`           // Event ID that has been processed
	CastsFid          uint64 `json:"casts_fid"`          // Casts ID that has been processed in backfill casts
	CastsBackfill     bool   `json:"casts_backfill"`     // Casts backfill flag
	ReactionsFid      uint64 `json:"reactions_fid"`      // Reactions ID that has been processed in backfill reactions
	ReactionsBackfill bool   `json:"reactions_backfill"` // Reactions backfill flag
}

type Task

type Task struct {
	Network network.Network
	Message farcaster.Message
}

func (Task) BuildActivity

func (t Task) BuildActivity(options ...activityx.Option) (*activityx.Activity, error)

func (Task) GetNetwork

func (t Task) GetNetwork() network.Network

func (Task) GetTimestamp

func (t Task) GetTimestamp() uint64

func (Task) ID

func (t Task) ID() string

func (Task) Validate

func (t Task) Validate() error