continue
}
+ if err := w.initDestTxSigns(destTx, ormTx); err != nil {
+ log.WithFields(log.Fields{"err": err, "cross-chain tx": ormTx}).Warnln("initDestTxSigns")
+ continue
+ }
+
if err := w.signDestTx(destTx, ormTx); err != nil {
log.WithFields(log.Fields{"err": err, "cross-chain tx": ormTx}).Warnln("signDestTx")
continue
return mainchainTx, mainchainTx.ID.String(), nil
}
+// TODO:
func (w *warder) addInputWitness(tx interface{}) {
switch tx.(type) {
case *vaporTypes.Tx:
}
// TODO:
+func (w *warder) initDestTxSigns(destTx interface{}, tx *orm.CrossTransaction) error {
+ return nil
+}
+
+// TODO:
func (w *warder) signDestTx(destTx interface{}, tx *orm.CrossTransaction) error {
if tx.Status != common.CrossTxPendingStatus || !tx.DestTxHash.Valid {
return errors.New("cross-chain tx status error")