forked from TrueCloudLab/frostfs-sdk-go
117 lines
3.5 KiB
Go
117 lines
3.5 KiB
Go
package client_test
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/nspcc-dev/neo-go/pkg/crypto/keys"
|
|
netmapv2 "github.com/nspcc-dev/neofs-api-go/v2/netmap"
|
|
"github.com/nspcc-dev/neofs-sdk-go/client"
|
|
"github.com/nspcc-dev/neofs-sdk-go/container"
|
|
"github.com/nspcc-dev/neofs-sdk-go/container/acl"
|
|
cid "github.com/nspcc-dev/neofs-sdk-go/container/id"
|
|
neofsecdsa "github.com/nspcc-dev/neofs-sdk-go/crypto/ecdsa"
|
|
"github.com/nspcc-dev/neofs-sdk-go/netmap"
|
|
"github.com/nspcc-dev/neofs-sdk-go/user"
|
|
)
|
|
|
|
func ExampleClient_ContainerPut() {
|
|
ctx := context.Background()
|
|
var accountID user.ID
|
|
|
|
// The account was taken from https://github.com/nspcc-dev/neofs-aio
|
|
key, err := keys.NEP2Decrypt("6PYM8VdX2BSm7BSXKzV4Fz6S3R9cDLLWNrD9nMjxW352jEv3fsC8N3wNLY", "one", keys.NEP2ScryptParams())
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
signer := neofsecdsa.SignerRFC6979(key.PrivateKey)
|
|
|
|
// decode account from user's signer
|
|
if err = user.IDFromSigner(&accountID, signer); err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
// prepare client
|
|
var prmInit client.PrmInit
|
|
prmInit.SetDefaultSigner(signer) // private signer for request signing
|
|
prmInit.ResolveNeoFSFailures() // enable erroneous status parsing
|
|
|
|
var c client.Client
|
|
c.Init(prmInit)
|
|
|
|
// connect to NeoFS gateway
|
|
var prmDial client.PrmDial
|
|
prmDial.SetServerURI("grpc://localhost:8080") // endpoint address
|
|
prmDial.SetTimeout(15 * time.Second)
|
|
prmDial.SetStreamTimeout(15 * time.Second)
|
|
|
|
if err = c.Dial(prmDial); err != nil {
|
|
panic(fmt.Errorf("dial %v", err))
|
|
}
|
|
|
|
// describe new container
|
|
cont := container.Container{}
|
|
// set version and nonce
|
|
cont.Init()
|
|
cont.SetOwner(accountID)
|
|
cont.SetBasicACL(acl.PublicRW)
|
|
|
|
// set reserved attributes
|
|
container.SetName(&cont, "name-1")
|
|
container.SetCreationTime(&cont, time.Now().UTC())
|
|
|
|
// init placement policy
|
|
var containerID cid.ID
|
|
var placementPolicyV2 netmapv2.PlacementPolicy
|
|
var replicas []netmapv2.Replica
|
|
|
|
replica := netmapv2.Replica{}
|
|
replica.SetCount(1)
|
|
replicas = append(replicas, replica)
|
|
placementPolicyV2.SetReplicas(replicas)
|
|
|
|
var placementPolicy netmap.PlacementPolicy
|
|
if err = placementPolicy.ReadFromV2(placementPolicyV2); err != nil {
|
|
panic(fmt.Errorf("ReadFromV2 %w", err))
|
|
}
|
|
|
|
placementPolicy.SetContainerBackupFactor(1)
|
|
cont.SetPlacementPolicy(placementPolicy)
|
|
|
|
// prepare command to create container
|
|
var prmCon client.PrmContainerPut
|
|
prmCon.SetContainer(cont)
|
|
|
|
putResult, err := c.ContainerPut(ctx, prmCon)
|
|
if err != nil {
|
|
panic(fmt.Errorf("ContainerPut %w", err))
|
|
}
|
|
|
|
// containerID already exists
|
|
containerID = putResult.ID()
|
|
fmt.Println(containerID)
|
|
// example output: 76wa5UNiT8gk8Q5rdCVCV4pKuZSmYsifh6g84BcL6Hqs
|
|
|
|
// but container creation is async operation. We should wait some time or make polling to ensure container created
|
|
// for simplifying we just wait
|
|
<-time.After(2 * time.Second)
|
|
|
|
// take our created container
|
|
var cmdGet client.PrmContainerGet
|
|
cmdGet.SetContainer(containerID)
|
|
|
|
getResp, err := c.ContainerGet(ctx, cmdGet)
|
|
if err != nil {
|
|
panic(fmt.Errorf("ContainerGet %w", err))
|
|
}
|
|
|
|
jsonData, err := getResp.Container().MarshalJSON()
|
|
if err != nil {
|
|
panic(fmt.Errorf("MarshalJSON %w", err))
|
|
}
|
|
|
|
fmt.Println(string(jsonData))
|
|
// example output: {"version":{"major":2,"minor":13},"ownerID":{"value":"Ne6eoiwn40vQFI/EEI4I906PUEiy8ZXKcw=="},"nonce":"rPVd/iw2RW6Q6d66FVnIqg==","basicACL":532660223,"attributes":[{"key":"Name","value":"name-1"},{"key":"Timestamp","value":"1681738627"}],"placementPolicy":{"replicas":[{"count":1,"selector":""}],"containerBackupFactor":1,"selectors":[],"filters":[],"subnetId":{"value":0}}}
|
|
}
|