// VulcanizeDB // Copyright © 2018 Vulcanize // This program is free software: you can redistribute it and/or modify // it under the terms of the GNU Affero General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // This program is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU Affero General Public License for more details. // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see . package flip import ( "bytes" "encoding/json" "errors" "github.com/ethereum/go-ethereum/common" "github.com/ethereum/go-ethereum/core/types" "github.com/vulcanize/vulcanizedb/pkg/transformers/shared" "github.com/vulcanize/vulcanizedb/pkg/transformers/shared/constants" ) type CatFileFlipConverter struct{} func (CatFileFlipConverter) ToModels(ethLogs []types.Log) ([]interface{}, error) { var results []interface{} for _, ethLog := range ethLogs { err := verifyLog(ethLog) if err != nil { return nil, err } ilk := shared.GetHexWithoutPrefix(ethLog.Topics[2].Bytes()) what := string(bytes.Trim(ethLog.Topics[3].Bytes(), "\x00")) flipBytes := ethLog.Data[len(ethLog.Data)-constants.DataItemLength:] flip := common.BytesToAddress(flipBytes).String() raw, err := json.Marshal(ethLog) if err != nil { return nil, err } result := CatFileFlipModel{ Ilk: ilk, What: what, Flip: flip, TransactionIndex: ethLog.TxIndex, LogIndex: ethLog.Index, Raw: raw, } results = append(results, result) } return results, nil } func verifyLog(log types.Log) error { if len(log.Topics) < 4 { return errors.New("log missing topics") } if len(log.Data) < constants.DataItemLength { return errors.New("log missing data") } return nil }