diff --git a/token/services/auditor/manager.go b/token/services/auditor/manager.go index b48278058..e88a0a6ef 100644 --- a/token/services/auditor/manager.go +++ b/token/services/auditor/manager.go @@ -134,7 +134,7 @@ func (cm *Manager) restore(tmsID token.TMSID) error { if err != nil { return errors.WithMessagef(err, "failed to get auditor for [%s]", tmsID) } - it, err := auditor.auditDB.TokenRequests(auditdb.QueryTokenRequestsParams{Statuses: []TxStatus{auditdb.Pending, auditdb.Unknown}}) + it, err := auditor.auditDB.TokenRequests(auditdb.QueryTokenRequestsParams{Statuses: []TxStatus{auditdb.Pending, auditdb.Unknown, auditdb.Deleted}}) if err != nil { return errors.Errorf("failed to get tx iterator for [%s]", tmsID) } diff --git a/token/services/ttx/manager.go b/token/services/ttx/manager.go index a8c7d3efc..30e8c0d24 100644 --- a/token/services/ttx/manager.go +++ b/token/services/ttx/manager.go @@ -119,7 +119,7 @@ func (m *Manager) RestoreTMS(tmsID token.TMSID) error { return errors.WithMessagef(err, "failed to get db for [%s:%s]", tmsID.Network, tmsID.Channel) } - it, err := db.ttxDB.TokenRequests(ttxdb.QueryTokenRequestsParams{Statuses: []TxStatus{driver.Pending, driver.Unknown}}) + it, err := db.ttxDB.TokenRequests(ttxdb.QueryTokenRequestsParams{Statuses: []TxStatus{driver.Pending, driver.Unknown, driver.Deleted}}) if err != nil { return errors.WithMessagef(err, "failed to get tx iterator for [%s:%s:%s]", tmsID.Network, tmsID.Channel, tmsID) }