Skip to content
Snippets Groups Projects
Commit ae0d5f83 authored by Hans Moog's avatar Hans Moog
Browse files

Refactor: changed type conversions back to typeutils

parent 06f39953
No related branches found
No related tags found
No related merge requests found
...@@ -7,7 +7,6 @@ import ( ...@@ -7,7 +7,6 @@ import (
"github.com/iotaledger/goshimmer/packages/errors" "github.com/iotaledger/goshimmer/packages/errors"
"github.com/iotaledger/goshimmer/packages/typeutils" "github.com/iotaledger/goshimmer/packages/typeutils"
"github.com/iotaledger/goshimmer/packages/unsafeconvert"
"github.com/iotaledger/iota.go/trinary" "github.com/iotaledger/iota.go/trinary"
) )
...@@ -70,14 +69,14 @@ func (approvers *Approvers) Marshal() (result []byte) { ...@@ -70,14 +69,14 @@ func (approvers *Approvers) Marshal() (result []byte) {
binary.BigEndian.PutUint64(result[MARSHALED_APPROVERS_HASHES_COUNT_START:MARSHALED_APPROVERS_HASHES_COUNT_END], uint64(len(approvers.hashes))) binary.BigEndian.PutUint64(result[MARSHALED_APPROVERS_HASHES_COUNT_START:MARSHALED_APPROVERS_HASHES_COUNT_END], uint64(len(approvers.hashes)))
copy(result[MARSHALED_APPROVERS_HASH_START:MARSHALED_APPROVERS_HASH_END], unsafeconvert.StringToBytes(approvers.hash)) copy(result[MARSHALED_APPROVERS_HASH_START:MARSHALED_APPROVERS_HASH_END], typeutils.StringToBytes(approvers.hash))
i := 0 i := 0
for hash := range approvers.hashes { for hash := range approvers.hashes {
var HASH_START = MARSHALED_APPROVERS_HASHES_START + i*(MARSHALED_APPROVERS_HASH_SIZE) var HASH_START = MARSHALED_APPROVERS_HASHES_START + i*(MARSHALED_APPROVERS_HASH_SIZE)
var HASH_END = HASH_START + MARSHALED_APPROVERS_HASH_SIZE var HASH_END = HASH_START + MARSHALED_APPROVERS_HASH_SIZE
copy(result[HASH_START:HASH_END], unsafeconvert.StringToBytes(hash)) copy(result[HASH_START:HASH_END], typeutils.StringToBytes(hash))
i++ i++
} }
......
...@@ -9,7 +9,6 @@ import ( ...@@ -9,7 +9,6 @@ import (
"github.com/iotaledger/goshimmer/packages/bitutils" "github.com/iotaledger/goshimmer/packages/bitutils"
"github.com/iotaledger/goshimmer/packages/errors" "github.com/iotaledger/goshimmer/packages/errors"
"github.com/iotaledger/goshimmer/packages/typeutils" "github.com/iotaledger/goshimmer/packages/typeutils"
"github.com/iotaledger/goshimmer/packages/unsafeconvert"
"github.com/iotaledger/iota.go/trinary" "github.com/iotaledger/iota.go/trinary"
) )
...@@ -114,8 +113,8 @@ func (bundle *Bundle) Marshal() (result []byte) { ...@@ -114,8 +113,8 @@ func (bundle *Bundle) Marshal() (result []byte) {
binary.BigEndian.PutUint64(result[MARSHALED_TRANSACTIONS_COUNT_START:MARSHALED_TRANSACTIONS_COUNT_END], uint64(len(bundle.transactionHashes))) binary.BigEndian.PutUint64(result[MARSHALED_TRANSACTIONS_COUNT_START:MARSHALED_TRANSACTIONS_COUNT_END], uint64(len(bundle.transactionHashes)))
copy(result[MARSHALED_HASH_START:MARSHALED_HASH_END], unsafeconvert.StringToBytes(bundle.hash)) copy(result[MARSHALED_HASH_START:MARSHALED_HASH_END], typeutils.StringToBytes(bundle.hash))
copy(result[MARSHALED_BUNDLE_ESSENCE_HASH_START:MARSHALED_BUNDLE_ESSENCE_HASH_END], unsafeconvert.StringToBytes(bundle.bundleEssenceHash)) copy(result[MARSHALED_BUNDLE_ESSENCE_HASH_START:MARSHALED_BUNDLE_ESSENCE_HASH_END], typeutils.StringToBytes(bundle.bundleEssenceHash))
var flags bitutils.BitMask var flags bitutils.BitMask
if bundle.isValueBundle { if bundle.isValueBundle {
...@@ -128,7 +127,7 @@ func (bundle *Bundle) Marshal() (result []byte) { ...@@ -128,7 +127,7 @@ func (bundle *Bundle) Marshal() (result []byte) {
var HASH_START = MARSHALED_APPROVERS_HASHES_START + i*(MARSHALED_TRANSACTION_HASH_SIZE) var HASH_START = MARSHALED_APPROVERS_HASHES_START + i*(MARSHALED_TRANSACTION_HASH_SIZE)
var HASH_END = HASH_START + MARSHALED_TRANSACTION_HASH_SIZE var HASH_END = HASH_START + MARSHALED_TRANSACTION_HASH_SIZE
copy(result[HASH_START:HASH_END], unsafeconvert.StringToBytes(hash)) copy(result[HASH_START:HASH_END], typeutils.StringToBytes(hash))
i++ i++
} }
......
...@@ -7,7 +7,6 @@ import ( ...@@ -7,7 +7,6 @@ import (
"github.com/iotaledger/goshimmer/packages/bitutils" "github.com/iotaledger/goshimmer/packages/bitutils"
"github.com/iotaledger/goshimmer/packages/errors" "github.com/iotaledger/goshimmer/packages/errors"
"github.com/iotaledger/goshimmer/packages/typeutils" "github.com/iotaledger/goshimmer/packages/typeutils"
"github.com/iotaledger/goshimmer/packages/unsafeconvert"
"github.com/iotaledger/iota.go/trinary" "github.com/iotaledger/iota.go/trinary"
) )
...@@ -219,7 +218,7 @@ func (metadata *TransactionMetadata) Marshal() ([]byte, errors.IdentifiableError ...@@ -219,7 +218,7 @@ func (metadata *TransactionMetadata) Marshal() ([]byte, errors.IdentifiableError
metadata.finalizedMutex.RLock() metadata.finalizedMutex.RLock()
defer metadata.finalizedMutex.RUnlock() defer metadata.finalizedMutex.RUnlock()
copy(marshaledMetadata[MARSHALED_HASH_START:MARSHALED_HASH_END], unsafeconvert.StringToBytes(metadata.hash)) copy(marshaledMetadata[MARSHALED_HASH_START:MARSHALED_HASH_END], typeutils.StringToBytes(metadata.hash))
marshaledReceivedTime, err := metadata.receivedTime.MarshalBinary() marshaledReceivedTime, err := metadata.receivedTime.MarshalBinary()
if err != nil { if err != nil {
......
...@@ -7,7 +7,7 @@ import ( ...@@ -7,7 +7,7 @@ import (
"github.com/iotaledger/goshimmer/packages/errors" "github.com/iotaledger/goshimmer/packages/errors"
"github.com/iotaledger/goshimmer/packages/model/approvers" "github.com/iotaledger/goshimmer/packages/model/approvers"
"github.com/iotaledger/goshimmer/packages/node" "github.com/iotaledger/goshimmer/packages/node"
"github.com/iotaledger/goshimmer/packages/unsafeconvert" "github.com/iotaledger/goshimmer/packages/typeutils"
"github.com/iotaledger/iota.go/trinary" "github.com/iotaledger/iota.go/trinary"
) )
...@@ -86,7 +86,7 @@ func configureApproversDatabase(plugin *node.Plugin) { ...@@ -86,7 +86,7 @@ func configureApproversDatabase(plugin *node.Plugin) {
func storeApproversInDatabase(approvers *approvers.Approvers) errors.IdentifiableError { func storeApproversInDatabase(approvers *approvers.Approvers) errors.IdentifiableError {
if approvers.GetModified() { if approvers.GetModified() {
if err := approversDatabase.Set(unsafeconvert.StringToBytes(approvers.GetHash()), approvers.Marshal()); err != nil { if err := approversDatabase.Set(typeutils.StringToBytes(approvers.GetHash()), approvers.Marshal()); err != nil {
return ErrDatabaseError.Derive(err, "failed to store approvers") return ErrDatabaseError.Derive(err, "failed to store approvers")
} }
...@@ -97,7 +97,7 @@ func storeApproversInDatabase(approvers *approvers.Approvers) errors.Identifiabl ...@@ -97,7 +97,7 @@ func storeApproversInDatabase(approvers *approvers.Approvers) errors.Identifiabl
} }
func getApproversFromDatabase(transactionHash trinary.Trytes) (*approvers.Approvers, errors.IdentifiableError) { func getApproversFromDatabase(transactionHash trinary.Trytes) (*approvers.Approvers, errors.IdentifiableError) {
approversData, err := approversDatabase.Get(unsafeconvert.StringToBytes(transactionHash)) approversData, err := approversDatabase.Get(typeutils.StringToBytes(transactionHash))
if err != nil { if err != nil {
if err == badger.ErrKeyNotFound { if err == badger.ErrKeyNotFound {
return nil, nil return nil, nil
...@@ -115,7 +115,7 @@ func getApproversFromDatabase(transactionHash trinary.Trytes) (*approvers.Approv ...@@ -115,7 +115,7 @@ func getApproversFromDatabase(transactionHash trinary.Trytes) (*approvers.Approv
} }
func databaseContainsApprovers(transactionHash trinary.Trytes) (bool, errors.IdentifiableError) { func databaseContainsApprovers(transactionHash trinary.Trytes) (bool, errors.IdentifiableError) {
if contains, err := approversDatabase.Contains(unsafeconvert.StringToBytes(transactionHash)); err != nil { if contains, err := approversDatabase.Contains(typeutils.StringToBytes(transactionHash)); err != nil {
return false, ErrDatabaseError.Derive(err, "failed to check if the approvers exists") return false, ErrDatabaseError.Derive(err, "failed to check if the approvers exists")
} else { } else {
return contains, nil return contains, nil
......
...@@ -7,7 +7,7 @@ import ( ...@@ -7,7 +7,7 @@ import (
"github.com/iotaledger/goshimmer/packages/errors" "github.com/iotaledger/goshimmer/packages/errors"
"github.com/iotaledger/goshimmer/packages/model/bundle" "github.com/iotaledger/goshimmer/packages/model/bundle"
"github.com/iotaledger/goshimmer/packages/node" "github.com/iotaledger/goshimmer/packages/node"
"github.com/iotaledger/goshimmer/packages/unsafeconvert" "github.com/iotaledger/goshimmer/packages/typeutils"
"github.com/iotaledger/iota.go/trinary" "github.com/iotaledger/iota.go/trinary"
) )
...@@ -90,7 +90,7 @@ func configureBundleDatabase(plugin *node.Plugin) { ...@@ -90,7 +90,7 @@ func configureBundleDatabase(plugin *node.Plugin) {
func storeBundleInDatabase(bundle *bundle.Bundle) errors.IdentifiableError { func storeBundleInDatabase(bundle *bundle.Bundle) errors.IdentifiableError {
if bundle.GetModified() { if bundle.GetModified() {
if err := bundleDatabase.Set(unsafeconvert.StringToBytes(bundle.GetHash()), bundle.Marshal()); err != nil { if err := bundleDatabase.Set(typeutils.StringToBytes(bundle.GetHash()), bundle.Marshal()); err != nil {
return ErrDatabaseError.Derive(err, "failed to store bundle") return ErrDatabaseError.Derive(err, "failed to store bundle")
} }
...@@ -101,7 +101,7 @@ func storeBundleInDatabase(bundle *bundle.Bundle) errors.IdentifiableError { ...@@ -101,7 +101,7 @@ func storeBundleInDatabase(bundle *bundle.Bundle) errors.IdentifiableError {
} }
func getBundleFromDatabase(transactionHash trinary.Trytes) (*bundle.Bundle, errors.IdentifiableError) { func getBundleFromDatabase(transactionHash trinary.Trytes) (*bundle.Bundle, errors.IdentifiableError) {
bundleData, err := bundleDatabase.Get(unsafeconvert.StringToBytes(transactionHash)) bundleData, err := bundleDatabase.Get(typeutils.StringToBytes(transactionHash))
if err != nil { if err != nil {
if err == badger.ErrKeyNotFound { if err == badger.ErrKeyNotFound {
return nil, nil return nil, nil
...@@ -119,7 +119,7 @@ func getBundleFromDatabase(transactionHash trinary.Trytes) (*bundle.Bundle, erro ...@@ -119,7 +119,7 @@ func getBundleFromDatabase(transactionHash trinary.Trytes) (*bundle.Bundle, erro
} }
func databaseContainsBundle(transactionHash trinary.Trytes) (bool, errors.IdentifiableError) { func databaseContainsBundle(transactionHash trinary.Trytes) (bool, errors.IdentifiableError) {
if contains, err := bundleDatabase.Contains(unsafeconvert.StringToBytes(transactionHash)); err != nil { if contains, err := bundleDatabase.Contains(typeutils.StringToBytes(transactionHash)); err != nil {
return false, ErrDatabaseError.Derive(err, "failed to check if the bundle exists") return false, ErrDatabaseError.Derive(err, "failed to check if the bundle exists")
} else { } else {
return contains, nil return contains, nil
......
...@@ -8,7 +8,6 @@ import ( ...@@ -8,7 +8,6 @@ import (
"github.com/iotaledger/goshimmer/packages/model/value_transaction" "github.com/iotaledger/goshimmer/packages/model/value_transaction"
"github.com/iotaledger/goshimmer/packages/node" "github.com/iotaledger/goshimmer/packages/node"
"github.com/iotaledger/goshimmer/packages/typeutils" "github.com/iotaledger/goshimmer/packages/typeutils"
"github.com/iotaledger/goshimmer/packages/unsafeconvert"
"github.com/iotaledger/iota.go/trinary" "github.com/iotaledger/iota.go/trinary"
) )
...@@ -88,7 +87,7 @@ func configureTransactionDatabase(plugin *node.Plugin) { ...@@ -88,7 +87,7 @@ func configureTransactionDatabase(plugin *node.Plugin) {
func storeTransactionInDatabase(transaction *value_transaction.ValueTransaction) errors.IdentifiableError { func storeTransactionInDatabase(transaction *value_transaction.ValueTransaction) errors.IdentifiableError {
if transaction.GetModified() { if transaction.GetModified() {
if err := transactionDatabase.Set(unsafeconvert.StringToBytes(transaction.GetHash()), transaction.MetaTransaction.GetBytes()); err != nil { if err := transactionDatabase.Set(typeutils.StringToBytes(transaction.GetHash()), transaction.MetaTransaction.GetBytes()); err != nil {
return ErrDatabaseError.Derive(err, "failed to store transaction") return ErrDatabaseError.Derive(err, "failed to store transaction")
} }
...@@ -99,7 +98,7 @@ func storeTransactionInDatabase(transaction *value_transaction.ValueTransaction) ...@@ -99,7 +98,7 @@ func storeTransactionInDatabase(transaction *value_transaction.ValueTransaction)
} }
func getTransactionFromDatabase(transactionHash trinary.Trytes) (*value_transaction.ValueTransaction, errors.IdentifiableError) { func getTransactionFromDatabase(transactionHash trinary.Trytes) (*value_transaction.ValueTransaction, errors.IdentifiableError) {
txData, err := transactionDatabase.Get(unsafeconvert.StringToBytes(transactionHash)) txData, err := transactionDatabase.Get(typeutils.StringToBytes(transactionHash))
if err != nil { if err != nil {
if err == badger.ErrKeyNotFound { if err == badger.ErrKeyNotFound {
return nil, nil return nil, nil
...@@ -112,7 +111,7 @@ func getTransactionFromDatabase(transactionHash trinary.Trytes) (*value_transact ...@@ -112,7 +111,7 @@ func getTransactionFromDatabase(transactionHash trinary.Trytes) (*value_transact
} }
func databaseContainsTransaction(transactionHash trinary.Trytes) (bool, errors.IdentifiableError) { func databaseContainsTransaction(transactionHash trinary.Trytes) (bool, errors.IdentifiableError) {
if contains, err := transactionDatabase.Contains(unsafeconvert.StringToBytes(transactionHash)); err != nil { if contains, err := transactionDatabase.Contains(typeutils.StringToBytes(transactionHash)); err != nil {
return contains, ErrDatabaseError.Derive(err, "failed to check if the transaction exists") return contains, ErrDatabaseError.Derive(err, "failed to check if the transaction exists")
} else { } else {
return contains, nil return contains, nil
......
...@@ -8,7 +8,6 @@ import ( ...@@ -8,7 +8,6 @@ import (
"github.com/iotaledger/goshimmer/packages/model/transactionmetadata" "github.com/iotaledger/goshimmer/packages/model/transactionmetadata"
"github.com/iotaledger/goshimmer/packages/node" "github.com/iotaledger/goshimmer/packages/node"
"github.com/iotaledger/goshimmer/packages/typeutils" "github.com/iotaledger/goshimmer/packages/typeutils"
"github.com/iotaledger/goshimmer/packages/unsafeconvert"
"github.com/iotaledger/iota.go/trinary" "github.com/iotaledger/iota.go/trinary"
) )
...@@ -91,7 +90,7 @@ func storeTransactionMetadataInDatabase(metadata *transactionmetadata.Transactio ...@@ -91,7 +90,7 @@ func storeTransactionMetadataInDatabase(metadata *transactionmetadata.Transactio
if marshaledMetadata, err := metadata.Marshal(); err != nil { if marshaledMetadata, err := metadata.Marshal(); err != nil {
return err return err
} else { } else {
if err := transactionMetadataDatabase.Set(unsafeconvert.StringToBytes(metadata.GetHash()), marshaledMetadata); err != nil { if err := transactionMetadataDatabase.Set(typeutils.StringToBytes(metadata.GetHash()), marshaledMetadata); err != nil {
return ErrDatabaseError.Derive(err, "failed to store transaction metadata") return ErrDatabaseError.Derive(err, "failed to store transaction metadata")
} }
...@@ -103,7 +102,7 @@ func storeTransactionMetadataInDatabase(metadata *transactionmetadata.Transactio ...@@ -103,7 +102,7 @@ func storeTransactionMetadataInDatabase(metadata *transactionmetadata.Transactio
} }
func getTransactionMetadataFromDatabase(transactionHash trinary.Trytes) (*transactionmetadata.TransactionMetadata, errors.IdentifiableError) { func getTransactionMetadataFromDatabase(transactionHash trinary.Trytes) (*transactionmetadata.TransactionMetadata, errors.IdentifiableError) {
txMetadata, err := transactionMetadataDatabase.Get(unsafeconvert.StringToBytes(transactionHash)) txMetadata, err := transactionMetadataDatabase.Get(typeutils.StringToBytes(transactionHash))
if err != nil { if err != nil {
if err == badger.ErrKeyNotFound { if err == badger.ErrKeyNotFound {
return nil, nil return nil, nil
...@@ -121,7 +120,7 @@ func getTransactionMetadataFromDatabase(transactionHash trinary.Trytes) (*transa ...@@ -121,7 +120,7 @@ func getTransactionMetadataFromDatabase(transactionHash trinary.Trytes) (*transa
} }
func databaseContainsTransactionMetadata(transactionHash trinary.Trytes) (bool, errors.IdentifiableError) { func databaseContainsTransactionMetadata(transactionHash trinary.Trytes) (bool, errors.IdentifiableError) {
if contains, err := transactionMetadataDatabase.Contains(unsafeconvert.StringToBytes(transactionHash)); err != nil { if contains, err := transactionMetadataDatabase.Contains(typeutils.StringToBytes(transactionHash)); err != nil {
return contains, ErrDatabaseError.Derive(err, "failed to check if the transaction metadata exists") return contains, ErrDatabaseError.Derive(err, "failed to check if the transaction metadata exists")
} else { } else {
return contains, nil return contains, nil
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment