// 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 integration_tests import ( "github.com/ethereum/go-ethereum/common" . "github.com/onsi/ginkgo" . "github.com/onsi/gomega" "github.com/vulcanize/vulcanizedb/pkg/core" "github.com/vulcanize/vulcanizedb/pkg/datastore/postgres" "github.com/vulcanize/vulcanizedb/pkg/transformers/shared/constants" "github.com/vulcanize/vulcanizedb/pkg/transformers/test_data" "github.com/vulcanize/vulcanizedb/test_config" "github.com/vulcanize/vulcanizedb/pkg/transformers/factories" "github.com/vulcanize/vulcanizedb/pkg/transformers/shared" "github.com/vulcanize/vulcanizedb/pkg/transformers/vat_fold" ) var _ = Describe("VatFold Transformer", func() { var ( db *postgres.DB blockChain core.BlockChain ) BeforeEach(func() { rpcClient, ethClient, err := getClients(ipc) Expect(err).NotTo(HaveOccurred()) blockChain, err = getBlockChain(rpcClient, ethClient) Expect(err).NotTo(HaveOccurred()) db = test_config.NewTestDB(blockChain.Node()) test_config.CleanTestDB(db) }) It("transforms VatFold log events", func() { blockNumber := int64(9367233) config := shared.TransformerConfig{ TransformerName: constants.VatFoldLabel, ContractAddresses: []string{test_data.KovanVatContractAddress}, ContractAbi: test_data.KovanVatABI, Topic: test_data.KovanVatFoldSignature, StartingBlockNumber: blockNumber, EndingBlockNumber: blockNumber, } header, err := persistHeader(db, blockNumber, blockChain) Expect(err).NotTo(HaveOccurred()) fetcher := shared.NewFetcher(blockChain) logs, err := fetcher.FetchLogs( shared.HexStringsToAddresses(config.ContractAddresses), []common.Hash{common.HexToHash(config.Topic)}, header) Expect(err).NotTo(HaveOccurred()) transformer := factories.LogNoteTransformer{ Config: config, Converter: &vat_fold.VatFoldConverter{}, Repository: &vat_fold.VatFoldRepository{}, }.NewLogNoteTransformer(db) err = transformer.Execute(logs, header) Expect(err).NotTo(HaveOccurred()) var dbResults []vat_fold.VatFoldModel err = db.Select(&dbResults, `SELECT ilk, urn, rate from maker.vat_fold`) Expect(err).NotTo(HaveOccurred()) Expect(len(dbResults)).To(Equal(1)) dbResult := dbResults[0] Expect(dbResult.Ilk).To(Equal("5245500000000000000000000000000000000000000000000000000000000000")) Expect(dbResult.Urn).To(Equal(common.HexToAddress("0x0000000000000000000000003728e9777b2a0a611ee0f89e00e01044ce4736d1").String())) Expect(dbResult.Rate).To(Equal("0.000000000000000000000000000")) }) })