Add opensearch packages vpc endpoint support

resources/opensearchservice-packages.go

@@ -0,0 +1,62 @@
+package resources
+
+import (
+ "time"
+
+ "github.com/aws/aws-sdk-go/aws/session"
+ "github.com/aws/aws-sdk-go/service/opensearchservice"
+ "github.com/rebuy-de/aws-nuke/v2/pkg/types"
+)
+
+type OSPackage struct {
+ svc *opensearchservice.OpenSearchService
+ packageID *string
+ packageName *string
+ createdTime *time.Time
+}
+
+func init() {
+ register("OSPackage", ListOSPackages)
+}
+
+func ListOSPackages(sess *session.Session) ([]Resource, error) {
+ svc := opensearchservice.New(sess)
+
+ listResp, err := svc.DescribePackages(&opensearchservice.DescribePackagesInput{})
+ if err != nil {
+ return nil, err
+ }
+
+ resources := make([]Resource, 0)
+
+ for _, pkg := range listResp.PackageDetailsList {
+ resources = append(resources, &OSPackage{
+ svc: svc,
+ packageID: pkg.PackageID,
+ packageName: pkg.PackageName,
+ createdTime: pkg.CreatedAt,
+ })
+ }
+
+ return resources, nil
+}
+
+func (o *OSPackage) Remove() error {
+ _, err := o.svc.DeletePackage(&opensearchservice.DeletePackageInput{
+ PackageID: o.packageID,
+ })
+
+ return err
+}
+
+func (o *OSPackage) Properties() types.Properties {
+ properties := types.NewProperties()
+ properties.Set("PackageID", o.packageID)
+ properties.Set("PackageName", o.packageName)
+ properties.Set("CreatedTime", o.createdTime.Format(time.RFC3339))
+ return properties
+}
+
+func (o *OSPackage) String() string {
+ return *o.packageID
+}

resources/opensearchservice-vpcendpoints.go

@@ -0,0 +1,76 @@
+package resources
+
+import (
+ "github.com/aws/aws-sdk-go/aws/session"
+ "github.com/aws/aws-sdk-go/service/opensearchservice"
+ "github.com/rebuy-de/aws-nuke/v2/pkg/types"
+)
+
+type OSVPCEndpoint struct {
+ svc *opensearchservice.OpenSearchService
+ vpcEndpointId *string
+}
+
+func init() {
+ register("OSVPCEndpoint", ListOSVPCEndpoints)
+}
+
+func ListOSVPCEndpoints(sess *session.Session) ([]Resource, error) {
+ svc := opensearchservice.New(sess)
+
+ vpcEndpointIds, err := getOpenSearchVpcEndpointIds(svc)
+ if err != nil {
+ return nil, err
+ }
+
+ listResp, err := svc.DescribeVpcEndpoints(&opensearchservice.DescribeVpcEndpointsInput{
+ VpcEndpointIds: vpcEndpointIds,
+ })
+ if err != nil {
+ return nil, err
+ }
+
+ resources := make([]Resource, 0)
+
+ for _, vpcEndpoint := range listResp.VpcEndpoints {
+ resources = append(resources, &OSVPCEndpoint{
+ svc: svc,
+ vpcEndpointId: vpcEndpoint.VpcEndpointId,
+ })
+ }
+
+ return resources, nil
+}
+
+func getOpenSearchVpcEndpointIds(svc *opensearchservice.OpenSearchService) ([]*string, error) {
+ vpcEndpointIds := make([]*string, 0)
+
+ listResp, err := svc.ListVpcEndpoints(&opensearchservice.ListVpcEndpointsInput{})
+ if err != nil {
+ return nil, err
+ }
+
+ for _, vpcEndpoint := range listResp.VpcEndpointSummaryList {
+ vpcEndpointIds = append(vpcEndpointIds, vpcEndpoint.VpcEndpointId)
+ }
+
+ return vpcEndpointIds, nil
+}
+
+func (o *OSVPCEndpoint) Remove() error {
+ _, err := o.svc.DeleteVpcEndpoint(&opensearchservice.DeleteVpcEndpointInput{
+ VpcEndpointId: o.vpcEndpointId,
+ })
+
+ return err
+}
+
+func (o *OSVPCEndpoint) Properties() types.Properties {
+ properties := types.NewProperties()
+ properties.Set("VpcEndpointId", o.vpcEndpointId)
+ return properties
+}
+
+func (o *OSVPCEndpoint) String() string {
+ return *o.vpcEndpointId
+}