Sprint5 chain

core/chain/chain.go

@@ -55,7 +55,9 @@ type Chain interface {
  // Register is used to register OSS or BUCKET roles
  Register(name, multiaddr string, income string, pledge uint64) (string, error)
  // Update is used to update the communication address of the scheduling service
- Update(name, multiaddr string) (string, error)
+ UpdateAddress(name, multiaddr string) (string, error)
+ //
+ UpdateIncomeAccount(pubkey []byte) (string, error)
  // CreateBucket is used to create a bucket for users
  CreateBucket(owner_pkey []byte, name string) (string, error)
  // DeleteBucket is used to delete buckets created by users
@@ -78,6 +80,10 @@ type Chain interface {
  QueryUserSpaceInfo(pubkey []byte) (UserSpaceInfo, error)
  //
  IncreaseStakes(tokens *big.Int) (string, error)
+ //
+ Exit(role string) (string, error)
+ //
+ QuerySpacePricePerGib() (string, error)
 }
 
 type chainClient struct {

core/chain/events.go

@@ -345,6 +345,12 @@ type Event_OssUpdate struct {
  Topics []types.Hash
 }
 
+type Event_OssDestroy struct {
+ Phase types.Phase
+ Acc types.AccountID
+ Topics []types.Hash
+}
+
 // ------------------------System------------------------
 type Event_UnsignedPhaseStarted struct {
  Phase types.Phase
@@ -430,6 +436,7 @@ type EventRecords struct {
  // OSS
  Oss_OssRegister []Event_OssRegister
  Oss_OssUpdate []Event_OssUpdate
+ Oss_OssDestroy []Event_OssDestroy
  // System
  types.EventRecords
 }

core/chain/state.go

@@ -7,6 +7,7 @@
 package chain
 
 import (
+ "fmt"
  "log"
 
  "github.com/CESSProject/sdk-go/core/utils"
@@ -563,6 +564,40 @@ func (c *chainClient) QueryUserSpaceInfo(pubkey []byte) (UserSpaceInfo, error) {
  return data, nil
 }
 
+func (c *chainClient) QuerySpacePricePerGib() (string, error) {
+ defer func() {
+ if err := recover(); err != nil {
+ println(utils.RecoverError(err))
+ }
+ }()
+ var data types.U128
+
+ if !c.IsChainClientOk() {
+ c.SetChainState(false)
+ return "", ERR_RPC_CONNECTION
+ }
+ c.SetChainState(true)
+
+ key, err := types.CreateStorageKey(
+ c.metadata,
+ STORAGEHANDLER,
+ UNITPRICE,
+ )
+ if err != nil {
+ return "", errors.Wrap(err, "[CreateStorageKey]")
+ }
+
+ ok, err := c.api.RPC.State.GetStorageLatest(key, &data)
+ if err != nil {
+ return "", errors.Wrap(err, "[GetStorageLatest]")
+ }
+ if !ok {
+ return "", ERR_RPC_EMPTY_VALUE
+ }
+
+ return fmt.Sprintf("%v", data), nil
+}
+
 // Pallert
 const (
  _FILEBANK = "FileBank"