Skip to content

Commit 1986314

Browse files
authored
feat(ipfs): add list-pins command in scaleway cli (#1678)
1 parent fbb6292 commit 1986314

File tree

1 file changed

+6
-142
lines changed

1 file changed

+6
-142
lines changed

api/ipfs/v1alpha1/ipfs_sdk.go

Lines changed: 6 additions & 142 deletions
Original file line numberDiff line numberDiff line change
@@ -145,10 +145,6 @@ func (enum *PinStatus) UnmarshalJSON(data []byte) error {
145145
return nil
146146
}
147147

148-
type CreateVolumeJWTResponse struct {
149-
Token string `json:"token"`
150-
}
151-
152148
type ListPinsResponse struct {
153149
TotalCount uint64 `json:"total_count"`
154150

@@ -237,7 +233,7 @@ type CreateVolumeRequest struct {
237233
Name string `json:"name"`
238234
}
239235

240-
// CreateVolume: create volume in S3 bucket.
236+
// CreateVolume: create volume.
241237
func (s *API) CreateVolume(req *CreateVolumeRequest, opts ...scw.RequestOption) (*Volume, error) {
242238
var err error
243239

@@ -427,7 +423,7 @@ type DeleteVolumeRequest struct {
427423
VolumeID string `json:"-"`
428424
}
429425

430-
// DeleteVolume: delete volume in S3 bucket.
426+
// DeleteVolume: delete volume.
431427
func (s *API) DeleteVolume(req *DeleteVolumeRequest, opts ...scw.RequestOption) error {
432428
var err error
433429

@@ -470,7 +466,7 @@ type CreatePinByURLRequest struct {
470466
PinOptions *PinOptions `json:"pin_options"`
471467
}
472468

473-
// CreatePinByURL: add content in s3 bucket.
469+
// CreatePinByURL: add content in volume by url.
474470
func (s *API) CreatePinByURL(req *CreatePinByURLRequest, opts ...scw.RequestOption) (*Pin, error) {
475471
var err error
476472

@@ -520,7 +516,7 @@ type CreatePinByCIDRequest struct {
520516
PinOptions *PinOptions `json:"pin_options"`
521517
}
522518

523-
// CreatePinByCID: add content in s3 bucket.
519+
// CreatePinByCID: add content in volume by cid.
524520
func (s *API) CreatePinByCID(req *CreatePinByCIDRequest, opts ...scw.RequestOption) (*Pin, error) {
525521
var err error
526522

@@ -553,54 +549,6 @@ func (s *API) CreatePinByCID(req *CreatePinByCIDRequest, opts ...scw.RequestOpti
553549
return &resp, nil
554550
}
555551

556-
type CreatePinByRawRequest struct {
557-
// Region: region to target. If none is passed will use default region from the config.
558-
Region scw.Region `json:"-"`
559-
560-
VolumeID string `json:"volume_id"`
561-
562-
Content []byte `json:"content"`
563-
564-
MimeType *string `json:"mime_type"`
565-
566-
Name *string `json:"name"`
567-
568-
PinOptions *PinOptions `json:"pin_options"`
569-
}
570-
571-
// CreatePinByRaw: add content in s3 bucket.
572-
func (s *API) CreatePinByRaw(req *CreatePinByRawRequest, opts ...scw.RequestOption) (*Pin, error) {
573-
var err error
574-
575-
if req.Region == "" {
576-
defaultRegion, _ := s.client.GetDefaultRegion()
577-
req.Region = defaultRegion
578-
}
579-
580-
if fmt.Sprint(req.Region) == "" {
581-
return nil, errors.New("field Region cannot be empty in request")
582-
}
583-
584-
scwReq := &scw.ScalewayRequest{
585-
Method: "POST",
586-
Path: "/ipfs/v1alpha1/regions/" + fmt.Sprint(req.Region) + "/pins/create-by-raw",
587-
Headers: http.Header{},
588-
}
589-
590-
err = scwReq.SetBody(req)
591-
if err != nil {
592-
return nil, err
593-
}
594-
595-
var resp Pin
596-
597-
err = s.client.Do(scwReq, &resp, opts...)
598-
if err != nil {
599-
return nil, err
600-
}
601-
return &resp, nil
602-
}
603-
604552
type ReplacePinRequest struct {
605553
// Region: region to target. If none is passed will use default region from the config.
606554
Region scw.Region `json:"-"`
@@ -665,7 +613,7 @@ type GetPinRequest struct {
665613
VolumeID string `json:"-"`
666614
}
667615

668-
// GetPin: get pin id create when content is add in s3 bucket.
616+
// GetPin: get pin id in volume.
669617
func (s *API) GetPin(req *GetPinRequest, opts ...scw.RequestOption) (*Pin, error) {
670618
var err error
671619

@@ -720,6 +668,7 @@ type ListPinsRequest struct {
720668
Status PinStatus `json:"-"`
721669
}
722670

671+
// ListPins: list pins in specific volume.
723672
func (s *API) ListPins(req *ListPinsRequest, opts ...scw.RequestOption) (*ListPinsResponse, error) {
724673
var err error
725674

@@ -805,91 +754,6 @@ func (s *API) DeletePin(req *DeletePinRequest, opts ...scw.RequestOption) error
805754
return nil
806755
}
807756

808-
type CreateVolumeJWTRequest struct {
809-
// Region: region to target. If none is passed will use default region from the config.
810-
Region scw.Region `json:"-"`
811-
812-
VolumeID string `json:"-"`
813-
}
814-
815-
func (s *API) CreateVolumeJWT(req *CreateVolumeJWTRequest, opts ...scw.RequestOption) (*CreateVolumeJWTResponse, error) {
816-
var err error
817-
818-
if req.Region == "" {
819-
defaultRegion, _ := s.client.GetDefaultRegion()
820-
req.Region = defaultRegion
821-
}
822-
823-
if fmt.Sprint(req.Region) == "" {
824-
return nil, errors.New("field Region cannot be empty in request")
825-
}
826-
827-
if fmt.Sprint(req.VolumeID) == "" {
828-
return nil, errors.New("field VolumeID cannot be empty in request")
829-
}
830-
831-
scwReq := &scw.ScalewayRequest{
832-
Method: "POST",
833-
Path: "/ipfs/v1alpha1/regions/" + fmt.Sprint(req.Region) + "/volumes/" + fmt.Sprint(req.VolumeID) + "/token",
834-
Headers: http.Header{},
835-
}
836-
837-
err = scwReq.SetBody(req)
838-
if err != nil {
839-
return nil, err
840-
}
841-
842-
var resp CreateVolumeJWTResponse
843-
844-
err = s.client.Do(scwReq, &resp, opts...)
845-
if err != nil {
846-
return nil, err
847-
}
848-
return &resp, nil
849-
}
850-
851-
type DeleteVolumeJWTRequest struct {
852-
// Region: region to target. If none is passed will use default region from the config.
853-
Region scw.Region `json:"-"`
854-
855-
VolumeID string `json:"-"`
856-
857-
Token string `json:"-"`
858-
}
859-
860-
func (s *API) DeleteVolumeJWT(req *DeleteVolumeJWTRequest, opts ...scw.RequestOption) error {
861-
var err error
862-
863-
if req.Region == "" {
864-
defaultRegion, _ := s.client.GetDefaultRegion()
865-
req.Region = defaultRegion
866-
}
867-
868-
query := url.Values{}
869-
parameter.AddToQuery(query, "token", req.Token)
870-
871-
if fmt.Sprint(req.Region) == "" {
872-
return errors.New("field Region cannot be empty in request")
873-
}
874-
875-
if fmt.Sprint(req.VolumeID) == "" {
876-
return errors.New("field VolumeID cannot be empty in request")
877-
}
878-
879-
scwReq := &scw.ScalewayRequest{
880-
Method: "DELETE",
881-
Path: "/ipfs/v1alpha1/regions/" + fmt.Sprint(req.Region) + "/volumes/" + fmt.Sprint(req.VolumeID) + "/token",
882-
Query: query,
883-
Headers: http.Header{},
884-
}
885-
886-
err = s.client.Do(scwReq, nil, opts...)
887-
if err != nil {
888-
return err
889-
}
890-
return nil
891-
}
892-
893757
// UnsafeGetTotalCount should not be used
894758
// Internal usage only
895759
func (r *ListVolumesResponse) UnsafeGetTotalCount() uint64 {

0 commit comments

Comments
 (0)