backend

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

type EthShell interface {
	PublishEvent(ctx context.Context, topic string, id uuid.UUID, cid string, newAccounts []string) (*types.Transaction, common.Address, error)
	GetTopics(ctx context.Context) ([]string, error)
	GetEvents(topic string, fromBlock uint64) ([]ethshell.EventLogEvent, error)
	SubscribeToEvents(ctx context.Context) (ethereum.Subscription, chan types.Log, error)
	UnpackLog(ctx context.Context, log types.Log) (ethshell.EventLogEvent, error)
}

type EventLog interface {
	Insert(event eventlog.Event) (eventlog.Event, error)
	ResetFromBlockAndInsert(topic string, lastBlockNumber uint64, events []eventlog.Event) error
	FindLastSynchronisedBlockNumber(topic string) (uint64, error)
	FindPendingEvents() ([]eventlog.Event, error)
	FindConfirmedEvents() ([]eventlog.Event, error)
	Confirm(id uuid.UUID, blockNumber uint64, timestamp uint64) (eventlog.Event, error)
	ClearPendingEvents(topic string) error
}

type IpfsShell interface {
	PublishBusinessEvent(businessEvent ipfsshell.BusinessEvent) (string, error)
	GetBusinessEvent(cid string) (ipfsshell.BusinessEvent, error)
}

type PublishRequest struct {
	Type        string
	Payload     string
	Version     float64
	Topic       string
	NewAccounts []string
}