Commit 6ebef55e authored by vicotor's avatar vicotor

fix bug

parent e865d202
...@@ -212,6 +212,9 @@ func (s *ChainSync) SyncLogs(beginHeight, endHeight int64) error { ...@@ -212,6 +212,9 @@ func (s *ChainSync) SyncLogs(beginHeight, endHeight int64) error {
dao.TokenConfigChangedEvent.ID.Hex(), dao.TokenConfigChangedEvent.ID.Hex(),
dao.SwapConfigChangedEvent.ID.Hex(), dao.SwapConfigChangedEvent.ID.Hex(),
} }
//for _, t := range topics {
// log.Println("monitor topic:", t)
//}
logs, err := s.d.GetLogs(s.chain, beginHeight, endHeight, topics, []string{ logs, err := s.d.GetLogs(s.chain, beginHeight, endHeight, topics, []string{
s.chain.BridgeContract, s.chain.BridgeContract,
......
This diff is collapsed.
...@@ -260,19 +260,19 @@ ...@@ -260,19 +260,19 @@
"anonymous": false, "anonymous": false,
"inputs": [ "inputs": [
{ {
"indexed": true, "indexed": false,
"internalType": "uint256", "internalType": "uint256",
"name": "outId", "name": "outId",
"type": "uint256" "type": "uint256"
}, },
{ {
"indexed": true, "indexed": false,
"internalType": "uint256", "internalType": "uint256",
"name": "fromChainID", "name": "fromChainID",
"type": "uint256" "type": "uint256"
}, },
{ {
"indexed": true, "indexed": false,
"internalType": "address", "internalType": "address",
"name": "sender", "name": "sender",
"type": "address" "type": "address"
......
...@@ -60,6 +60,7 @@ func (s *Dao) HandleEvents(chain ChainInterface, logs []types.Log) error { ...@@ -60,6 +60,7 @@ func (s *Dao) HandleEvents(chain ChainInterface, logs []types.Log) error {
allTokenConfigChanged = append(allTokenConfigChanged, lg) allTokenConfigChanged = append(allTokenConfigChanged, lg)
case SwapConfigChangedEvent.ID.Hex(): case SwapConfigChangedEvent.ID.Hex():
allSwapConfigChanged = append(allSwapConfigChanged, lg) allSwapConfigChanged = append(allSwapConfigChanged, lg)
log.WithField("tx", lg.TxHash).Info("got swap config changed event")
case TransferInExecutionEvent.ID.Hex(): case TransferInExecutionEvent.ID.Hex():
allExecuted = append(allExecuted, lg) allExecuted = append(allExecuted, lg)
case TransferInRejectionEvent.ID.Hex(): case TransferInRejectionEvent.ID.Hex():
...@@ -413,6 +414,7 @@ func (s *Dao) filterSwapConfigChanged(chain ChainInterface, txLog *types.Log, ct ...@@ -413,6 +414,7 @@ func (s *Dao) filterSwapConfigChanged(chain ChainInterface, txLog *types.Log, ct
if txLog.Topics[0].Hex() == SwapConfigChangedEvent.ID.Hex() { if txLog.Topics[0].Hex() == SwapConfigChangedEvent.ID.Hex() {
configure, err := chain.ParseSwapConfigChanged(txLog) configure, err := chain.ParseSwapConfigChanged(txLog)
if err != nil { if err != nil {
log.WithError(err).Error("parse SwapConfigChanged log")
return err return err
} }
info := &dbModel.SwapTokenInfo{ info := &dbModel.SwapTokenInfo{
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment