mirror of https://github.com/poanetwork/gecko.git
Make all RPC call logs `Info` level.
This commit is contained in:
parent
d85ef87695
commit
f59f45a20f
|
@ -57,7 +57,7 @@ type GetNodeVersionReply struct {
|
||||||
|
|
||||||
// GetNodeVersion returns the version this node is running
|
// GetNodeVersion returns the version this node is running
|
||||||
func (service *Admin) GetNodeVersion(_ *http.Request, _ *struct{}, reply *GetNodeVersionReply) error {
|
func (service *Admin) GetNodeVersion(_ *http.Request, _ *struct{}, reply *GetNodeVersionReply) error {
|
||||||
service.log.Debug("Admin: GetNodeVersion called")
|
service.log.Info("Admin: GetNodeVersion called")
|
||||||
|
|
||||||
reply.Version = service.version.String()
|
reply.Version = service.version.String()
|
||||||
return nil
|
return nil
|
||||||
|
@ -70,7 +70,7 @@ type GetNodeIDReply struct {
|
||||||
|
|
||||||
// GetNodeID returns the node ID of this node
|
// GetNodeID returns the node ID of this node
|
||||||
func (service *Admin) GetNodeID(_ *http.Request, _ *struct{}, reply *GetNodeIDReply) error {
|
func (service *Admin) GetNodeID(_ *http.Request, _ *struct{}, reply *GetNodeIDReply) error {
|
||||||
service.log.Debug("Admin: GetNodeID called")
|
service.log.Info("Admin: GetNodeID called")
|
||||||
|
|
||||||
reply.NodeID = service.nodeID
|
reply.NodeID = service.nodeID
|
||||||
return nil
|
return nil
|
||||||
|
@ -83,7 +83,7 @@ type GetNetworkIDReply struct {
|
||||||
|
|
||||||
// GetNetworkID returns the network ID this node is running on
|
// GetNetworkID returns the network ID this node is running on
|
||||||
func (service *Admin) GetNetworkID(_ *http.Request, _ *struct{}, reply *GetNetworkIDReply) error {
|
func (service *Admin) GetNetworkID(_ *http.Request, _ *struct{}, reply *GetNetworkIDReply) error {
|
||||||
service.log.Debug("Admin: GetNetworkID called")
|
service.log.Info("Admin: GetNetworkID called")
|
||||||
|
|
||||||
reply.NetworkID = cjson.Uint32(service.networkID)
|
reply.NetworkID = cjson.Uint32(service.networkID)
|
||||||
return nil
|
return nil
|
||||||
|
@ -96,7 +96,7 @@ type GetNetworkNameReply struct {
|
||||||
|
|
||||||
// GetNetworkName returns the network name this node is running on
|
// GetNetworkName returns the network name this node is running on
|
||||||
func (service *Admin) GetNetworkName(_ *http.Request, _ *struct{}, reply *GetNetworkNameReply) error {
|
func (service *Admin) GetNetworkName(_ *http.Request, _ *struct{}, reply *GetNetworkNameReply) error {
|
||||||
service.log.Debug("Admin: GetNetworkName called")
|
service.log.Info("Admin: GetNetworkName called")
|
||||||
|
|
||||||
reply.NetworkName = genesis.NetworkName(service.networkID)
|
reply.NetworkName = genesis.NetworkName(service.networkID)
|
||||||
return nil
|
return nil
|
||||||
|
@ -114,7 +114,7 @@ type GetBlockchainIDReply struct {
|
||||||
|
|
||||||
// GetBlockchainID returns the blockchain ID that resolves the alias that was supplied
|
// GetBlockchainID returns the blockchain ID that resolves the alias that was supplied
|
||||||
func (service *Admin) GetBlockchainID(_ *http.Request, args *GetBlockchainIDArgs, reply *GetBlockchainIDReply) error {
|
func (service *Admin) GetBlockchainID(_ *http.Request, args *GetBlockchainIDArgs, reply *GetBlockchainIDReply) error {
|
||||||
service.log.Debug("Admin: GetBlockchainID called")
|
service.log.Info("Admin: GetBlockchainID called")
|
||||||
|
|
||||||
bID, err := service.chainManager.Lookup(args.Alias)
|
bID, err := service.chainManager.Lookup(args.Alias)
|
||||||
reply.BlockchainID = bID.String()
|
reply.BlockchainID = bID.String()
|
||||||
|
@ -128,7 +128,7 @@ type PeersReply struct {
|
||||||
|
|
||||||
// Peers returns the list of current validators
|
// Peers returns the list of current validators
|
||||||
func (service *Admin) Peers(_ *http.Request, _ *struct{}, reply *PeersReply) error {
|
func (service *Admin) Peers(_ *http.Request, _ *struct{}, reply *PeersReply) error {
|
||||||
service.log.Debug("Admin: Peers called")
|
service.log.Info("Admin: Peers called")
|
||||||
reply.Peers = service.networking.Peers()
|
reply.Peers = service.networking.Peers()
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
@ -145,7 +145,7 @@ type StartCPUProfilerReply struct {
|
||||||
|
|
||||||
// StartCPUProfiler starts a cpu profile writing to the specified file
|
// StartCPUProfiler starts a cpu profile writing to the specified file
|
||||||
func (service *Admin) StartCPUProfiler(_ *http.Request, args *StartCPUProfilerArgs, reply *StartCPUProfilerReply) error {
|
func (service *Admin) StartCPUProfiler(_ *http.Request, args *StartCPUProfilerArgs, reply *StartCPUProfilerReply) error {
|
||||||
service.log.Debug("Admin: StartCPUProfiler called with %s", args.Filename)
|
service.log.Info("Admin: StartCPUProfiler called with %s", args.Filename)
|
||||||
reply.Success = true
|
reply.Success = true
|
||||||
return service.performance.StartCPUProfiler(args.Filename)
|
return service.performance.StartCPUProfiler(args.Filename)
|
||||||
}
|
}
|
||||||
|
@ -157,7 +157,7 @@ type StopCPUProfilerReply struct {
|
||||||
|
|
||||||
// StopCPUProfiler stops the cpu profile
|
// StopCPUProfiler stops the cpu profile
|
||||||
func (service *Admin) StopCPUProfiler(_ *http.Request, _ *struct{}, reply *StopCPUProfilerReply) error {
|
func (service *Admin) StopCPUProfiler(_ *http.Request, _ *struct{}, reply *StopCPUProfilerReply) error {
|
||||||
service.log.Debug("Admin: StopCPUProfiler called")
|
service.log.Info("Admin: StopCPUProfiler called")
|
||||||
reply.Success = true
|
reply.Success = true
|
||||||
return service.performance.StopCPUProfiler()
|
return service.performance.StopCPUProfiler()
|
||||||
}
|
}
|
||||||
|
@ -174,7 +174,7 @@ type MemoryProfileReply struct {
|
||||||
|
|
||||||
// MemoryProfile runs a memory profile writing to the specified file
|
// MemoryProfile runs a memory profile writing to the specified file
|
||||||
func (service *Admin) MemoryProfile(_ *http.Request, args *MemoryProfileArgs, reply *MemoryProfileReply) error {
|
func (service *Admin) MemoryProfile(_ *http.Request, args *MemoryProfileArgs, reply *MemoryProfileReply) error {
|
||||||
service.log.Debug("Admin: MemoryProfile called with %s", args.Filename)
|
service.log.Info("Admin: MemoryProfile called with %s", args.Filename)
|
||||||
reply.Success = true
|
reply.Success = true
|
||||||
return service.performance.MemoryProfile(args.Filename)
|
return service.performance.MemoryProfile(args.Filename)
|
||||||
}
|
}
|
||||||
|
@ -191,7 +191,7 @@ type LockProfileReply struct {
|
||||||
|
|
||||||
// LockProfile runs a mutex profile writing to the specified file
|
// LockProfile runs a mutex profile writing to the specified file
|
||||||
func (service *Admin) LockProfile(_ *http.Request, args *LockProfileArgs, reply *LockProfileReply) error {
|
func (service *Admin) LockProfile(_ *http.Request, args *LockProfileArgs, reply *LockProfileReply) error {
|
||||||
service.log.Debug("Admin: LockProfile called with %s", args.Filename)
|
service.log.Info("Admin: LockProfile called with %s", args.Filename)
|
||||||
reply.Success = true
|
reply.Success = true
|
||||||
return service.performance.LockProfile(args.Filename)
|
return service.performance.LockProfile(args.Filename)
|
||||||
}
|
}
|
||||||
|
@ -209,7 +209,7 @@ type AliasReply struct {
|
||||||
|
|
||||||
// Alias attempts to alias an HTTP endpoint to a new name
|
// Alias attempts to alias an HTTP endpoint to a new name
|
||||||
func (service *Admin) Alias(_ *http.Request, args *AliasArgs, reply *AliasReply) error {
|
func (service *Admin) Alias(_ *http.Request, args *AliasArgs, reply *AliasReply) error {
|
||||||
service.log.Debug("Admin: Alias called with URL: %s, Alias: %s", args.Endpoint, args.Alias)
|
service.log.Info("Admin: Alias called with URL: %s, Alias: %s", args.Endpoint, args.Alias)
|
||||||
reply.Success = true
|
reply.Success = true
|
||||||
return service.httpServer.AddAliasesWithReadLock(args.Endpoint, args.Alias)
|
return service.httpServer.AddAliasesWithReadLock(args.Endpoint, args.Alias)
|
||||||
}
|
}
|
||||||
|
@ -227,7 +227,7 @@ type AliasChainReply struct {
|
||||||
|
|
||||||
// AliasChain attempts to alias a chain to a new name
|
// AliasChain attempts to alias a chain to a new name
|
||||||
func (service *Admin) AliasChain(_ *http.Request, args *AliasChainArgs, reply *AliasChainReply) error {
|
func (service *Admin) AliasChain(_ *http.Request, args *AliasChainArgs, reply *AliasChainReply) error {
|
||||||
service.log.Debug("Admin: AliasChain called with Chain: %s, Alias: %s", args.Chain, args.Alias)
|
service.log.Info("Admin: AliasChain called with Chain: %s, Alias: %s", args.Chain, args.Alias)
|
||||||
|
|
||||||
chainID, err := service.chainManager.Lookup(args.Chain)
|
chainID, err := service.chainManager.Lookup(args.Chain)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|
|
@ -74,7 +74,7 @@ type GetLivenessReply struct {
|
||||||
|
|
||||||
// GetLiveness returns a summation of the health of the node
|
// GetLiveness returns a summation of the health of the node
|
||||||
func (h *Health) GetLiveness(_ *http.Request, _ *GetLivenessArgs, reply *GetLivenessReply) error {
|
func (h *Health) GetLiveness(_ *http.Request, _ *GetLivenessArgs, reply *GetLivenessReply) error {
|
||||||
h.log.Debug("Health: GetLiveness called")
|
h.log.Info("Health: GetLiveness called")
|
||||||
reply.Checks, reply.Healthy = h.health.Results()
|
reply.Checks, reply.Healthy = h.health.Results()
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
|
@ -61,7 +61,7 @@ type PublishBlockchainReply struct {
|
||||||
|
|
||||||
// PublishBlockchain publishes the finalized accepted transactions from the blockchainID over the IPC
|
// PublishBlockchain publishes the finalized accepted transactions from the blockchainID over the IPC
|
||||||
func (ipc *IPCs) PublishBlockchain(r *http.Request, args *PublishBlockchainArgs, reply *PublishBlockchainReply) error {
|
func (ipc *IPCs) PublishBlockchain(r *http.Request, args *PublishBlockchainArgs, reply *PublishBlockchainReply) error {
|
||||||
ipc.log.Debug("IPCs: PublishBlockchain called with BlockchainID: %s", args.BlockchainID)
|
ipc.log.Info("IPCs: PublishBlockchain called with BlockchainID: %s", args.BlockchainID)
|
||||||
chainID, err := ipc.chainManager.Lookup(args.BlockchainID)
|
chainID, err := ipc.chainManager.Lookup(args.BlockchainID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
ipc.log.Error("unknown blockchainID: %s", err)
|
ipc.log.Error("unknown blockchainID: %s", err)
|
||||||
|
@ -117,7 +117,7 @@ type UnpublishBlockchainReply struct {
|
||||||
|
|
||||||
// UnpublishBlockchain closes publishing of a blockchainID
|
// UnpublishBlockchain closes publishing of a blockchainID
|
||||||
func (ipc *IPCs) UnpublishBlockchain(r *http.Request, args *UnpublishBlockchainArgs, reply *UnpublishBlockchainReply) error {
|
func (ipc *IPCs) UnpublishBlockchain(r *http.Request, args *UnpublishBlockchainArgs, reply *UnpublishBlockchainReply) error {
|
||||||
ipc.log.Debug("IPCs: UnpublishBlockchain called with BlockchainID: %s", args.BlockchainID)
|
ipc.log.Info("IPCs: UnpublishBlockchain called with BlockchainID: %s", args.BlockchainID)
|
||||||
chainID, err := ipc.chainManager.Lookup(args.BlockchainID)
|
chainID, err := ipc.chainManager.Lookup(args.BlockchainID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
ipc.log.Error("unknown blockchainID %s: %s", args.BlockchainID, err)
|
ipc.log.Error("unknown blockchainID %s: %s", args.BlockchainID, err)
|
||||||
|
|
|
@ -135,7 +135,7 @@ func (ks *Keystore) CreateUser(_ *http.Request, args *CreateUserArgs, reply *Cre
|
||||||
ks.lock.Lock()
|
ks.lock.Lock()
|
||||||
defer ks.lock.Unlock()
|
defer ks.lock.Unlock()
|
||||||
|
|
||||||
ks.log.Debug("Keystore: CreateUser called with %.*s", maxUserPassLen, args.Username)
|
ks.log.Info("Keystore: CreateUser called with %.*s", maxUserPassLen, args.Username)
|
||||||
|
|
||||||
if len(args.Username) > maxUserPassLen || len(args.Password) > maxUserPassLen {
|
if len(args.Username) > maxUserPassLen || len(args.Password) > maxUserPassLen {
|
||||||
return errUserPassMaxLength
|
return errUserPassMaxLength
|
||||||
|
@ -183,7 +183,7 @@ func (ks *Keystore) ListUsers(_ *http.Request, args *ListUsersArgs, reply *ListU
|
||||||
ks.lock.Lock()
|
ks.lock.Lock()
|
||||||
defer ks.lock.Unlock()
|
defer ks.lock.Unlock()
|
||||||
|
|
||||||
ks.log.Debug("Keystore: ListUsers called")
|
ks.log.Info("Keystore: ListUsers called")
|
||||||
|
|
||||||
reply.Users = []string{}
|
reply.Users = []string{}
|
||||||
|
|
||||||
|
@ -211,7 +211,7 @@ func (ks *Keystore) ExportUser(_ *http.Request, args *ExportUserArgs, reply *Exp
|
||||||
ks.lock.Lock()
|
ks.lock.Lock()
|
||||||
defer ks.lock.Unlock()
|
defer ks.lock.Unlock()
|
||||||
|
|
||||||
ks.log.Debug("Keystore: ExportUser called for %s", args.Username)
|
ks.log.Info("Keystore: ExportUser called for %s", args.Username)
|
||||||
|
|
||||||
usr, err := ks.getUser(args.Username)
|
usr, err := ks.getUser(args.Username)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -264,7 +264,7 @@ func (ks *Keystore) ImportUser(r *http.Request, args *ImportUserArgs, reply *Imp
|
||||||
ks.lock.Lock()
|
ks.lock.Lock()
|
||||||
defer ks.lock.Unlock()
|
defer ks.lock.Unlock()
|
||||||
|
|
||||||
ks.log.Debug("Keystore: ImportUser called for %s", args.Username)
|
ks.log.Info("Keystore: ImportUser called for %s", args.Username)
|
||||||
|
|
||||||
if args.Username == "" {
|
if args.Username == "" {
|
||||||
return errEmptyUsername
|
return errEmptyUsername
|
||||||
|
@ -324,7 +324,7 @@ func (ks *Keystore) DeleteUser(_ *http.Request, args *DeleteUserArgs, reply *Del
|
||||||
ks.lock.Lock()
|
ks.lock.Lock()
|
||||||
defer ks.lock.Unlock()
|
defer ks.lock.Unlock()
|
||||||
|
|
||||||
ks.log.Debug("Keystore: DeleteUser called with %s", args.Username)
|
ks.log.Info("Keystore: DeleteUser called with %s", args.Username)
|
||||||
|
|
||||||
if args.Username == "" {
|
if args.Username == "" {
|
||||||
return errEmptyUsername
|
return errEmptyUsername
|
||||||
|
|
|
@ -56,7 +56,7 @@ type IssueTxReply struct {
|
||||||
|
|
||||||
// IssueTx attempts to issue a transaction into consensus
|
// IssueTx attempts to issue a transaction into consensus
|
||||||
func (service *Service) IssueTx(r *http.Request, args *IssueTxArgs, reply *IssueTxReply) error {
|
func (service *Service) IssueTx(r *http.Request, args *IssueTxArgs, reply *IssueTxReply) error {
|
||||||
service.vm.ctx.Log.Debug("AVM: IssueTx called with %s", args.Tx)
|
service.vm.ctx.log.Info("AVM: IssueTx called with %s", args.Tx)
|
||||||
|
|
||||||
txID, err := service.vm.IssueTx(args.Tx.Bytes, nil)
|
txID, err := service.vm.IssueTx(args.Tx.Bytes, nil)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -79,7 +79,7 @@ type GetTxStatusReply struct {
|
||||||
|
|
||||||
// GetTxStatus returns the status of the specified transaction
|
// GetTxStatus returns the status of the specified transaction
|
||||||
func (service *Service) GetTxStatus(r *http.Request, args *GetTxStatusArgs, reply *GetTxStatusReply) error {
|
func (service *Service) GetTxStatus(r *http.Request, args *GetTxStatusArgs, reply *GetTxStatusReply) error {
|
||||||
service.vm.ctx.Log.Debug("AVM: GetTxStatus called with %s", args.TxID)
|
service.vm.ctx.log.Info("AVM: GetTxStatus called with %s", args.TxID)
|
||||||
|
|
||||||
if args.TxID.IsZero() {
|
if args.TxID.IsZero() {
|
||||||
return errNilTxID
|
return errNilTxID
|
||||||
|
@ -106,7 +106,7 @@ type GetTxReply struct {
|
||||||
|
|
||||||
// GetTx returns the specified transaction
|
// GetTx returns the specified transaction
|
||||||
func (service *Service) GetTx(r *http.Request, args *GetTxArgs, reply *GetTxReply) error {
|
func (service *Service) GetTx(r *http.Request, args *GetTxArgs, reply *GetTxReply) error {
|
||||||
service.vm.ctx.Log.Debug("AVM: GetTx called with %s", args.TxID)
|
service.vm.ctx.log.Info("AVM: GetTx called with %s", args.TxID)
|
||||||
|
|
||||||
if args.TxID.IsZero() {
|
if args.TxID.IsZero() {
|
||||||
return errNilTxID
|
return errNilTxID
|
||||||
|
@ -136,7 +136,7 @@ type GetUTXOsReply struct {
|
||||||
|
|
||||||
// GetUTXOs creates an empty account with the name passed in
|
// GetUTXOs creates an empty account with the name passed in
|
||||||
func (service *Service) GetUTXOs(r *http.Request, args *GetUTXOsArgs, reply *GetUTXOsReply) error {
|
func (service *Service) GetUTXOs(r *http.Request, args *GetUTXOsArgs, reply *GetUTXOsReply) error {
|
||||||
service.vm.ctx.Log.Debug("AVM: GetUTXOs called with %s", args.Addresses)
|
service.vm.ctx.log.Info("AVM: GetUTXOs called with %s", args.Addresses)
|
||||||
|
|
||||||
addrSet := ids.Set{}
|
addrSet := ids.Set{}
|
||||||
for _, addr := range args.Addresses {
|
for _, addr := range args.Addresses {
|
||||||
|
@ -178,7 +178,7 @@ type GetAssetDescriptionReply struct {
|
||||||
|
|
||||||
// GetAssetDescription creates an empty account with the name passed in
|
// GetAssetDescription creates an empty account with the name passed in
|
||||||
func (service *Service) GetAssetDescription(_ *http.Request, args *GetAssetDescriptionArgs, reply *GetAssetDescriptionReply) error {
|
func (service *Service) GetAssetDescription(_ *http.Request, args *GetAssetDescriptionArgs, reply *GetAssetDescriptionReply) error {
|
||||||
service.vm.ctx.Log.Debug("AVM: GetAssetDescription called with %s", args.AssetID)
|
service.vm.ctx.log.Info("AVM: GetAssetDescription called with %s", args.AssetID)
|
||||||
|
|
||||||
assetID, err := service.vm.Lookup(args.AssetID)
|
assetID, err := service.vm.Lookup(args.AssetID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -222,7 +222,7 @@ type GetBalanceReply struct {
|
||||||
|
|
||||||
// GetBalance returns the amount of an asset that an address at least partially owns
|
// GetBalance returns the amount of an asset that an address at least partially owns
|
||||||
func (service *Service) GetBalance(r *http.Request, args *GetBalanceArgs, reply *GetBalanceReply) error {
|
func (service *Service) GetBalance(r *http.Request, args *GetBalanceArgs, reply *GetBalanceReply) error {
|
||||||
service.vm.ctx.Log.Debug("AVM: GetBalance called with address: %s assetID: %s", args.Address, args.AssetID)
|
service.vm.ctx.log.Info("AVM: GetBalance called with address: %s assetID: %s", args.Address, args.AssetID)
|
||||||
|
|
||||||
address, err := service.vm.Parse(args.Address)
|
address, err := service.vm.Parse(args.Address)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -287,7 +287,7 @@ type GetAllBalancesReply struct {
|
||||||
// Note that balances include assets that the address only _partially_ owns
|
// Note that balances include assets that the address only _partially_ owns
|
||||||
// (ie is one of several addresses specified in a multi-sig)
|
// (ie is one of several addresses specified in a multi-sig)
|
||||||
func (service *Service) GetAllBalances(r *http.Request, args *GetAllBalancesArgs, reply *GetAllBalancesReply) error {
|
func (service *Service) GetAllBalances(r *http.Request, args *GetAllBalancesArgs, reply *GetAllBalancesReply) error {
|
||||||
service.vm.ctx.Log.Debug("AVM: GetAllBalances called with address: %s", args.Address)
|
service.vm.ctx.log.Info("AVM: GetAllBalances called with address: %s", args.Address)
|
||||||
|
|
||||||
address, err := service.vm.Parse(args.Address)
|
address, err := service.vm.Parse(args.Address)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -360,7 +360,7 @@ type CreateFixedCapAssetReply struct {
|
||||||
|
|
||||||
// CreateFixedCapAsset returns ID of the newly created asset
|
// CreateFixedCapAsset returns ID of the newly created asset
|
||||||
func (service *Service) CreateFixedCapAsset(r *http.Request, args *CreateFixedCapAssetArgs, reply *CreateFixedCapAssetReply) error {
|
func (service *Service) CreateFixedCapAsset(r *http.Request, args *CreateFixedCapAssetArgs, reply *CreateFixedCapAssetReply) error {
|
||||||
service.vm.ctx.Log.Debug("AVM: CreateFixedCapAsset called with name: %s symbol: %s number of holders: %d",
|
service.vm.ctx.log.Info("AVM: CreateFixedCapAsset called with name: %s symbol: %s number of holders: %d",
|
||||||
args.Name,
|
args.Name,
|
||||||
args.Symbol,
|
args.Symbol,
|
||||||
len(args.InitialHolders),
|
len(args.InitialHolders),
|
||||||
|
@ -445,7 +445,7 @@ type CreateVariableCapAssetReply struct {
|
||||||
|
|
||||||
// CreateVariableCapAsset returns ID of the newly created asset
|
// CreateVariableCapAsset returns ID of the newly created asset
|
||||||
func (service *Service) CreateVariableCapAsset(r *http.Request, args *CreateVariableCapAssetArgs, reply *CreateVariableCapAssetReply) error {
|
func (service *Service) CreateVariableCapAsset(r *http.Request, args *CreateVariableCapAssetArgs, reply *CreateVariableCapAssetReply) error {
|
||||||
service.vm.ctx.Log.Debug("AVM: CreateFixedCapAsset called with name: %s symbol: %s number of minters: %d",
|
service.vm.ctx.log.Info("AVM: CreateFixedCapAsset called with name: %s symbol: %s number of minters: %d",
|
||||||
args.Name,
|
args.Name,
|
||||||
args.Symbol,
|
args.Symbol,
|
||||||
len(args.MinterSets),
|
len(args.MinterSets),
|
||||||
|
@ -523,7 +523,7 @@ type CreateAddressReply struct {
|
||||||
|
|
||||||
// CreateAddress creates an address for the user [args.Username]
|
// CreateAddress creates an address for the user [args.Username]
|
||||||
func (service *Service) CreateAddress(r *http.Request, args *CreateAddressArgs, reply *CreateAddressReply) error {
|
func (service *Service) CreateAddress(r *http.Request, args *CreateAddressArgs, reply *CreateAddressReply) error {
|
||||||
service.vm.ctx.Log.Debug("AVM: CreateAddress called for user '%s'", args.Username)
|
service.vm.ctx.log.Info("AVM: CreateAddress called for user '%s'", args.Username)
|
||||||
|
|
||||||
db, err := service.vm.ctx.Keystore.GetDatabase(args.Username, args.Password)
|
db, err := service.vm.ctx.Keystore.GetDatabase(args.Username, args.Password)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -603,7 +603,7 @@ type ExportKeyReply struct {
|
||||||
|
|
||||||
// ExportKey returns a private key from the provided user
|
// ExportKey returns a private key from the provided user
|
||||||
func (service *Service) ExportKey(r *http.Request, args *ExportKeyArgs, reply *ExportKeyReply) error {
|
func (service *Service) ExportKey(r *http.Request, args *ExportKeyArgs, reply *ExportKeyReply) error {
|
||||||
service.vm.ctx.Log.Debug("AVM: ExportKey called for user '%s'", args.Username)
|
service.vm.ctx.log.Info("AVM: ExportKey called for user '%s'", args.Username)
|
||||||
|
|
||||||
address, err := service.vm.Parse(args.Address)
|
address, err := service.vm.Parse(args.Address)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -645,7 +645,7 @@ type ImportKeyReply struct {
|
||||||
|
|
||||||
// ImportKey adds a private key to the provided user
|
// ImportKey adds a private key to the provided user
|
||||||
func (service *Service) ImportKey(r *http.Request, args *ImportKeyArgs, reply *ImportKeyReply) error {
|
func (service *Service) ImportKey(r *http.Request, args *ImportKeyArgs, reply *ImportKeyReply) error {
|
||||||
service.vm.ctx.Log.Debug("AVM: ImportKey called for user '%s'", args.Username)
|
service.vm.ctx.log.Info("AVM: ImportKey called for user '%s'", args.Username)
|
||||||
|
|
||||||
db, err := service.vm.ctx.Keystore.GetDatabase(args.Username, args.Password)
|
db, err := service.vm.ctx.Keystore.GetDatabase(args.Username, args.Password)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -692,7 +692,7 @@ type SendReply struct {
|
||||||
|
|
||||||
// Send returns the ID of the newly created transaction
|
// Send returns the ID of the newly created transaction
|
||||||
func (service *Service) Send(r *http.Request, args *SendArgs, reply *SendReply) error {
|
func (service *Service) Send(r *http.Request, args *SendArgs, reply *SendReply) error {
|
||||||
service.vm.ctx.Log.Debug("AVM: Send called with username: %s", args.Username)
|
service.vm.ctx.log.Info("AVM: Send called with username: %s", args.Username)
|
||||||
|
|
||||||
if args.Amount == 0 {
|
if args.Amount == 0 {
|
||||||
return errInvalidAmount
|
return errInvalidAmount
|
||||||
|
@ -873,7 +873,7 @@ type CreateMintTxReply struct {
|
||||||
|
|
||||||
// CreateMintTx returns the newly created unsigned transaction
|
// CreateMintTx returns the newly created unsigned transaction
|
||||||
func (service *Service) CreateMintTx(r *http.Request, args *CreateMintTxArgs, reply *CreateMintTxReply) error {
|
func (service *Service) CreateMintTx(r *http.Request, args *CreateMintTxArgs, reply *CreateMintTxReply) error {
|
||||||
service.vm.ctx.Log.Debug("AVM: CreateMintTx called")
|
service.vm.ctx.log.Info("AVM: CreateMintTx called")
|
||||||
|
|
||||||
if args.Amount == 0 {
|
if args.Amount == 0 {
|
||||||
return errInvalidMintAmount
|
return errInvalidMintAmount
|
||||||
|
@ -990,7 +990,7 @@ type SignMintTxReply struct {
|
||||||
|
|
||||||
// SignMintTx returns the newly signed transaction
|
// SignMintTx returns the newly signed transaction
|
||||||
func (service *Service) SignMintTx(r *http.Request, args *SignMintTxArgs, reply *SignMintTxReply) error {
|
func (service *Service) SignMintTx(r *http.Request, args *SignMintTxArgs, reply *SignMintTxReply) error {
|
||||||
service.vm.ctx.Log.Debug("AVM: SignMintTx called")
|
service.vm.ctx.log.Info("AVM: SignMintTx called")
|
||||||
|
|
||||||
minter, err := service.vm.Parse(args.Minter)
|
minter, err := service.vm.Parse(args.Minter)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -1116,7 +1116,7 @@ type ImportAVAReply struct {
|
||||||
// The AVA must have already been exported from the P-Chain.
|
// The AVA must have already been exported from the P-Chain.
|
||||||
// Returns the ID of the newly created atomic transaction
|
// Returns the ID of the newly created atomic transaction
|
||||||
func (service *Service) ImportAVA(_ *http.Request, args *ImportAVAArgs, reply *ImportAVAReply) error {
|
func (service *Service) ImportAVA(_ *http.Request, args *ImportAVAArgs, reply *ImportAVAReply) error {
|
||||||
service.vm.ctx.Log.Debug("AVM: ImportAVA called with username: %s", args.Username)
|
service.vm.ctx.log.Info("AVM: ImportAVA called with username: %s", args.Username)
|
||||||
|
|
||||||
toBytes, err := service.vm.Parse(args.To)
|
toBytes, err := service.vm.Parse(args.To)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -1268,7 +1268,7 @@ type ExportAVAReply struct {
|
||||||
// After this tx is accepted, the AVA must be imported to the P-chain with an importTx.
|
// After this tx is accepted, the AVA must be imported to the P-chain with an importTx.
|
||||||
// Returns the ID of the newly created atomic transaction
|
// Returns the ID of the newly created atomic transaction
|
||||||
func (service *Service) ExportAVA(_ *http.Request, args *ExportAVAArgs, reply *ExportAVAReply) error {
|
func (service *Service) ExportAVA(_ *http.Request, args *ExportAVAArgs, reply *ExportAVAReply) error {
|
||||||
service.vm.ctx.Log.Debug("AVM: ExportAVA called with username: %s", args.Username)
|
service.vm.ctx.log.Info("AVM: ExportAVA called with username: %s", args.Username)
|
||||||
|
|
||||||
if args.Amount == 0 {
|
if args.Amount == 0 {
|
||||||
return errInvalidAmount
|
return errInvalidAmount
|
||||||
|
|
|
@ -234,7 +234,7 @@ type GetCurrentValidatorsReply struct {
|
||||||
|
|
||||||
// GetCurrentValidators returns the list of current validators
|
// GetCurrentValidators returns the list of current validators
|
||||||
func (service *Service) GetCurrentValidators(_ *http.Request, args *GetCurrentValidatorsArgs, reply *GetCurrentValidatorsReply) error {
|
func (service *Service) GetCurrentValidators(_ *http.Request, args *GetCurrentValidatorsArgs, reply *GetCurrentValidatorsReply) error {
|
||||||
service.vm.Ctx.Log.Debug("Platform: GetCurrentValidators called")
|
service.vm.Ctx.log.Info("Platform: GetCurrentValidators called")
|
||||||
|
|
||||||
if args.SubnetID.IsZero() {
|
if args.SubnetID.IsZero() {
|
||||||
args.SubnetID = DefaultSubnetID
|
args.SubnetID = DefaultSubnetID
|
||||||
|
@ -298,7 +298,7 @@ type GetPendingValidatorsReply struct {
|
||||||
|
|
||||||
// GetPendingValidators returns the list of current validators
|
// GetPendingValidators returns the list of current validators
|
||||||
func (service *Service) GetPendingValidators(_ *http.Request, args *GetPendingValidatorsArgs, reply *GetPendingValidatorsReply) error {
|
func (service *Service) GetPendingValidators(_ *http.Request, args *GetPendingValidatorsArgs, reply *GetPendingValidatorsReply) error {
|
||||||
service.vm.Ctx.Log.Debug("Platform: GetPendingValidators called")
|
service.vm.Ctx.log.Info("Platform: GetPendingValidators called")
|
||||||
|
|
||||||
if args.SubnetID.IsZero() {
|
if args.SubnetID.IsZero() {
|
||||||
args.SubnetID = DefaultSubnetID
|
args.SubnetID = DefaultSubnetID
|
||||||
|
@ -360,7 +360,7 @@ type SampleValidatorsReply struct {
|
||||||
|
|
||||||
// SampleValidators returns a sampling of the list of current validators
|
// SampleValidators returns a sampling of the list of current validators
|
||||||
func (service *Service) SampleValidators(_ *http.Request, args *SampleValidatorsArgs, reply *SampleValidatorsReply) error {
|
func (service *Service) SampleValidators(_ *http.Request, args *SampleValidatorsArgs, reply *SampleValidatorsReply) error {
|
||||||
service.vm.Ctx.Log.Debug("Platform: SampleValidators called with {Size = %d}", args.Size)
|
service.vm.Ctx.log.Info("Platform: SampleValidators called with {Size = %d}", args.Size)
|
||||||
|
|
||||||
if args.SubnetID.IsZero() {
|
if args.SubnetID.IsZero() {
|
||||||
args.SubnetID = DefaultSubnetID
|
args.SubnetID = DefaultSubnetID
|
||||||
|
@ -437,7 +437,7 @@ type ListAccountsReply struct {
|
||||||
|
|
||||||
// ListAccounts lists all of the accounts controlled by [args.Username]
|
// ListAccounts lists all of the accounts controlled by [args.Username]
|
||||||
func (service *Service) ListAccounts(_ *http.Request, args *ListAccountsArgs, reply *ListAccountsReply) error {
|
func (service *Service) ListAccounts(_ *http.Request, args *ListAccountsArgs, reply *ListAccountsReply) error {
|
||||||
service.vm.Ctx.Log.Debug("Platform: ListAccounts called for user '%s'", args.Username)
|
service.vm.Ctx.log.Info("Platform: ListAccounts called for user '%s'", args.Username)
|
||||||
|
|
||||||
// db holds the user's info that pertains to the Platform Chain
|
// db holds the user's info that pertains to the Platform Chain
|
||||||
userDB, err := service.vm.Ctx.Keystore.GetDatabase(args.Username, args.Password)
|
userDB, err := service.vm.Ctx.Keystore.GetDatabase(args.Username, args.Password)
|
||||||
|
@ -499,7 +499,7 @@ type CreateAccountReply struct {
|
||||||
// The account's ID is [privKey].PublicKey().Address(), where [privKey] is a
|
// The account's ID is [privKey].PublicKey().Address(), where [privKey] is a
|
||||||
// private key controlled by the user.
|
// private key controlled by the user.
|
||||||
func (service *Service) CreateAccount(_ *http.Request, args *CreateAccountArgs, reply *CreateAccountReply) error {
|
func (service *Service) CreateAccount(_ *http.Request, args *CreateAccountArgs, reply *CreateAccountReply) error {
|
||||||
service.vm.Ctx.Log.Debug("Platform: CreateAccount called for user '%s'", args.Username)
|
service.vm.Ctx.log.Info("Platform: CreateAccount called for user '%s'", args.Username)
|
||||||
|
|
||||||
// userDB holds the user's info that pertains to the Platform Chain
|
// userDB holds the user's info that pertains to the Platform Chain
|
||||||
userDB, err := service.vm.Ctx.Keystore.GetDatabase(args.Username, args.Password)
|
userDB, err := service.vm.Ctx.Keystore.GetDatabase(args.Username, args.Password)
|
||||||
|
@ -569,7 +569,7 @@ type AddDefaultSubnetValidatorArgs struct {
|
||||||
// AddDefaultSubnetValidator returns an unsigned transaction to add a validator to the default subnet
|
// AddDefaultSubnetValidator returns an unsigned transaction to add a validator to the default subnet
|
||||||
// The returned unsigned transaction should be signed using Sign()
|
// The returned unsigned transaction should be signed using Sign()
|
||||||
func (service *Service) AddDefaultSubnetValidator(_ *http.Request, args *AddDefaultSubnetValidatorArgs, reply *CreateTxResponse) error {
|
func (service *Service) AddDefaultSubnetValidator(_ *http.Request, args *AddDefaultSubnetValidatorArgs, reply *CreateTxResponse) error {
|
||||||
service.vm.Ctx.Log.Debug("Platform: AddDefaultSubnetValidator called")
|
service.vm.Ctx.log.Info("Platform: AddDefaultSubnetValidator called")
|
||||||
|
|
||||||
switch {
|
switch {
|
||||||
case args.ID.IsZero(): // If ID unspecified, use this node's ID as validator ID
|
case args.ID.IsZero(): // If ID unspecified, use this node's ID as validator ID
|
||||||
|
@ -626,7 +626,7 @@ type AddDefaultSubnetDelegatorArgs struct {
|
||||||
// to the default subnet
|
// to the default subnet
|
||||||
// The returned unsigned transaction should be signed using Sign()
|
// The returned unsigned transaction should be signed using Sign()
|
||||||
func (service *Service) AddDefaultSubnetDelegator(_ *http.Request, args *AddDefaultSubnetDelegatorArgs, reply *CreateTxResponse) error {
|
func (service *Service) AddDefaultSubnetDelegator(_ *http.Request, args *AddDefaultSubnetDelegatorArgs, reply *CreateTxResponse) error {
|
||||||
service.vm.Ctx.Log.Debug("Platform: AddDefaultSubnetDelegator called")
|
service.vm.Ctx.log.Info("Platform: AddDefaultSubnetDelegator called")
|
||||||
|
|
||||||
switch {
|
switch {
|
||||||
case args.ID.IsZero(): // If ID unspecified, use this node's ID as validator ID
|
case args.ID.IsZero(): // If ID unspecified, use this node's ID as validator ID
|
||||||
|
@ -741,7 +741,7 @@ type CreateSubnetArgs struct {
|
||||||
// CreateSubnet returns an unsigned transaction to create a new subnet.
|
// CreateSubnet returns an unsigned transaction to create a new subnet.
|
||||||
// The unsigned transaction must be signed with the key of [args.Payer]
|
// The unsigned transaction must be signed with the key of [args.Payer]
|
||||||
func (service *Service) CreateSubnet(_ *http.Request, args *CreateSubnetArgs, response *CreateTxResponse) error {
|
func (service *Service) CreateSubnet(_ *http.Request, args *CreateSubnetArgs, response *CreateTxResponse) error {
|
||||||
service.vm.Ctx.Log.Debug("Platform: CreateSubnet called")
|
service.vm.Ctx.log.Info("Platform: CreateSubnet called")
|
||||||
|
|
||||||
switch {
|
switch {
|
||||||
case args.PayerNonce == 0:
|
case args.PayerNonce == 0:
|
||||||
|
@ -796,7 +796,7 @@ type ExportAVAArgs struct {
|
||||||
// The unsigned transaction must be signed with the key of the account exporting the AVA
|
// The unsigned transaction must be signed with the key of the account exporting the AVA
|
||||||
// and paying the transaction fee
|
// and paying the transaction fee
|
||||||
func (service *Service) ExportAVA(_ *http.Request, args *ExportAVAArgs, response *CreateTxResponse) error {
|
func (service *Service) ExportAVA(_ *http.Request, args *ExportAVAArgs, response *CreateTxResponse) error {
|
||||||
service.vm.Ctx.Log.Debug("Platform: ExportAVA called")
|
service.vm.Ctx.log.Info("Platform: ExportAVA called")
|
||||||
|
|
||||||
switch {
|
switch {
|
||||||
case args.PayerNonce == 0:
|
case args.PayerNonce == 0:
|
||||||
|
@ -858,7 +858,7 @@ type SignResponse struct {
|
||||||
|
|
||||||
// Sign [args.bytes]
|
// Sign [args.bytes]
|
||||||
func (service *Service) Sign(_ *http.Request, args *SignArgs, reply *SignResponse) error {
|
func (service *Service) Sign(_ *http.Request, args *SignArgs, reply *SignResponse) error {
|
||||||
service.vm.Ctx.Log.Debug("Platform: Sign called")
|
service.vm.Ctx.log.Info("Platform: Sign called")
|
||||||
|
|
||||||
if args.Signer == "" {
|
if args.Signer == "" {
|
||||||
return errNilSigner
|
return errNilSigner
|
||||||
|
@ -915,7 +915,7 @@ func (service *Service) Sign(_ *http.Request, args *SignArgs, reply *SignRespons
|
||||||
|
|
||||||
// Sign [unsigned] with [key]
|
// Sign [unsigned] with [key]
|
||||||
func (service *Service) signAddDefaultSubnetValidatorTx(tx *addDefaultSubnetValidatorTx, key *crypto.PrivateKeySECP256K1R) (*addDefaultSubnetValidatorTx, error) {
|
func (service *Service) signAddDefaultSubnetValidatorTx(tx *addDefaultSubnetValidatorTx, key *crypto.PrivateKeySECP256K1R) (*addDefaultSubnetValidatorTx, error) {
|
||||||
service.vm.Ctx.Log.Debug("Platform: signAddDefaultSubnetValidatorTx called")
|
service.vm.Ctx.log.Info("Platform: signAddDefaultSubnetValidatorTx called")
|
||||||
|
|
||||||
// TODO: Should we check if tx is already signed?
|
// TODO: Should we check if tx is already signed?
|
||||||
unsignedIntf := interface{}(&tx.UnsignedAddDefaultSubnetValidatorTx)
|
unsignedIntf := interface{}(&tx.UnsignedAddDefaultSubnetValidatorTx)
|
||||||
|
@ -938,7 +938,7 @@ func (service *Service) signAddDefaultSubnetValidatorTx(tx *addDefaultSubnetVali
|
||||||
|
|
||||||
// Sign [unsigned] with [key]
|
// Sign [unsigned] with [key]
|
||||||
func (service *Service) signAddDefaultSubnetDelegatorTx(tx *addDefaultSubnetDelegatorTx, key *crypto.PrivateKeySECP256K1R) (*addDefaultSubnetDelegatorTx, error) {
|
func (service *Service) signAddDefaultSubnetDelegatorTx(tx *addDefaultSubnetDelegatorTx, key *crypto.PrivateKeySECP256K1R) (*addDefaultSubnetDelegatorTx, error) {
|
||||||
service.vm.Ctx.Log.Debug("Platform: signAddDefaultSubnetDelegatorTx called")
|
service.vm.Ctx.log.Info("Platform: signAddDefaultSubnetDelegatorTx called")
|
||||||
|
|
||||||
// TODO: Should we check if tx is already signed?
|
// TODO: Should we check if tx is already signed?
|
||||||
unsignedIntf := interface{}(&tx.UnsignedAddDefaultSubnetDelegatorTx)
|
unsignedIntf := interface{}(&tx.UnsignedAddDefaultSubnetDelegatorTx)
|
||||||
|
@ -961,7 +961,7 @@ func (service *Service) signAddDefaultSubnetDelegatorTx(tx *addDefaultSubnetDele
|
||||||
|
|
||||||
// Sign [xt] with [key]
|
// Sign [xt] with [key]
|
||||||
func (service *Service) signCreateSubnetTx(tx *CreateSubnetTx, key *crypto.PrivateKeySECP256K1R) (*CreateSubnetTx, error) {
|
func (service *Service) signCreateSubnetTx(tx *CreateSubnetTx, key *crypto.PrivateKeySECP256K1R) (*CreateSubnetTx, error) {
|
||||||
service.vm.Ctx.Log.Debug("Platform: signCreateSubnetTx called")
|
service.vm.Ctx.log.Info("Platform: signCreateSubnetTx called")
|
||||||
|
|
||||||
// TODO: Should we check if tx is already signed?
|
// TODO: Should we check if tx is already signed?
|
||||||
unsignedIntf := interface{}(&tx.UnsignedCreateSubnetTx)
|
unsignedIntf := interface{}(&tx.UnsignedCreateSubnetTx)
|
||||||
|
@ -984,7 +984,7 @@ func (service *Service) signCreateSubnetTx(tx *CreateSubnetTx, key *crypto.Priva
|
||||||
|
|
||||||
// Sign [tx] with [key]
|
// Sign [tx] with [key]
|
||||||
func (service *Service) signExportTx(tx *ExportTx, key *crypto.PrivateKeySECP256K1R) (*ExportTx, error) {
|
func (service *Service) signExportTx(tx *ExportTx, key *crypto.PrivateKeySECP256K1R) (*ExportTx, error) {
|
||||||
service.vm.Ctx.Log.Debug("Platform: signExportTx called")
|
service.vm.Ctx.log.Info("Platform: signExportTx called")
|
||||||
|
|
||||||
// TODO: Should we check if tx is already signed?
|
// TODO: Should we check if tx is already signed?
|
||||||
unsignedIntf := interface{}(&tx.UnsignedExportTx)
|
unsignedIntf := interface{}(&tx.UnsignedExportTx)
|
||||||
|
@ -1012,7 +1012,7 @@ func (service *Service) signExportTx(tx *ExportTx, key *crypto.PrivateKeySECP256
|
||||||
// Sorts tx.ControlSigs before returning
|
// Sorts tx.ControlSigs before returning
|
||||||
// Assumes each element of tx.ControlSigs is actually a signature, not just empty bytes
|
// Assumes each element of tx.ControlSigs is actually a signature, not just empty bytes
|
||||||
func (service *Service) signAddNonDefaultSubnetValidatorTx(tx *addNonDefaultSubnetValidatorTx, key *crypto.PrivateKeySECP256K1R) (*addNonDefaultSubnetValidatorTx, error) {
|
func (service *Service) signAddNonDefaultSubnetValidatorTx(tx *addNonDefaultSubnetValidatorTx, key *crypto.PrivateKeySECP256K1R) (*addNonDefaultSubnetValidatorTx, error) {
|
||||||
service.vm.Ctx.Log.Debug("Platform: signAddNonDefaultSubnetValidatorTx called")
|
service.vm.Ctx.log.Info("Platform: signAddNonDefaultSubnetValidatorTx called")
|
||||||
|
|
||||||
// Compute the byte repr. of the unsigned tx and the signature of [key] over it
|
// Compute the byte repr. of the unsigned tx and the signature of [key] over it
|
||||||
unsignedIntf := interface{}(&tx.UnsignedAddNonDefaultSubnetValidatorTx)
|
unsignedIntf := interface{}(&tx.UnsignedAddNonDefaultSubnetValidatorTx)
|
||||||
|
@ -1075,7 +1075,7 @@ type ImportAVAArgs struct {
|
||||||
// The AVA must have already been exported from the X-Chain.
|
// The AVA must have already been exported from the X-Chain.
|
||||||
// The unsigned transaction must be signed with the key of the tx fee payer.
|
// The unsigned transaction must be signed with the key of the tx fee payer.
|
||||||
func (service *Service) ImportAVA(_ *http.Request, args *ImportAVAArgs, response *SignResponse) error {
|
func (service *Service) ImportAVA(_ *http.Request, args *ImportAVAArgs, response *SignResponse) error {
|
||||||
service.vm.Ctx.Log.Debug("Platform: ImportAVA called")
|
service.vm.Ctx.log.Info("Platform: ImportAVA called")
|
||||||
|
|
||||||
switch {
|
switch {
|
||||||
case args.To == "":
|
case args.To == "":
|
||||||
|
@ -1203,7 +1203,7 @@ func (service *Service) ImportAVA(_ *http.Request, args *ImportAVAArgs, response
|
||||||
// Sorts tx.ControlSigs before returning
|
// Sorts tx.ControlSigs before returning
|
||||||
// Assumes each element of tx.ControlSigs is actually a signature, not just empty bytes
|
// Assumes each element of tx.ControlSigs is actually a signature, not just empty bytes
|
||||||
func (service *Service) signCreateChainTx(tx *CreateChainTx, key *crypto.PrivateKeySECP256K1R) (*CreateChainTx, error) {
|
func (service *Service) signCreateChainTx(tx *CreateChainTx, key *crypto.PrivateKeySECP256K1R) (*CreateChainTx, error) {
|
||||||
service.vm.Ctx.Log.Debug("Platform: signCreateChainTx called")
|
service.vm.Ctx.log.Info("Platform: signCreateChainTx called")
|
||||||
|
|
||||||
// Compute the byte repr. of the unsigned tx and the signature of [key] over it
|
// Compute the byte repr. of the unsigned tx and the signature of [key] over it
|
||||||
unsignedIntf := interface{}(&tx.UnsignedCreateChainTx)
|
unsignedIntf := interface{}(&tx.UnsignedCreateChainTx)
|
||||||
|
@ -1263,7 +1263,7 @@ type IssueTxResponse struct {
|
||||||
|
|
||||||
// IssueTx issues the transaction [args.Tx] to the network
|
// IssueTx issues the transaction [args.Tx] to the network
|
||||||
func (service *Service) IssueTx(_ *http.Request, args *IssueTxArgs, response *IssueTxResponse) error {
|
func (service *Service) IssueTx(_ *http.Request, args *IssueTxArgs, response *IssueTxResponse) error {
|
||||||
service.vm.Ctx.Log.Debug("Platform: IssueTx called")
|
service.vm.Ctx.log.Info("Platform: IssueTx called")
|
||||||
|
|
||||||
genTx := genericTx{}
|
genTx := genericTx{}
|
||||||
if err := Codec.Unmarshal(args.Tx.Bytes, &genTx); err != nil {
|
if err := Codec.Unmarshal(args.Tx.Bytes, &genTx); err != nil {
|
||||||
|
@ -1327,7 +1327,7 @@ type CreateBlockchainArgs struct {
|
||||||
// CreateBlockchain returns an unsigned transaction to create a new blockchain
|
// CreateBlockchain returns an unsigned transaction to create a new blockchain
|
||||||
// Must be signed with the Subnet's control keys and with a key that pays the transaction fee before issuance
|
// Must be signed with the Subnet's control keys and with a key that pays the transaction fee before issuance
|
||||||
func (service *Service) CreateBlockchain(_ *http.Request, args *CreateBlockchainArgs, response *CreateTxResponse) error {
|
func (service *Service) CreateBlockchain(_ *http.Request, args *CreateBlockchainArgs, response *CreateTxResponse) error {
|
||||||
service.vm.Ctx.Log.Debug("Platform: CreateBlockchain called")
|
service.vm.Ctx.log.Info("Platform: CreateBlockchain called")
|
||||||
|
|
||||||
switch {
|
switch {
|
||||||
case args.PayerNonce == 0:
|
case args.PayerNonce == 0:
|
||||||
|
@ -1410,7 +1410,7 @@ type GetBlockchainStatusReply struct {
|
||||||
|
|
||||||
// GetBlockchainStatus gets the status of a blockchain with the ID [args.BlockchainID].
|
// GetBlockchainStatus gets the status of a blockchain with the ID [args.BlockchainID].
|
||||||
func (service *Service) GetBlockchainStatus(_ *http.Request, args *GetBlockchainStatusArgs, reply *GetBlockchainStatusReply) error {
|
func (service *Service) GetBlockchainStatus(_ *http.Request, args *GetBlockchainStatusArgs, reply *GetBlockchainStatusReply) error {
|
||||||
service.vm.Ctx.Log.Debug("Platform: GetBlockchainStatus called")
|
service.vm.Ctx.log.Info("Platform: GetBlockchainStatus called")
|
||||||
|
|
||||||
switch {
|
switch {
|
||||||
case args.BlockchainID == "":
|
case args.BlockchainID == "":
|
||||||
|
@ -1490,7 +1490,7 @@ type ValidatedByResponse struct {
|
||||||
|
|
||||||
// ValidatedBy returns the ID of the Subnet that validates [args.BlockchainID]
|
// ValidatedBy returns the ID of the Subnet that validates [args.BlockchainID]
|
||||||
func (service *Service) ValidatedBy(_ *http.Request, args *ValidatedByArgs, response *ValidatedByResponse) error {
|
func (service *Service) ValidatedBy(_ *http.Request, args *ValidatedByArgs, response *ValidatedByResponse) error {
|
||||||
service.vm.Ctx.Log.Debug("Platform: ValidatedBy called")
|
service.vm.Ctx.log.Info("Platform: ValidatedBy called")
|
||||||
|
|
||||||
switch {
|
switch {
|
||||||
case args.BlockchainID == "":
|
case args.BlockchainID == "":
|
||||||
|
@ -1522,7 +1522,7 @@ type ValidatesResponse struct {
|
||||||
|
|
||||||
// Validates returns the IDs of the blockchains validated by [args.SubnetID]
|
// Validates returns the IDs of the blockchains validated by [args.SubnetID]
|
||||||
func (service *Service) Validates(_ *http.Request, args *ValidatesArgs, response *ValidatesResponse) error {
|
func (service *Service) Validates(_ *http.Request, args *ValidatesArgs, response *ValidatesResponse) error {
|
||||||
service.vm.Ctx.Log.Debug("Platform: Validates called")
|
service.vm.Ctx.log.Info("Platform: Validates called")
|
||||||
|
|
||||||
switch {
|
switch {
|
||||||
case args.SubnetID == "":
|
case args.SubnetID == "":
|
||||||
|
@ -1576,7 +1576,7 @@ type GetBlockchainsResponse struct {
|
||||||
|
|
||||||
// GetBlockchains returns all of the blockchains that exist
|
// GetBlockchains returns all of the blockchains that exist
|
||||||
func (service *Service) GetBlockchains(_ *http.Request, args *struct{}, response *GetBlockchainsResponse) error {
|
func (service *Service) GetBlockchains(_ *http.Request, args *struct{}, response *GetBlockchainsResponse) error {
|
||||||
service.vm.Ctx.Log.Debug("Platform: GetBlockchains called")
|
service.vm.Ctx.log.Info("Platform: GetBlockchains called")
|
||||||
|
|
||||||
chains, err := service.vm.getChains(service.vm.DB)
|
chains, err := service.vm.getChains(service.vm.DB)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|
Loading…
Reference in New Issue