TrueCloudLab/frostfs-node
20
1
Fork 28
Code Issues 106 Pull requests 4 Projects Releases 2 Activity Actions

Make listing chains with generated wallet #1638

Closed
aarifullin wants to merge 2 commits from aarifullin/frostfs-node:fix/apemngr_list_chain into master
pull from: aarifullin/frostfs-node:fix/apemngr_list_chain
merge into: TrueCloudLab:master
Conversation 4 Commits 2 Files changed 2 +5 -9
2 changed files with 5 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
cmd/frostfs-cli/modules/ape_manager/list_chain.go
View file

@ -23,7 +23,7 @@ var listCmd = &cobra.Command{
func list(cmd *cobra.Command, _ []string) { func list(cmd *cobra.Command, _ []string) {
target := parseTarget(cmd) target := parseTarget(cmd)
key := key.Get(cmd) key := key.GetOrGenerate(cmd)
cli := internalclient.GetSDKClientByFlag(cmd, key, commonflags.RPC) cli := internalclient.GetSDKClientByFlag(cmd, key, commonflags.RPC)
resp, err := cli.APEManagerListChains(cmd.Context(), resp, err := cli.APEManagerListChains(cmd.Context(),

12
pkg/services/apemanager/executor.go
View file

@ -177,19 +177,15 @@ func (s *Service) RemoveChain(ctx context.Context, req *apemanagerV2.RemoveChain
return resp, nil return resp, nil
} }
func (s *Service) ListChains(ctx context.Context, req *apemanagerV2.ListChainsRequest) (*apemanagerV2.ListChainsResponse, error) { func (s *Service) ListChains(_ context.Context, req *apemanagerV2.ListChainsRequest) (*apemanagerV2.ListChainsResponse, error) {
pub, err := getSignaturePublicKey(req.GetVerificationHeader())
if err != nil {
return nil, err
}
var target policy_engine.Target var target policy_engine.Target
switch targetType := req.GetBody().GetTarget().GetTargetType(); targetType { switch targetType := req.GetBody().GetTarget().GetTargetType(); targetType {
case apeV2.TargetTypeContainer: case apeV2.TargetTypeContainer:
reqCID := req.GetBody().GetTarget().GetName() reqCID := req.GetBody().GetTarget().GetName()
if err = s.validateContainerTargetRequest(ctx, reqCID, pub); err != nil { var cidSDK cidSDK.ID
return nil, err if err := cidSDK.DecodeString(reqCID); err != nil {
return nil, fmt.Errorf("invalid CID format: %w", err)
} }
target = policy_engine.ContainerTarget(reqCID) target = policy_engine.ContainerTarget(reqCID)
default: default: