Function NewExchange

cmd/cql-eth-exchange/exchange.go:89–130

NewExchange creates new exchange process object.

(cfg *ExchangeConfig)

// NewExchange creates new exchange process object.
func NewExchange(cfg *ExchangeConfig) (e *Exchange, err error) {
	e = &Exchange{
		cfg:              cfg,
		receivedBlockMap: make(map[uint64]bool),
		receiveAddrMap:   make(map[string]bool),
	}

	// init keys
	e.vaultPrivateKey, err = kms.GetLocalPrivateKey()
	if err != nil {
		return
	}
	e.vaultAddress, err = crypto.PubKeyHash(e.vaultPrivateKey.PubKey())
	if err != nil {
		return
	}

	// init meta database
	var db *sql.DB
	if cfg.UseLocalDatabase {
		db, err = sql.Open("sqlite3", cfg.Database)
	} else {
		dsnCfg := client.Config{}
		dsnCfg.DatabaseID = cfg.Database
		db, err = sql.Open("covenantsql", dsnCfg.FormatDSN())
	}

	e.metaDatabase = &gorp.DbMap{Db: db, Dialect: gorp.SqliteDialect{}}
	e.metaDatabase.AddTableWithName(TxRecord{}, "record").
		SetKeys(false, "Hash")
	e.metaDatabase.AddTableWithName(AuditRecord{}, "audit").
		SetKeys(true, "ID")
	if err = e.metaDatabase.CreateTablesIfNotExists(); err != nil {
		return
	}

	for _, addr := range cfg.ReceiveAddresses {
		e.receiveAddrMap[addr.String()] = true
	}

	return
}

// Start connects to server and listen to new blocks for token exchanges.
func (e *Exchange) Start(ctx context.Context) (err error) {