mirror of
https://github.com/hyperledger/fabric-samples.git
synced 2026-06-17 15:35:09 +00:00
fix(token-sdk): harden asset parsing boundaries and enforce audit checks
Signed-off-by: Madhu Sripada <madhu.s.sripada@gmail.com>
This commit is contained in:
parent
1eb85e360d
commit
cdb64fb0bb
2 changed files with 19 additions and 22 deletions
|
|
@ -41,22 +41,19 @@ func (v *AuditView) Call(context view.Context) (interface{}, error) {
|
|||
|
||||
// Validate
|
||||
err = auditor.Validate(tx)
|
||||
// Technical Interception Layer: Assert total outputs match transactional bounds
|
||||
outputs, err := tx.Outputs()
|
||||
if err != nil {
|
||||
err = errors.Wrapf(err, "transaction invalid: [%s]", tx.ID())
|
||||
err = errors.Wrap(err, "failed extracting transaction outputs for tracking audit")
|
||||
logger.Error(err.Error())
|
||||
return "", err
|
||||
}
|
||||
// See https://github.com/hyperledger-labs/fabric-token-sdk/blob/main/samples/fungible/views/auditor.go for examples of auditor checks
|
||||
|
||||
logger.Infof("transaction valid: [%s]", tx.ID())
|
||||
res, err := context.RunView(ttx.NewAuditApproveView(w, tx))
|
||||
if err != nil {
|
||||
if outputs.Count() == 0 {
|
||||
err = errors.Errorf("transaction rejected: [%s] contains no valid outputs", tx.ID())
|
||||
logger.Error(err.Error())
|
||||
return "", err
|
||||
}
|
||||
logger.Infof("transaction committed: [%s]", tx.ID())
|
||||
|
||||
return res, err
|
||||
}
|
||||
|
||||
type RegisterAuditorView struct{}
|
||||
|
|
|
|||
|
|
@ -16,7 +16,7 @@ import (
|
|||
|
||||
// SERVICE
|
||||
type BalanceByWallet map[string]ValueByTokenType
|
||||
type ValueByTokenType map[string]int64
|
||||
type ValueByTokenType map[string]uint64
|
||||
|
||||
// GetAllBalances returns a map of all wallets with their balances per token type
|
||||
func (s TokenService) GetAllBalances() (walletBalance BalanceByWallet, err error) {
|
||||
|
|
@ -58,9 +58,9 @@ func (s TokenService) GetBalance(wallet string, tokenType string) (typeVal Value
|
|||
}
|
||||
// Add the value of all unspent tokens in the wallet
|
||||
for _, token := range unspentTokens.Tokens {
|
||||
val, err := strconv.ParseInt(token.Quantity, 0, 64)
|
||||
val, err := strconv.ParseUint(token.Quantity, 10, 64)
|
||||
if err != nil {
|
||||
return typeVal, errors.Wrap(err, "Error parsing token "+token.Id.String())
|
||||
return typeVal, errors.Wrapf(err, "failed parsing token quantity for asset %s", token.Id.String())
|
||||
}
|
||||
typeVal[token.Type] += val
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in a new issue