compile and update migration package

c9s · Jan 24, 2024 · ee1a272 · ee1a272
1 parent c7027db
commit ee1a272
Show file tree

Hide file tree

Showing 77 changed files with 18 additions and 138 deletions.
diff --git a/pkg/migrations/mysql/main_20200721225616_trades.go b/pkg/migrations/mysql/main_20200721225616_trades.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_trades, down_main_trades)
-
 }
 
 func up_main_trades(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20200819054742_trade_index.go b/pkg/migrations/mysql/main_20200819054742_trade_index.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_tradeIndex, down_main_tradeIndex)
-
 }
 
 func up_main_tradeIndex(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20201102222546_orders.go b/pkg/migrations/mysql/main_20201102222546_orders.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_orders, down_main_orders)
-
 }
 
 func up_main_orders(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20201103173342_trades_add_order_id.go b/pkg/migrations/mysql/main_20201103173342_trades_add_order_id.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_tradesAddOrderId, down_main_tradesAddOrderId)
-
 }
 
 func up_main_tradesAddOrderId(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20201105092857_trades_index_fix.go b/pkg/migrations/mysql/main_20201105092857_trades_index_fix.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_tradesIndexFix, down_main_tradesIndexFix)
-
 }
 
 func up_main_tradesIndexFix(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20201105093056_orders_add_index.go b/pkg/migrations/mysql/main_20201105093056_orders_add_index.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_ordersAddIndex, down_main_ordersAddIndex)
-
 }
 
 func up_main_ordersAddIndex(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20201106114742_klines.go b/pkg/migrations/mysql/main_20201106114742_klines.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_klines, down_main_klines)
-
 }
 
 func up_main_klines(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20201211175751_fix_symbol_length.go b/pkg/migrations/mysql/main_20201211175751_fix_symbol_length.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_fixSymbolLength, down_main_fixSymbolLength)
-
 }
 
 func up_main_fixSymbolLength(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20210118163847_fix_unique_index.go b/pkg/migrations/mysql/main_20210118163847_fix_unique_index.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_fixUniqueIndex, down_main_fixUniqueIndex)
-
 }
 
 func up_main_fixUniqueIndex(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20210119232826_add_margin_columns.go b/pkg/migrations/mysql/main_20210119232826_add_margin_columns.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_addMarginColumns, down_main_addMarginColumns)
-
 }
 
 func up_main_addMarginColumns(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20210129182704_trade_price_quantity_index.go b/pkg/migrations/mysql/main_20210129182704_trade_price_quantity_index.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_tradePriceQuantityIndex, down_main_tradePriceQuantityIndex)
-
 }
 
 func up_main_tradePriceQuantityIndex(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20210215203116_add_pnl_column.go b/pkg/migrations/mysql/main_20210215203116_add_pnl_column.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_addPnlColumn, down_main_addPnlColumn)
-
 }
 
 func up_main_addPnlColumn(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20210223080622_add_rewards_table.go b/pkg/migrations/mysql/main_20210223080622_add_rewards_table.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_addRewardsTable, down_main_addRewardsTable)
-
 }
 
 func up_main_addRewardsTable(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20210301140656_add_withdraws_table.go b/pkg/migrations/mysql/main_20210301140656_add_withdraws_table.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_addWithdrawsTable, down_main_addWithdrawsTable)
-
 }
 
 func up_main_addWithdrawsTable(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20210307201830_add_deposits_table.go b/pkg/migrations/mysql/main_20210307201830_add_deposits_table.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_addDepositsTable, down_main_addDepositsTable)
-
 }
 
 func up_main_addDepositsTable(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20210416230730_klines_symbol_length.go b/pkg/migrations/mysql/main_20210416230730_klines_symbol_length.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_klinesSymbolLength, down_main_klinesSymbolLength)
-
 }
 
 func up_main_klinesSymbolLength(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20210421091430_increase_symbol_length.go b/pkg/migrations/mysql/main_20210421091430_increase_symbol_length.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_increaseSymbolLength, down_main_increaseSymbolLength)
-
 }
 
 func up_main_increaseSymbolLength(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20210421095030_increase_decimal_length.go b/pkg/migrations/mysql/main_20210421095030_increase_decimal_length.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_increaseDecimalLength, down_main_increaseDecimalLength)
-
 }
 
 func up_main_increaseDecimalLength(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20210531234123_add_kline_taker_buy_columns.go b/pkg/migrations/mysql/main_20210531234123_add_kline_taker_buy_columns.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_addKlineTakerBuyColumns, down_main_addKlineTakerBuyColumns)
-
 }
 
 func up_main_addKlineTakerBuyColumns(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20211205162043_add_is_futures_column.go b/pkg/migrations/mysql/main_20211205162043_add_is_futures_column.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_addIsFuturesColumn, down_main_addIsFuturesColumn)
-
 }
 
 func up_main_addIsFuturesColumn(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20211211020303_add_ftx_kline.go b/pkg/migrations/mysql/main_20211211020303_add_ftx_kline.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_addFtxKline, down_main_addFtxKline)
-
 }
 
 func up_main_addFtxKline(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20211211034819_add_nav_history_details.go b/pkg/migrations/mysql/main_20211211034819_add_nav_history_details.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_addNavHistoryDetails, down_main_addNavHistoryDetails)
-
 }
 
 func up_main_addNavHistoryDetails(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20211211103657_update_fee_currency_length.go b/pkg/migrations/mysql/main_20211211103657_update_fee_currency_length.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_updateFeeCurrencyLength, down_main_updateFeeCurrencyLength)
-
 }
 
 func up_main_updateFeeCurrencyLength(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20211226022411_add_kucoin_klines.go b/pkg/migrations/mysql/main_20211226022411_add_kucoin_klines.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_addKucoinKlines, down_main_addKucoinKlines)
-
 }
 
 func up_main_addKucoinKlines(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20220304153317_add_profit_table.go b/pkg/migrations/mysql/main_20220304153317_add_profit_table.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_addProfitTable, down_main_addProfitTable)
-
 }
 
 func up_main_addProfitTable(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20220307132917_add_positions.go b/pkg/migrations/mysql/main_20220307132917_add_positions.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_addPositions, down_main_addPositions)
-
 }
 
 func up_main_addPositions(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20220317125555_fix_trade_indexes.go b/pkg/migrations/mysql/main_20220317125555_fix_trade_indexes.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_fixTradeIndexes, down_main_fixTradeIndexes)
-
 }
 
 func up_main_fixTradeIndexes(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20220419121046_fix_fee_column.go b/pkg/migrations/mysql/main_20220419121046_fix_fee_column.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_fixFeeColumn, down_main_fixFeeColumn)
-
 }
 
 func up_main_fixFeeColumn(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20220503144849_add_margin_info_to_nav.go b/pkg/migrations/mysql/main_20220503144849_add_margin_info_to_nav.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_addMarginInfoToNav, down_main_addMarginInfoToNav)
-
 }
 
 func up_main_addMarginInfoToNav(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20220504184155_fix_net_asset_column.go b/pkg/migrations/mysql/main_20220504184155_fix_net_asset_column.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_fixNetAssetColumn, down_main_fixNetAssetColumn)
-
 }
 
 func up_main_fixNetAssetColumn(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20220512170322_fix_profit_symbol_length.go b/pkg/migrations/mysql/main_20220512170322_fix_profit_symbol_length.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_fixProfitSymbolLength, down_main_fixProfitSymbolLength)
-
 }
 
 func up_main_fixProfitSymbolLength(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20220520140707_kline_unique_idx.go b/pkg/migrations/mysql/main_20220520140707_kline_unique_idx.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_klineUniqueIdx, down_main_klineUniqueIdx)
-
 }
 
 func up_main_klineUniqueIdx(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20220531012226_margin_loans.go b/pkg/migrations/mysql/main_20220531012226_margin_loans.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_marginLoans, down_main_marginLoans)
-
 }
 
 func up_main_marginLoans(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20220531013327_margin_repays.go b/pkg/migrations/mysql/main_20220531013327_margin_repays.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_marginRepays, down_main_marginRepays)
-
 }
 
 func up_main_marginRepays(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20220531013542_margin_interests.go b/pkg/migrations/mysql/main_20220531013542_margin_interests.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_marginInterests, down_main_marginInterests)
-
 }
 
 func up_main_marginInterests(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20220531015005_margin_liquidations.go b/pkg/migrations/mysql/main_20220531015005_margin_liquidations.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_marginLiquidations, down_main_marginLiquidations)
-
 }
 
 func up_main_marginLiquidations(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20230815173104_add_bybit_klines.go b/pkg/migrations/mysql/main_20230815173104_add_bybit_klines.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_addBybitKlines, down_main_addBybitKlines)
-
 }
 
 func up_main_addBybitKlines(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/main_20231123125402_fix_order_status_length.go b/pkg/migrations/mysql/main_20231123125402_fix_order_status_length.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_fixOrderStatusLength, down_main_fixOrderStatusLength)
-
 }
 
 func up_main_fixOrderStatusLength(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/mysql/migration_api.go b/pkg/migrations/mysql/migration_api.go
@@ -9,14 +9,9 @@ import (
 	"github.com/c9s/rockhopper/v2"
 )
 
-type registryKey struct {
-	Package string
-	Version int64
-}
-
-var registeredGoMigrations = map[registryKey]*rockhopper.Migration{}
+var registeredGoMigrations = map[rockhopper.RegistryKey]*rockhopper.Migration{}
 
-func MergeMigrationsMap(ms map[registryKey]*rockhopper.Migration) {
+func MergeMigrationsMap(ms map[rockhopper.RegistryKey]*rockhopper.Migration) {
 	for k, m := range ms {
 		if _, ok := registeredGoMigrations[k]; !ok {
 			registeredGoMigrations[k] = m
@@ -26,7 +21,7 @@ func MergeMigrationsMap(ms map[registryKey]*rockhopper.Migration) {
 	}
 }
 
-func GetMigrationsMap() map[registryKey]*rockhopper.Migration {
+func GetMigrationsMap() map[rockhopper.RegistryKey]*rockhopper.Migration {
 	return registeredGoMigrations
 }
 
@@ -71,10 +66,6 @@ func _parseFuncPackageName(funcName string) string {
 
 // AddNamedMigration adds a named migration to the registered go migration map
 func AddNamedMigration(packageName, filename string, up, down rockhopper.TransactionHandler) {
-	if registeredGoMigrations == nil {
-		registeredGoMigrations = make(map[registryKey]*rockhopper.Migration)
-	}
-
 	v, err := rockhopper.FileNumericComponent(filename)
 	if err != nil {
 		panic(fmt.Errorf("unable to parse numeric component from filename %s: %v", filename, err))
@@ -91,7 +82,7 @@ func AddNamedMigration(packageName, filename string, up, down rockhopper.Transac
 		UseTx:   true,
 	}
 
-	key := registryKey{Package: packageName, Version: v}
+	key := rockhopper.RegistryKey{Package: packageName, Version: v}
 	if existing, ok := registeredGoMigrations[key]; ok {
 		panic(fmt.Sprintf("failed to add migration %q: version conflicts with key %+v: %+v", filename, key, existing))
 	}

diff --git a/pkg/migrations/mysql/migration_api_test.go b/pkg/migrations/mysql/migration_api_test.go
@@ -14,8 +14,8 @@ func TestGetMigrationsMap(t *testing.T) {
 }
 
 func TestMergeMigrationsMap(t *testing.T) {
-	MergeMigrationsMap(map[registryKey]*rockhopper.Migration{
-		registryKey{Version: 2}: &rockhopper.Migration{},
-		registryKey{Version: 2}: &rockhopper.Migration{},
+	MergeMigrationsMap(map[rockhopper.RegistryKey]*rockhopper.Migration{
+		rockhopper.RegistryKey{Version: 2}: &rockhopper.Migration{},
+		rockhopper.RegistryKey{Version: 2}: &rockhopper.Migration{},
 	})
 }
diff --git a/pkg/migrations/sqlite3/main_20200721225616_trades.go b/pkg/migrations/sqlite3/main_20200721225616_trades.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_trades, down_main_trades)
-
 }
 
 func up_main_trades(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/sqlite3/main_20200819054742_trade_index.go b/pkg/migrations/sqlite3/main_20200819054742_trade_index.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_tradeIndex, down_main_tradeIndex)
-
 }
 
 func up_main_tradeIndex(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/sqlite3/main_20201102222546_orders.go b/pkg/migrations/sqlite3/main_20201102222546_orders.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_orders, down_main_orders)
-
 }
 
 func up_main_orders(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {

diff --git a/pkg/migrations/sqlite3/main_20201103173342_trades_add_order_id.go b/pkg/migrations/sqlite3/main_20201103173342_trades_add_order_id.go
@@ -8,7 +8,6 @@ import (
 
 func init() {
 	AddMigration("main", up_main_tradesAddOrderId, down_main_tradesAddOrderId)
-
 }
 
 func up_main_tradesAddOrderId(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {
-Original file line number
+Diff line change
@@ Expand Up / @@ -8,7 +8,6 @@ import ( @@
     func init() {
     	AddMigration("main", up_main_trades, down_main_trades)
     }
     func up_main_trades(ctx context.Context, tx rockhopper.SQLExecutor) (err error) {
@@ Expand Down @@