feat : Added changes to add amount to Utxo table to track coin amount (#854)

* feat: add amount to Utxo table to track amount

Signed-off-by: Jenita <[email protected]>

* feat: add amount to Utxo table to track amount

Signed-off-by: Jenita <[email protected]>

* feat: add amount to Utxo table to track amount

Signed-off-by: Jenita <[email protected]>

---------

Signed-off-by: Jenita <[email protected]>
Co-authored-by: Jenita <[email protected]>

Author: jkawan

database/plugin/metadata/sqlite/models/utxo.go

@@ -22,6 +22,7 @@ type Utxo struct {
 	DeletedSlot uint64 `gorm:"index"`
 	PaymentKey  []byte `gorm:"index"`
 	StakingKey  []byte `gorm:"index"`
+	Amount      uint64 `gorm:"index"`
 	Cbor        []byte `gorm:"-"` // This is here for convenience but not represented in the metadata DB
 }
 

database/plugin/metadata/sqlite/utxo.go

@@ -202,6 +202,7 @@ func (d *MetadataStoreSqlite) SetUtxo(
 	slot uint64, // slot
 	payment []byte, // payment
 	stake []byte, // stake
+	amount uint64, // amount
 	txn *gorm.DB,
 ) error {
 	tmpUtxo := models.Utxo{

database/plugin/metadata/store.go

@@ -203,6 +203,7 @@ type MetadataStore interface {
 		uint64, // slot
 		[]byte, // payment
 		[]byte, // stake
+		uint64, // amount
 		*gorm.DB,
 	) error
 	SetVoteDelegation(

database/utxo.go

@@ -32,6 +32,7 @@ type Utxo struct {
 	DeletedSlot uint64 `gorm:"index"`
 	PaymentKey  []byte `gorm:"index"`
 	StakingKey  []byte `gorm:"index"`
+	Amount      uint64 `gorm:"index"`
 	Cbor        []byte `gorm:"-"` // This is not represented in the metadata DB
 }
 
@@ -64,6 +65,7 @@ func (d *Database) NewUtxo(
 	outputIdx uint32,
 	slot uint64,
 	paymentKey, stakeKey, cbor []byte,
+	amt uint64,
 	txn *Txn,
 ) error {
 	if txn == nil {
@@ -82,6 +84,7 @@ func (d *Database) NewUtxo(
 		slot,
 		paymentKey,
 		stakeKey,
+		amt,
 		txn.Metadata(),
 	)
 }

ledger/chainsync.go

@@ -241,6 +241,7 @@ func (ls *LedgerState) createGenesisBlock() error {
 				outAddr.PaymentKeyHash().Bytes(),
 				outAddr.StakeKeyHash().Bytes(),
 				outputCbor,
+				utxo.Output.Amount(),
 				txn,
 			)
 			if err != nil {

ledger/delta.go

@@ -71,6 +71,7 @@ func (d *LedgerDelta) apply(ls *LedgerState, txn *database.Txn) error {
 			outAddr.PaymentKeyHash().Bytes(),
 			outAddr.StakeKeyHash().Bytes(),
 			produced.Output.Cbor(),
+			produced.Output.Amount(),
 			txn,
 		)
 		if err != nil {