forked from cerc-io/ipld-eth-server
65cb6e9092
* Updated loading config from /Users/konstantinzolotarev/.vulcanizedb for addreses * Updated contract addresses loading from env variables. * Implement getter chain for addresses, configs and transformers Solves the issue with declaring stuff as vars when the environment file hasn't been loaded yet. Instead, this data is fetched dynamically when the root commands are called. * Update test data to use constant Kovan addresses * Decouple integration tests from config file IO * Add ABI to environment file, convert getter chains for related values * Decouple tests suites from ABI config file IO * Add startingBlock to environment and implement getter chain * Exit when called without config file * Add missing deployment blocks to staging.toml * Remove comment
127 lines
5.8 KiB
Go
127 lines
5.8 KiB
Go
// Copyright © 2018 Vulcanize
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package cmd
|
|
|
|
import (
|
|
"fmt"
|
|
"time"
|
|
|
|
log "github.com/sirupsen/logrus"
|
|
"github.com/spf13/cobra"
|
|
|
|
"github.com/vulcanize/vulcanizedb/libraries/shared"
|
|
"github.com/vulcanize/vulcanizedb/pkg/datastore/postgres"
|
|
"github.com/vulcanize/vulcanizedb/pkg/transformers"
|
|
shared2 "github.com/vulcanize/vulcanizedb/pkg/transformers/shared"
|
|
"github.com/vulcanize/vulcanizedb/pkg/transformers/shared/constants"
|
|
)
|
|
|
|
// continuousLogSyncCmd represents the continuousLogSync command
|
|
var continuousLogSyncCmd = &cobra.Command{
|
|
Use: "continuousLogSync",
|
|
Short: "Continuously sync logs at the head of the chain",
|
|
Long: fmt.Sprintf(`Continously syncs logs based on the configured transformers.
|
|
|
|
vulcanizedb continousLogSync --config environments/local.toml
|
|
|
|
Available transformers for (optional) selection with --transformers:
|
|
%v
|
|
|
|
This command expects a light sync to have been run, and the presence of header records in the Vulcanize database.`,
|
|
constants.AllTransformerLabels()),
|
|
Run: func(cmd *cobra.Command, args []string) {
|
|
syncMakerLogs()
|
|
},
|
|
}
|
|
|
|
var transformerNames []string
|
|
|
|
func syncMakerLogs() {
|
|
ticker := time.NewTicker(pollingInterval)
|
|
defer ticker.Stop()
|
|
|
|
blockChain := getBlockChain()
|
|
db, err := postgres.NewDB(databaseConfig, blockChain.Node())
|
|
if err != nil {
|
|
log.Fatal("Failed to initialize database.")
|
|
}
|
|
|
|
initializers := getTransformerInitializers(transformerNames)
|
|
|
|
watcher := shared.NewWatcher(db, blockChain)
|
|
watcher.AddTransformers(initializers)
|
|
|
|
for range ticker.C {
|
|
err = watcher.Execute()
|
|
if err != nil {
|
|
// TODO Handle watcher errors in ContinuousLogSync
|
|
}
|
|
}
|
|
}
|
|
|
|
func getTransformerInitializers(transformerNames []string) []shared2.TransformerInitializer {
|
|
var initializers []shared2.TransformerInitializer
|
|
|
|
if transformerNames[0] == "all" {
|
|
initializers = transformers.TransformerInitializers()
|
|
} else {
|
|
initializerMap := buildTransformerInitializerMap()
|
|
for _, transformerName := range transformerNames {
|
|
initializers = append(initializers, initializerMap[transformerName])
|
|
}
|
|
}
|
|
return initializers
|
|
}
|
|
|
|
func buildTransformerInitializerMap() map[string]shared2.TransformerInitializer {
|
|
initializerMap := make(map[string]shared2.TransformerInitializer)
|
|
|
|
initializerMap[constants.BiteLabel] = transformers.GetBiteTransformer().NewTransformer
|
|
initializerMap[constants.CatFileChopLumpLabel] = transformers.GetCatFileChopLumpTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.CatFileFlipLabel] = transformers.GetCatFileFlipTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.CatFilePitVowLabel] = transformers.GetCatFilePitVowTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.DealLabel] = transformers.GetDealTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.DentLabel] = transformers.GetDentTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.DripDripLabel] = transformers.GetDripDripTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.DripFileIlkLabel] = transformers.GetDripFileIlkTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.DripFileRepoLabel] = transformers.GetDripFileRepoTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.DripFileVowLabel] = transformers.GetDripFileVowTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.FlapKickLabel] = transformers.GetFlapKickTransformer().NewTransformer
|
|
initializerMap[constants.FlipKickLabel] = transformers.GetFlipKickTransformer().NewTransformer
|
|
initializerMap[constants.FlopKickLabel] = transformers.GetFlopKickTransformer().NewTransformer
|
|
initializerMap[constants.FrobLabel] = transformers.GetFrobTransformer().NewTransformer
|
|
initializerMap[constants.PitFileDebtCeilingLabel] = transformers.GetPitFileDebtCeilingTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.PitFileIlkLabel] = transformers.GetPitFileIlkTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.PriceFeedLabel] = transformers.GetPriceFeedTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.TendLabel] = transformers.GetTendTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.VatFluxLabel] = transformers.GetVatFluxTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.VatFoldLabel] = transformers.GetVatFoldTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.VatGrabLabel] = transformers.GetVatGrabTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.VatHealLabel] = transformers.GetVatHealTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.VatInitLabel] = transformers.GetVatInitTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.VatMoveLabel] = transformers.GetVatMoveTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.VatSlipLabel] = transformers.GetVatSlipTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.VatTollLabel] = transformers.GetVatTollTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.VatTuneLabel] = transformers.GetVatTuneTransformer().NewLogNoteTransformer
|
|
initializerMap[constants.VowFlogLabel] = transformers.GetFlogTransformer().NewLogNoteTransformer
|
|
|
|
return initializerMap
|
|
}
|
|
|
|
func init() {
|
|
rootCmd.AddCommand(continuousLogSyncCmd)
|
|
continuousLogSyncCmd.Flags().StringSliceVar(&transformerNames, "transformers", []string{"all"}, "transformer names to be run during this command")
|
|
}
|