blockchain

type BlockchainPublisher ¶

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

Can publish to the blockchain, signing messages using the provided signer

func NewBlockchainPublisher(
	logger *zap.Logger,
	client *ethclient.Client,
	signer TransactionSigner,
	contractOptions config.ContractsOptions,
) (*BlockchainPublisher, error)

func (m *BlockchainPublisher) PublishGroupMessage(
	ctx context.Context,
	groupID [32]byte,
	message []byte,
) error

func (m *BlockchainPublisher) PublishIdentityUpdate(
	ctx context.Context,
	inboxId [32]byte,
	identityUpdate []byte,
) error

type ChainClient ¶

type ChainClient interface {
	ethereum.BlockNumberReader
	ethereum.LogFilterer
	ethereum.ChainIDReader
}

type IBlockchainPublisher ¶

type IBlockchainPublisher interface {
	PublishIdentityUpdate(ctx context.Context, inboxId [32]byte, identityUpdate []byte) error
	PublishGroupMessage(ctx context.Context, groupdId [32]byte, message []byte) error
}

type LogStreamBuilder ¶

type LogStreamBuilder interface {
	ListenForContractEvent(
		fromBlock uint64,
		contractAddress common.Address,
		topic common.Hash,
	) <-chan types.Log
	Build() (LogStreamer, error)
}

Construct a raw blockchain listener that can be used to listen for events across many contract event types

type LogStreamer ¶

type LogStreamer interface {
	Start(ctx context.Context) error
}

type NodeRegistry ¶

type NodeRegistry interface {
	AddNode(
		ctx context.Context,
		owner string,
		signingKeyPub *ecdsa.PublicKey,
		httpAddress string,
	) error
}

type NodeRegistryAdmin ¶

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

* A NodeRegistryAdmin is a struct responsible for calling admin functions on the node registry *

func NewNodeRegistryAdmin(
	logger *zap.Logger,
	client *ethclient.Client,
	signer TransactionSigner,
	contractsOptions config.ContractsOptions,
) (*NodeRegistryAdmin, error)

func (n *NodeRegistryAdmin) AddNode(
	ctx context.Context,
	owner string,
	signingKeyPub *ecdsa.PublicKey,
	httpAddress string,
) error

func (n *NodeRegistryAdmin) UpdateHealth(
	ctx context.Context, nodeId int64, health bool,
) error

func (n *NodeRegistryAdmin) UpdateHttpAddress(
	ctx context.Context, nodeId int64, address string,
) error

type NodeRegistryCaller ¶

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

* A NodeRegistryCaller is a struct responsible for calling public functions on the node registry *

func NewNodeRegistryCaller(
	logger *zap.Logger,
	client *ethclient.Client,
	contractsOptions config.ContractsOptions,
) (*NodeRegistryCaller, error)

func (n *NodeRegistryCaller) GetAllNodes(
	ctx context.Context,
) ([]abis.NodesNodeWithId, error)

type PrivateKeySigner ¶

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

* PrivateKeySigner is a naive and not secure implementation of the TransactionSigner interface.

It is meant to be used in tests only *

func NewPrivateKeySigner(privateKeyString string, chainID int) (*PrivateKeySigner, error)

func (s *PrivateKeySigner) FromAddress() common.Address

func (s *PrivateKeySigner) SignerFunc() bind.SignerFn

type RpcLogStreamBuilder ¶

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

The builder that allows you to configure contract events to listen for

func NewRpcLogStreamBuilder(client *ethclient.Client, logger *zap.Logger) *RpcLogStreamBuilder

func (c *RpcLogStreamBuilder) Build() (*RpcLogStreamer, error)

func (c *RpcLogStreamBuilder) ListenForContractEvent(
	fromBlock int,
	contractAddress common.Address,
	topics []common.Hash,
) <-chan types.Log

type RpcLogStreamer ¶

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

* A RpcLogStreamer is a naive implementation of the ChainStreamer interface. It queries a remote blockchain node for log events to backfill history, and then streams new events, to get a complete history of events on a chain. *

func NewRpcLogStreamer(
	client ChainClient,
	logger *zap.Logger,
	watchers []contractConfig,
) *RpcLogStreamer

func (r *RpcLogStreamer) Start(ctx context.Context) error

type TransactionSigner ¶

type TransactionSigner interface {
	FromAddress() common.Address
	SignerFunc() bind.SignerFn
}