Method updateBilling

worker/dbms.go:205–234

(itx interfaces.Transaction, count uint32)

}

func (dbms *DBMS) updateBilling(itx interfaces.Transaction, count uint32) {
	var (
		tx *types.UpdateBilling
		ok bool
	)
	if tx, ok = itx.(*types.UpdateBilling); !ok {
		log.WithFields(log.Fields{
			"type": itx.GetTransactionType(),
		}).WithError(ErrInvalidTransactionType).Warn("invalid tx type in update billing")
		return
	}
	// Get profile and database instance
	var (
		id       = tx.Receiver.DatabaseID()
		profile  *types.SQLChainProfile
		database *Database
	)
	le := log.WithFields(log.Fields{
		"id": id,
	})
	if database, ok = dbms.getMeta(id); !ok {
		le.Warn("cannot find database")
		return
	}
	if profile, ok = dbms.busService.RequestSQLProfile(id); !ok {
		le.Warn("cannot find profile")
		return
	}
	database.chain.SetLastBillingHeight(int32(profile.LastUpdatedHeight))
}

func (dbms *DBMS) createDatabase(tx interfaces.Transaction, count uint32) {
	cd, ok := tx.(*types.CreateDatabase)