update

diff --git a/federation/service/warder.go b/federation/service/warder.go
index 7a7a5b3..91f93f7 100644 (file)
--- a/federation/service/warder.go
+++ b/federation/service/warder.go
@@ -25,3 +25,10 @@ func NewWarder(cfg *config.Warder) *Warder {
 func (w *Warder) RequestSign(destTx interface{}, ormTx *orm.CrossTransaction) (string, error) {
        return "", nil
 }
+
+// NotifySubmission() will notify a remote warder the submission of a destTx,
+// the remote warder will check the tx signs count and set the tx submitted if
+// signs count reach quorum
+func (w *Warder) NotifySubmission(ormTx *orm.CrossTransaction) error {
+       return nil
+}

diff --git a/federation/warder.go b/federation/warder.go
index fd89d76..a1d6270 100644 (file)
--- a/federation/warder.go
+++ b/federation/warder.go
@@ -108,7 +108,7 @@ func (w *warder) processCrossTxRoutine() {
                        }
 
                        if submittedTxID != destTxID {
-                               log.WithFields(log.Fields{"err": err, "cross-chain tx": ormTx, "built tx ID": destTxID, "submittedTx ID": submittedTxID}).Warnln("submitTx ID mismatch")
+                               log.WithFields(log.Fields{"err": err, "cross-chain tx": ormTx, "builtTx ID": destTxID, "submittedTx ID": submittedTxID}).Warnln("submitTx ID mismatch")
                                continue
 
                        }
@@ -214,5 +214,14 @@ func (w *warder) submitTx(destTx interface{}) (string, error) {
 
 // TODO:
 func (w *warder) updateSubmission(tx *orm.CrossTransaction) error {
+       if err := w.db.Where(tx).UpdateColumn(&orm.CrossTransaction{
+               Status: common.CrossTxSubmittedStatus,
+       }).Error; err != nil {
+               return err
+       }
+
+       for _, remote := range w.remotes {
+               remote.NotifySubmission(tx)
+       }
        return nil
 }