Feature/start with legacy data

cmd/keeper.go

@@ -69,8 +69,37 @@ func KeeperBootCmd(c *cli.Context) error {
 		return err
 	}
 	defer kd.Close()
+
+	var fromStart bool
+	legacyDB := c.String("legacy")
+	if legacyDB != "" {
+		req, err := kd.ReadLatestRequest(ctx)
+		if err != nil {
+			return err
+		}
+		actions, err := db.ListActions(ctx, mtg.ActionStateDone, 1)
+		if err != nil {
+			return err
+		}
+		if req == nil && len(actions) == 0 {
+			ld, err := keeper.OpenSQLite3StoreLegacy(legacyDB)
+			if err != nil {
+				return err
+			}
+			err = kd.ImportBackup(ctx, ld)
+			if err != nil {
+				return err
+			}
+			err = ld.Close()
+			if err != nil {
+				return err
+			}
+			fromStart = true
+		}
+	}
+
 	keeper := keeper.NewNode(kd, group, mc.Keeper, mc.Signer.MTG, client)
-	keeper.Boot(ctx)
+	keeper.Boot(ctx, fromStart)
 
 	if mmc := mc.Keeper.MonitorConversaionId; mmc != "" {
 		go MonitorKeeper(ctx, db, kd, mc.Keeper, group, mmc, version)
@@ -98,3 +127,29 @@ func KeeperFundRequest(c *cli.Context) error {
 	traceId := uuid.Must(uuid.NewV4()).String()
 	return makeKeeperPaymentRequest(c.String("config"), assetId, amount, traceId, "")
 }
+
+func KeeperExportLegacyData(c *cli.Context) error {
+	ctx := context.Background()
+
+	input := c.String("database")
+	if input == "" {
+		return fmt.Errorf("empty path of legacy database")
+	}
+	path := c.String("export")
+	if path == "" {
+		return fmt.Errorf("empty path of export database")
+	}
+
+	ld, err := keeper.OpenSQLite3StoreLegacy(input)
+	if err != nil {
+		return err
+	}
+	defer ld.Close()
+	sd, err := keeper.OpenSQLite3Store(path)
+	if err != nil {
+		return err
+	}
+	defer sd.Close()
+
+	return sd.ImportBackup(ctx, ld)
+}

cmd/signer.go

@@ -55,12 +55,40 @@ func SignerBootCmd(c *cli.Context) error {
 		return err
 	}
 
-	kd, err := signer.OpenSQLite3Store(mc.Signer.StoreDir + "/mpc.sqlite3")
+	kd, err := signer.OpenSQLite3Store(mc.Signer.StoreDir+"/mpc.sqlite3", false)
 	if err != nil {
 		return err
 	}
 	defer kd.Close()
 
+	var fromStart bool
+	legacyDB := c.String("legacy")
+	if legacyDB != "" {
+		state, err := kd.SessionsState(ctx)
+		if err != nil {
+			return err
+		}
+		actions, err := db.ListActions(ctx, mtg.ActionStateDone, 1)
+		if err != nil {
+			return err
+		}
+		if state.Done == 0 && len(actions) == 0 {
+			ld, err := signer.OpenSQLite3Store(legacyDB, true)
+			if err != nil {
+				return err
+			}
+			err = kd.ImportBackup(ctx, ld)
+			if err != nil {
+				return err
+			}
+			err = ld.Close()
+			if err != nil {
+				return err
+			}
+			fromStart = true
+		}
+	}
+
 	s := &mixin.Keystore{
 		ClientID:          mc.Signer.MTG.App.AppId,
 		SessionID:         mc.Signer.MTG.App.SessionId,
@@ -82,7 +110,7 @@ func SignerBootCmd(c *cli.Context) error {
 	mc.Signer.MTG.App.SpendPrivateKey = key.String()
 
 	node := signer.NewNode(kd, group, messenger, mc.Signer, mc.Keeper.MTG, client)
-	node.Boot(ctx)
+	node.Boot(ctx, fromStart)
 
 	if mmc := mc.Signer.MonitorConversaionId; mmc != "" {
 		go MonitorSigner(ctx, db, kd, mc.Signer, group, mmc, version)
@@ -190,3 +218,29 @@ func makeSignerPaymentRequest(conf *signer.Configuration, op *common.Operation,
 	qrterminal.GenerateHalfBlock(url, qrterminal.H, os.Stdout)
 	return nil
 }
+
+func SignerExportLegacyData(c *cli.Context) error {
+	ctx := context.Background()
+
+	input := c.String("database")
+	if input == "" {
+		return fmt.Errorf("empty path of legacy database")
+	}
+	path := c.String("export")
+	if path == "" {
+		return fmt.Errorf("empty path of export database")
+	}
+
+	ld, err := signer.OpenSQLite3Store(input, true)
+	if err != nil {
+		return err
+	}
+	defer ld.Close()
+	sd, err := signer.OpenSQLite3Store(path, false)
+	if err != nil {
+		return err
+	}
+	defer sd.Close()
+
+	return sd.ImportBackup(ctx, ld)
+}

common/request.go

@@ -82,6 +82,7 @@ type Request struct {
 	ExtraHEX   string
 	State      uint8
 	CreatedAt  time.Time
+	UpdatedAt  time.Time
 	Sequence   uint64
 
 	Output *mtg.Action

keeper/interface.go

@@ -28,8 +28,12 @@ type Configuration struct {
 	MTG                         *mtg.Configuration `toml:"mtg"`
 }
 
+func OpenSQLite3StoreLegacy(path string) (*store.SQLite3Store, error) {
+	return store.OpenSQLite3Store(path, true)
+}
+
 func OpenSQLite3Store(path string) (*store.SQLite3Store, error) {
-	return store.OpenSQLite3Store(path)
+	return store.OpenSQLite3Store(path, false)
 }
 
 func OpenSQLite3ReadOnlyStore(path string) (*store.SQLite3Store, error) {

keeper/node.go

@@ -41,14 +41,16 @@ func NewNode(store *store.SQLite3Store, group *mtg.Group, conf *Configuration, s
 	return node
 }
 
-func (node *Node) Boot(ctx context.Context) {
+func (node *Node) Boot(ctx context.Context, fromStart bool) {
 	terminated, err := node.store.ReadTerminate(ctx)
 	if err != nil || terminated {
 		panic(err)
 	}
-	err = node.Migrate(ctx)
-	if err != nil {
-		panic(err)
+	if !fromStart {
+		err = node.Migrate(ctx)
+		if err != nil {
+			panic(err)
+		}
 	}
 }
 

keeper/store/ethereum.go

@@ -21,6 +21,15 @@ type SafeBalance struct {
 	UpdatedAt    time.Time
 }
 
+func BalancFromRow(row *sql.Rows) (*SafeBalance, error) {
+	var sb SafeBalance
+	err := row.Scan(&sb.Address, &sb.AssetId, &sb.AssetAddress, &sb.balance, &sb.LatestTxHash, &sb.UpdatedAt)
+	if err != nil {
+		return nil, err
+	}
+	return &sb, nil
+}
+
 func (sb *SafeBalance) UpdateBalance(change *big.Int) {
 	balance := new(big.Int).Add(sb.BigBalance(), change)
 	if balance.Sign() < 0 {