lint

chainregistry/requests.go

@@ -86,7 +86,6 @@ func GetAssetMapOnDisk(chainRegistryLocation string, chainRegBlacklist map[strin
 
 				currAssets := &AssetList{}
 				err = json.NewDecoder(jsonFile).Decode(currAssets)
-
 				if err != nil {
 					return nil, err
 				}

client/client.go

@@ -102,7 +102,6 @@ func setup() (*gorm.DB, *config.ClientConfig, int, string, error) {
 	dbTypes.CacheIBCDenoms(db)
 
 	err = db.AutoMigrate(&dbTypes.Address{}, &AddressUsageCSV{}, &AddressUsageJSON{})
-
 	if err != nil {
 		config.Log.Fatalf("Error migrating client models. Err: %v", err)
 	}

cmd/block_enqueue.go

@@ -75,7 +75,6 @@ func (idxr *Indexer) enqueueBlocksToProcessFromBlockInputFile(blockChan chan int
 	}
 	var blocksToIndex []uint64
 	err = json.Unmarshal(plan, &blocksToIndex)
-
 	if err != nil {
 		errString := err.Error()
 

cmd/index.go

@@ -732,7 +732,6 @@ func (idxr *Indexer) doDBUpdates(wg *sync.WaitGroup, txDataChan chan *dbData, bl
 			}
 
 			err = dbTypes.UpdateEpochIndexingStatus(idxr.db, idxr.dryRun, epochEventData.epochNumber, epochEventData.epochIdentifier, idxr.cfg.Lens.ChainID, idxr.cfg.Lens.ChainName)
-
 			if err != nil {
 				config.Log.Fatal(fmt.Sprintf("Error indexing block events for %s. Could not mark Epoch indexed.", identifierLoggingString), err)
 			}

config/index_config.go

@@ -83,15 +83,13 @@ func (conf *IndexConfig) Validate() error {
 	lensConf := conf.Lens
 
 	lensConf, err = validateLensConf(lensConf)
-
 	if err != nil {
 		return err
 	}
 
 	conf.Lens = lensConf
 
 	err = validateThrottlingConf(conf.Base.throttlingBase)
-
 	if err != nil {
 		return err
 	}

config/update_denoms_config.go

@@ -29,7 +29,6 @@ func (conf *UpdateDenomsConfig) Validate() error {
 	lensConf := conf.Lens
 
 	lensConf, err = validateLensConf(lensConf)
-
 	if err != nil {
 		return err
 	}

config/update_epochs_config.go

@@ -31,15 +31,13 @@ func (conf *UpdateEpochsConfig) Validate() error {
 	lensConf := conf.Lens
 
 	lensConf, err = validateLensConf(lensConf)
-
 	if err != nil {
 		return err
 	}
 
 	conf.Lens = lensConf
 
 	err = validateThrottlingConf(conf.Base.throttlingBase)
-
 	if err != nil {
 		return err
 	}

core/tx.go

@@ -283,7 +283,6 @@ func ProcessRPCBlockByHeightTXs(db *gorm.DB, cl *client.ChainClient, blockResult
 		// We can entirely ignore failed TXs in downstream parsers, because according to the Cosmos specification, a single failed message in a TX fails the whole TX
 		if txResult.Code == 0 {
 			logs, err = types.ParseABCILogs(txResult.Log)
-
 			if err != nil {
 				logs, err = indexerEvents.ParseTxEventsToMessageIndexEvents(len(txFull.Body.Messages), txResult.Events)
 			}

csv/parsers/accointing/accointing.go

@@ -158,28 +158,28 @@ func HandleFees(address string, events []db.TaxableTransaction, allFees []db.Fee
 	// We need to gather all unique fees, but we are receiving Messages not Txes
 	// Make a map from TX hash to fees array to keep unique
 	txToFeesMap := make(map[uint][]db.Fee)
-	txIdsToTx := make(map[uint]db.Tx)
+	txIDsToTX := make(map[uint]db.Tx)
 	for _, event := range events {
 		txID := event.Message.Tx.ID
 		feeStore := event.Message.Tx.Fees
 		txToFeesMap[txID] = feeStore
-		txIdsToTx[txID] = event.Message.Tx
+		txIDsToTX[txID] = event.Message.Tx
 	}
 
 	// Due to the way we are parsing, we may have fees for TX that we don't have events for
 	for _, fee := range allFees {
 		txID := fee.Tx.ID
 		if _, ok := txToFeesMap[txID]; !ok {
 			txToFeesMap[txID] = []db.Fee{fee}
-			txIdsToTx[txID] = fee.Tx
+			txIDsToTX[txID] = fee.Tx
 		}
 	}
 
 	for id, txFees := range txToFeesMap {
 		for _, fee := range txFees {
 			if fee.PayerAddress.Address == address {
 				newRow := Row{}
-				err = newRow.ParseFee(txIdsToTx[id], fee)
+				err = newRow.ParseFee(txIDsToTX[id], fee)
 				if err != nil {
 					return nil, err
 				}

csv/parsers/koinly/koinly.go

@@ -29,7 +29,7 @@ var unsupportedCoins = []string{
 
 var coinReplacementMap = map[string]string{}
 
-var symbolsToKoinlyIds = map[string]string{}
+var symbolsToKoinlyIDs = map[string]string{}
 
 // Probably not the best place for this, but its only used in Koinly for now
 // May want to consider adding the asset list URL as a config value and passing the AssetList value down to parsers if needed
@@ -42,7 +42,7 @@ func init() {
 
 	for _, asset := range assetList.Assets {
 		// Required format for koinly IDs is ID:<val>
-		symbolsToKoinlyIds[asset.Symbol] = fmt.Sprintf("ID:%s", asset.KoinlyID)
+		symbolsToKoinlyIDs[asset.Symbol] = fmt.Sprintf("ID:%s", asset.KoinlyID)
 	}
 }
 
@@ -124,18 +124,18 @@ func (p *Parser) GetRows(address string, startDate, endDate *time.Time) ([]parse
 	for i, row := range koinlyRows {
 
 		if row.FeeCurrency != "" {
-			if _, ok := symbolsToKoinlyIds[row.FeeCurrency]; ok {
-				koinlyRows[i].FeeCurrency = symbolsToKoinlyIds[row.FeeCurrency]
+			if _, ok := symbolsToKoinlyIDs[row.FeeCurrency]; ok {
+				koinlyRows[i].FeeCurrency = symbolsToKoinlyIDs[row.FeeCurrency]
 			}
 		}
 		if row.ReceivedCurrency != "" {
-			if _, ok := symbolsToKoinlyIds[row.ReceivedCurrency]; ok {
-				koinlyRows[i].ReceivedCurrency = symbolsToKoinlyIds[row.ReceivedCurrency]
+			if _, ok := symbolsToKoinlyIDs[row.ReceivedCurrency]; ok {
+				koinlyRows[i].ReceivedCurrency = symbolsToKoinlyIDs[row.ReceivedCurrency]
 			}
 		}
 		if row.SentCurrency != "" {
-			if _, ok := symbolsToKoinlyIds[row.SentCurrency]; ok {
-				koinlyRows[i].SentCurrency = symbolsToKoinlyIds[row.SentCurrency]
+			if _, ok := symbolsToKoinlyIDs[row.SentCurrency]; ok {
+				koinlyRows[i].SentCurrency = symbolsToKoinlyIDs[row.SentCurrency]
 			}
 		}
 	}
@@ -226,28 +226,28 @@ func HandleFees(address string, events []db.TaxableTransaction, allFees []db.Fee
 	// We need to gather all unique fees, but we are receiving Messages not Txes
 	// Make a map from TX hash to fees array to keep unique
 	txToFeesMap := make(map[uint][]db.Fee)
-	txIdsToTx := make(map[uint]db.Tx)
+	txIDsToTX := make(map[uint]db.Tx)
 	for _, event := range events {
 		txID := event.Message.Tx.ID
 		feeStore := event.Message.Tx.Fees
 		txToFeesMap[txID] = feeStore
-		txIdsToTx[txID] = event.Message.Tx
+		txIDsToTX[txID] = event.Message.Tx
 	}
 
 	// Due to the way we are parsing, we may have fees for TX that we don't have events for
 	for _, fee := range allFees {
 		txID := fee.Tx.ID
 		if _, ok := txToFeesMap[txID]; !ok {
 			txToFeesMap[txID] = []db.Fee{fee}
-			txIdsToTx[txID] = fee.Tx
+			txIDsToTX[txID] = fee.Tx
 		}
 	}
 
 	for id, txFees := range txToFeesMap {
 		for _, fee := range txFees {
 			if fee.PayerAddress.Address == address {
 				newRow := Row{}
-				err = newRow.ParseFee(txIdsToTx[id], fee)
+				err = newRow.ParseFee(txIDsToTX[id], fee)
 				if err != nil {
 					return nil, err
 				}

csv/parsers/taxbit/taxbit.go

@@ -155,28 +155,28 @@ func HandleFees(address string, events []db.TaxableTransaction, allFees []db.Fee
 	// We need to gather all unique fees, but we are receiving Messages not Txes
 	// Make a map from TX hash to fees array to keep unique
 	txToFeesMap := make(map[uint][]db.Fee)
-	txIdsToTx := make(map[uint]db.Tx)
+	txIDsToTX := make(map[uint]db.Tx)
 	for _, event := range events {
 		txID := event.Message.Tx.ID
 		feeStore := event.Message.Tx.Fees
 		txToFeesMap[txID] = feeStore
-		txIdsToTx[txID] = event.Message.Tx
+		txIDsToTX[txID] = event.Message.Tx
 	}
 
 	// Due to the way we are parsing, we may have fees for TX that we don't have events for
 	for _, fee := range allFees {
 		txID := fee.Tx.ID
 		if _, ok := txToFeesMap[txID]; !ok {
 			txToFeesMap[txID] = []db.Fee{fee}
-			txIdsToTx[txID] = fee.Tx
+			txIDsToTX[txID] = fee.Tx
 		}
 	}
 
 	for id, txFees := range txToFeesMap {
 		for _, fee := range txFees {
 			if fee.PayerAddress.Address == address {
 				newRow := Row{}
-				err = newRow.ParseFee(txIdsToTx[id], fee)
+				err = newRow.ParseFee(txIDsToTX[id], fee)
 				if err != nil {
 					return nil, err
 				}

osmosis/modules/gamm/exits.go

@@ -195,7 +195,6 @@ func (sf *WrapperMsgExitSwapShareAmountIn) HandleMsg(msgType string, msg sdk.Msg
 		return &txModule.MessageLogFormatError{MessageType: msgType, Log: fmt.Sprintf("%+v", log)}
 	}
 	sf.TokenOut, err = sdk.ParseCoinNormalized(tokenOut)
-
 	if err != nil {
 		return &txModule.MessageLogFormatError{MessageType: msgType, Log: fmt.Sprintf("%+v", log)}
 	}
@@ -357,7 +356,6 @@ func (sf *WrapperMsgExitSwapExternAmountOut) HandleMsg(msgType string, msg sdk.M
 		return &txModule.MessageLogFormatError{MessageType: msgType, Log: fmt.Sprintf("%+v", log)}
 	}
 	sf.TokenOut, err = sdk.ParseCoinNormalized(tokenOut)
-
 	if err != nil {
 		return &txModule.MessageLogFormatError{MessageType: msgType, Log: fmt.Sprintf("%+v", log)}
 	}

rest/requests.go

@@ -65,7 +65,6 @@ func GetTxsByBlockHeight(host string, height uint64) (tx.GetTxByBlockHeightRespo
 	defer resp.Body.Close()
 
 	err = checkResponseErrorCode(requestEndpoint, resp)
-
 	if err != nil {
 		return result, err
 	}
@@ -76,7 +75,6 @@ func GetTxsByBlockHeight(host string, height uint64) (tx.GetTxByBlockHeightRespo
 	}
 
 	err = json.Unmarshal(body, &result)
-
 	if err != nil {
 		return result, err
 	}
@@ -97,7 +95,6 @@ func GetLatestBlock(host string) (tx.GetLatestBlockResponse, error) {
 	defer resp.Body.Close()
 
 	err = checkResponseErrorCode(requestEndpoint, resp)
-
 	if err != nil {
 		return result, err
 	}
@@ -108,7 +105,6 @@ func GetLatestBlock(host string) (tx.GetLatestBlockResponse, error) {
 	}
 
 	err = json.Unmarshal(body, &result)
-
 	if err != nil {
 		return result, err
 	}

rpc/requests.go

@@ -56,7 +56,6 @@ func GetTxsByBlockHeight(cl *lensClient.ChainClient, height int64) (resp *txType
 	options := lensQuery.QueryOptions{Height: height, Pagination: &pg}
 	query := lensQuery.Query{Client: cl, Options: &options}
 	resp, unpackError, err := query.TxByHeight(cl.Codec)
-
 	if err != nil {
 		return nil, unpackError, err
 	}