eventDaemon

Documentation

Index

• Variables
• func ConfirmMultisigTx(session *multisig.MultiSigWalletSession, txid *big.Int) (tx *types.Transaction, err error)
• func GetAddressDao(session *union.UnionSession, Chat_id int64) (common.Address, error)
• func GetChatID(session *union.UnionSession, counter *big.Int) (int64, error)
• func GetUnionsCounter(session *union.UnionSession) (*big.Int, error)
• func InitiateMultisigSession(ctx context.Context, dao_wallet_address common.Address, ...)
• func IsTokenTransfer(session *multisig.MultiSigWalletSession, data []byte) (bool, error)
• func ListenToDepositMultisig(ctx context.Context, dao_wallet_address common.Address, ...)
• func Start(masterChannelSub chan *SubmissionMsg, masterChannelDep chan *DepositMsg)
• func SubscribeForApprovedUnions(session *union.UnionSession, listenChannel chan<- *union.UnionApprovedJoin) (event.Subscription, error)
• func SubscribeForSubmittedTransactions(session *multisig.MultiSigWalletSession, ...) (event.Subscription, error)
• func SubscribeToDepositCoins(session *multisig.MultiSigWalletSession, ...) (event.Subscription, error)
• type DepositMsg
• type NewOwnerMsg
• type RemoveOwnerMsg
• type SubmissionMsg

Variables

var GlobalAuth *bind.TransactOpts

var GlobalClient *ethclient.Client

Functions

func ConfirmMultisigTx

func ConfirmMultisigTx(session *multisig.MultiSigWalletSession, txid *big.Int) (tx *types.Transaction, err error)

func GetAddressDao

func GetAddressDao(session *union.UnionSession, Chat_id int64) (common.Address, error)

func GetChatID

func GetChatID(session *union.UnionSession, counter *big.Int) (int64, error)

func GetUnionsCounter

func GetUnionsCounter(session *union.UnionSession) (*big.Int, error)

func InitiateMultisigSession

func InitiateMultisigSession(ctx context.Context, dao_wallet_address common.Address, listenchan chan *SubmissionMsg, Chat_id int64)

Initiate event listener session (go routine) for SUBMIT Events

func IsTokenTransfer

func IsTokenTransfer(session *multisig.MultiSigWalletSession, data []byte) (bool, error)

func ListenToDepositMultisig

func ListenToDepositMultisig(ctx context.Context, dao_wallet_address common.Address, listenchan chan *DepositMsg, Chat_id int64)

Initiate event listener session (go routine) for DEPOSIT Events

func Start

func Start(masterChannelSub chan *SubmissionMsg, masterChannelDep chan *DepositMsg)

func SubscribeForApprovedUnions

func SubscribeForApprovedUnions(session *union.UnionSession, listenChannel chan<- *union.UnionApprovedJoin) (event.Subscription, error)

subscribing for ApprovedJoin events. This event represent that a new dao has been registred. We use watchers without fast-forwarding past events

func SubscribeForSubmittedTransactions

func SubscribeForSubmittedTransactions(session *multisig.MultiSigWalletSession, listenChannel chan<- *multisig.MultiSigWalletSubmission) (event.Subscription, error)

TODO: add Anonymouse event for each time of event in multisig (without indexed values)

func SubscribeToDepositCoins

func SubscribeToDepositCoins(session *multisig.MultiSigWalletSession, listenChannel chan<- *multisig.MultiSigWalletDeposit) (event.Subscription, error)

Types

type DepositMsg

type DepositMsg struct {
	Chat_id      int64
	DepositEvent *multisig.MultiSigWalletDeposit
}

Coin deposit

type NewOwnerMsg

type NewOwnerMsg struct {
	Chat_id       int64
	NewOwnerEvent *multisig.MultiSigWalletOwnerAddition
}

type RemoveOwnerMsg

type RemoveOwnerMsg struct {
	Chat_id          int64
	RemoveOwnerEvent *multisig.MultiSigWalletOwnerRemoval
}

type SubmissionMsg

type SubmissionMsg struct {
	Chat_id         int64
	SubmissionEvent *multisig.MultiSigWalletSubmission
}

any submitted tx