fix: wrong extra format (#5)

monitor/bsc_block_processor.go

@@ -187,6 +187,13 @@ func (p *BscBlockProcessor) handleEventList(blockHeight uint64, l types.Log) (st
 		return "", nil
 	}
 
+	// item should be existed
+	_, err = p.itemDao.GetByGroupId(context.Background(), event.GroupId.Int64(), true)
+	if err != nil {
+		util.Logger.Errorf("processor: %s, fail to find item %d err: %s", p.Name(), event.GroupId.Int64(), err)
+		return "", err
+	}
+
 	rawSql := fmt.Sprintf("update items set status = %d, price = %s, updated_bsc_height = %d where group_id = %d ",
 		database.ItemListed, event.Price, blockHeight, event.GroupId)
 
@@ -203,6 +210,13 @@ func (p *BscBlockProcessor) handleEventDelist(blockHeight uint64, l types.Log) (
 		return "", nil
 	}
 
+	// item should be existed
+	_, err = p.itemDao.GetByGroupId(context.Background(), event.GroupId.Int64(), true)
+	if err != nil {
+		util.Logger.Errorf("processor: %s, fail to find item %d err: %s", p.Name(), event.GroupId.Int64(), err)
+		return "", err
+	}
+
 	rawSql := fmt.Sprintf("update items set status = %d, updated_bsc_height = %d where group_id = %d ",
 		database.ItemDelisted, blockHeight, event.GroupId)
 

monitor/gnfd_event.go

@@ -11,11 +11,17 @@ type Extra struct {
 	Price decimal.Decimal `json:"price"`
 }
 
+// If there is wrong format extra, we just ignore the error and use default values.
+// https://gnfd-testnet-fullnode-tendermint-us.bnbchain.org/block_results?height=1658808
 func parseExtra(str string) (*Extra, error) {
 	var extra Extra
 	err := json.Unmarshal([]byte(str), &extra)
 	if err != nil {
-		return nil, err
+		return &Extra{
+			Desc:  "",
+			Url:   "",
+			Price: decimal.Zero,
+		}, nil
 	}
 
 	return &extra, nil