update

diff --git a/federation/database/orm/cross_transaction_sign.go b/federation/database/orm/cross_transaction_sign.go
index b60e7de..9442e2e 100644 (file)
--- a/federation/database/orm/cross_transaction_sign.go
+++ b/federation/database/orm/cross_transaction_sign.go
@@ -7,7 +7,7 @@ import (
 type CrossTransactionSign struct {
        ID                 uint64 `gorm:"primary_key"`
        CrossTransactionID uint64
-       WarderID           uint64
+       WarderID           uint8
        Signatures         string
        Status             uint8
        CreatedAt          types.Timestamp

diff --git a/federation/warder.go b/federation/warder.go
index 869e440..14cbfe7 100644 (file)
--- a/federation/warder.go
+++ b/federation/warder.go
@@ -246,8 +246,19 @@ func (w *warder) addInputWitness(tx interface{}) {
        }
 }
 
-// TODO:
-func (w *warder) initDestTxSigns(destTx interface{}, tx *orm.CrossTransaction) error {
+// TODO: fix WarderID
+func (w *warder) initDestTxSigns(destTx interface{}, ormTx *orm.CrossTransaction) error {
+       for _, remote := range w.remotes {
+
+               if err := w.db.Create(&orm.CrossTransactionSign{
+                       CrossTransactionID: ormTx.ID,
+                       WarderID:           remote.Position,
+                       Status:             common.CrossTxSignPendingStatus,
+               }).Error; err != nil {
+                       return err
+               }
+       }
+
        return nil
 }