Wala shell

Advanced PHP File Manager

Server IP: 127.0.0.1 | PHP Version: 8.3.30 | Domains Hosted: 54

Name	Size	Last Modified	Actions
📁 ..	-	2025-05-25 12:27
📄 accesspoint_arn.go package arn import ( "strings" "github.com/aws/aws-sdk-go/aws/arn" ) // AccessPointARN provides representation type AccessPointARN struct { arn.ARN AccessPointName string } // GetARN returns the base ARN for the Access Point resource func (a AccessPointARN) GetARN() arn.ARN { return a.ARN } // ParseAccessPointResource attempts to parse the ARN's resource as an // AccessPoint resource. // // Supported Access point resource format: // - Access point format: arn:{partition}:s3:{region}:{accountId}:accesspoint/{accesspointName} // - example: arn.aws.s3.us-west-2.012345678901:accesspoint/myaccesspoint // func ParseAccessPointResource(a arn.ARN, resParts []string) (AccessPointARN, error) { if len(a.Region) == 0 { return AccessPointARN{}, InvalidARNError{ARN: a, Reason: "region not set"} } if len(a.AccountID) == 0 { return AccessPointARN{}, InvalidARNError{ARN: a, Reason: "account-id not set"} } if len(resParts) == 0 { return AccessPointARN{}, InvalidARNError{ARN: a, Reason: "resource-id not set"} } if len(resParts) > 1 { return AccessPointARN{}, InvalidARNError{ARN: a, Reason: "sub resource not supported"} } resID := resParts[0] if len(strings.TrimSpace(resID)) == 0 { return AccessPointARN{}, InvalidARNError{ARN: a, Reason: "resource-id not set"} } return AccessPointARN{ ARN: a, AccessPointName: resID, }, nil }	1.35 KB	2025-05-25 12:27
📄 accesspoint_arn_test.go //go:build go1.7 // +build go1.7 package arn import ( "reflect" "strings" "testing" "github.com/aws/aws-sdk-go/aws/arn" ) func TestParseAccessPointResource(t testing.T) { cases := map[string]struct { ARN arn.ARN ExpectErr string ExpectARN AccessPointARN }{ "region not set": { ARN: arn.ARN{ Partition: "aws", Service: "s3", AccountID: "012345678901", Resource: "accesspoint/myendpoint", }, ExpectErr: "region not set", }, "account-id not set": { ARN: arn.ARN{ Partition: "aws", Service: "s3", Region: "us-west-2", Resource: "accesspoint/myendpoint", }, ExpectErr: "account-id not set", }, "resource-id not set": { ARN: arn.ARN{ Partition: "aws", Service: "s3", Region: "us-west-2", AccountID: "012345678901", Resource: "accesspoint", }, ExpectErr: "resource-id not set", }, "resource-id empty": { ARN: arn.ARN{ Partition: "aws", Service: "s3", Region: "us-west-2", AccountID: "012345678901", Resource: "accesspoint:", }, ExpectErr: "resource-id not set", }, "resource not supported": { ARN: arn.ARN{ Partition: "aws", Service: "s3", Region: "us-west-2", AccountID: "012345678901", Resource: "accesspoint/endpoint/object/key", }, ExpectErr: "sub resource not supported", }, "valid resource-id": { ARN: arn.ARN{ Partition: "aws", Service: "s3", Region: "us-west-2", AccountID: "012345678901", Resource: "accesspoint/endpoint", }, ExpectARN: AccessPointARN{ ARN: arn.ARN{ Partition: "aws", Service: "s3", Region: "us-west-2", AccountID: "012345678901", Resource: "accesspoint/endpoint", }, AccessPointName: "endpoint", }, }, } for name, c := range cases { t.Run(name, func(t testing.T) { resParts := SplitResource(c.ARN.Resource) a, err := ParseAccessPointResource(c.ARN, resParts[1:]) if len(c.ExpectErr) == 0 && err != nil { t.Fatalf("expect no error but got %v", err) } else if len(c.ExpectErr) != 0 && err == nil { t.Fatalf("expect error %q, but got nil", c.ExpectErr) } else if len(c.ExpectErr) != 0 && err != nil { if e, a := c.ExpectErr, err.Error(); !strings.Contains(a, e) { t.Fatalf("expect error %q, got %q", e, a) } return } if e, a := c.ExpectARN, a; !reflect.DeepEqual(e, a) { t.Errorf("expect %v, got %v", e, a) } }) } }	2.43 KB	2025-05-25 12:27
📄 arn.go package arn import ( "fmt" "strings" "github.com/aws/aws-sdk-go/aws/arn" ) var supportedServiceARN = []string{ "s3", "s3-outposts", "s3-object-lambda", } func isSupportedServiceARN(service string) bool { for _, name := range supportedServiceARN { if name == service { return true } } return false } // Resource provides the interfaces abstracting ARNs of specific resource // types. type Resource interface { GetARN() arn.ARN String() string } // ResourceParser provides the function for parsing an ARN's resource // component into a typed resource. type ResourceParser func(arn.ARN) (Resource, error) // ParseResource parses an AWS ARN into a typed resource for the S3 API. func ParseResource(s string, resParser ResourceParser) (resARN Resource, err error) { a, err := arn.Parse(s) if err != nil { return nil, err } if len(a.Partition) == 0 { return nil, InvalidARNError{ARN: a, Reason: "partition not set"} } if !isSupportedServiceARN(a.Service) { return nil, InvalidARNError{ARN: a, Reason: "service is not supported"} } if strings.HasPrefix(a.Region, "fips-") \|\| strings.HasSuffix(a.Region, "-fips") { return nil, InvalidARNError{ARN: a, Reason: "FIPS region not allowed in ARN"} } if len(a.Resource) == 0 { return nil, InvalidARNError{ARN: a, Reason: "resource not set"} } return resParser(a) } // SplitResource splits the resource components by the ARN resource delimiters. func SplitResource(v string) []string { var parts []string var offset int for offset <= len(v) { idx := strings.IndexAny(v[offset:], "/:") if idx < 0 { parts = append(parts, v[offset:]) break } parts = append(parts, v[offset:idx+offset]) offset += idx + 1 } return parts } // IsARN returns whether the given string is an ARN func IsARN(s string) bool { return arn.IsARN(s) } // InvalidARNError provides the error for an invalid ARN error. type InvalidARNError struct { ARN arn.ARN Reason string } // Error returns a string denoting the occurred InvalidARNError func (e InvalidARNError) Error() string { return fmt.Sprintf("invalid Amazon %s ARN, %s, %s", e.ARN.Service, e.Reason, e.ARN.String()) }	2.11 KB	2025-05-25 12:27
📄 arn_test.go //go:build go1.7 // +build go1.7 package arn import ( "reflect" "strings" "testing" "github.com/aws/aws-sdk-go/aws/arn" ) func TestParseResource(t testing.T) { cases := map[string]struct { Input string MappedResources map[string]func(arn.ARN, []string) (Resource, error) Expect Resource ExpectErr string }{ "Empty ARN": { Input: "", ExpectErr: "arn: invalid prefix", }, "No Partition": { Input: "arn::sqs:us-west-2:012345678901:accesspoint", ExpectErr: "partition not set", }, "Not S3 ARN": { Input: "arn:aws:sqs:us-west-2:012345678901:accesspoint", ExpectErr: "service is not supported", }, "No Resource": { Input: "arn:aws:s3:us-west-2:012345678901:", ExpectErr: "resource not set", }, "Unknown Resource Type": { Input: "arn:aws:s3:us-west-2:012345678901:myresource", ExpectErr: "unknown resource type", }, "Unknown BucketARN Resource Type": { Input: "arn:aws:s3:us-west-2:012345678901:bucket_name:mybucket", ExpectErr: "unknown resource type", }, "Unknown Resource Type with Resource and Sub-Resource": { Input: "arn:aws:s3:us-west-2:012345678901:somethingnew:myresource/subresource", ExpectErr: "unknown resource type", }, "Access Point with sub resource": { Input: "arn:aws:s3:us-west-2:012345678901:accesspoint:myresource/subresource", MappedResources: map[string]func(arn.ARN, []string) (Resource, error){ "accesspoint": func(a arn.ARN, parts []string) (Resource, error) { return ParseAccessPointResource(a, parts) }, }, ExpectErr: "resource not supported", }, "AccessPoint Resource Type": { Input: "arn:aws:s3:us-west-2:012345678901:accesspoint:myendpoint", MappedResources: map[string]func(arn.ARN, []string) (Resource, error){ "accesspoint": func(a arn.ARN, parts []string) (Resource, error) { return ParseAccessPointResource(a, parts) }, }, Expect: AccessPointARN{ ARN: arn.ARN{ Partition: "aws", Service: "s3", Region: "us-west-2", AccountID: "012345678901", Resource: "accesspoint:myendpoint", }, AccessPointName: "myendpoint", }, }, "AccessPoint Resource Type With Path Syntax": { Input: "arn:aws:s3:us-west-2:012345678901:accesspoint/myendpoint", MappedResources: map[string]func(arn.ARN, []string) (Resource, error){ "accesspoint": func(a arn.ARN, parts []string) (Resource, error) { return ParseAccessPointResource(a, parts) }, }, Expect: AccessPointARN{ ARN: arn.ARN{ Partition: "aws", Service: "s3", Region: "us-west-2", AccountID: "012345678901", Resource: "accesspoint/myendpoint", }, AccessPointName: "myendpoint", }, }, "invalid FIPS pseudo region in ARN (prefix)": { Input: "arn:aws:s3:fips-us-west-2:012345678901:accesspoint/myendpoint", ExpectErr: "FIPS region not allowed in ARN", }, "invalid FIPS pseudo region in ARN (suffix)": { Input: "arn:aws:s3:us-west-2-fips:012345678901:accesspoint/myendpoint", ExpectErr: "FIPS region not allowed in ARN", }, } for name, c := range cases { t.Run(name, func(t testing.T) { parsed, err := ParseResource(c.Input, mappedResourceParser(c.MappedResources)) if len(c.ExpectErr) == 0 && err != nil { t.Fatalf("expect no error but got %v", err) } else if len(c.ExpectErr) != 0 && err == nil { t.Fatalf("expect error but got nil") } else if len(c.ExpectErr) != 0 && err != nil { if e, a := c.ExpectErr, err.Error(); !strings.Contains(a, e) { t.Fatalf("expect error %q, got %q", e, a) } return } if e, a := c.Expect, parsed; !reflect.DeepEqual(e, a) { t.Errorf("Expect %v, got %v", e, a) } }) } } func mappedResourceParser(kinds map[string]func(arn.ARN, []string) (Resource, error)) ResourceParser { return func(a arn.ARN) (Resource, error) { parts := SplitResource(a.Resource) fn, ok := kinds[parts[0]] if !ok { return nil, InvalidARNError{ARN: a, Reason: "unknown resource type"} } return fn(a, parts[1:]) } } func TestSplitResource(t testing.T) { cases := []struct { Input string Expect []string }{ { Input: "accesspoint:myendpoint", Expect: []string{"accesspoint", "myendpoint"}, }, { Input: "accesspoint/myendpoint", Expect: []string{"accesspoint", "myendpoint"}, }, { Input: "accesspoint", Expect: []string{"accesspoint"}, }, { Input: "accesspoint:", Expect: []string{"accesspoint", ""}, }, { Input: "accesspoint: ", Expect: []string{"accesspoint", " "}, }, { Input: "accesspoint:endpoint/object/key", Expect: []string{"accesspoint", "endpoint", "object", "key"}, }, } for _, c := range cases { t.Run(c.Input, func(t testing.T) { parts := SplitResource(c.Input) if e, a := c.Expect, parts; !reflect.DeepEqual(e, a) { t.Errorf("expect %v, got %v", e, a) } }) } }	4.84 KB	2025-05-25 12:27
📄 outpost_arn.go package arn import ( "strings" "github.com/aws/aws-sdk-go/aws/arn" ) // OutpostARN interface that should be satisfied by outpost ARNs type OutpostARN interface { Resource GetOutpostID() string } // ParseOutpostARNResource will parse a provided ARNs resource using the appropriate ARN format // and return a specific OutpostARN type // // Currently supported outpost ARN formats: // * Outpost AccessPoint ARN format: // - ARN format: arn:{partition}:s3-outposts:{region}:{accountId}:outpost/{outpostId}/accesspoint/{accesspointName} // - example: arn:aws:s3-outposts:us-west-2:012345678901:outpost/op-1234567890123456/accesspoint/myaccesspoint // // * Outpost Bucket ARN format: // - ARN format: arn:{partition}:s3-outposts:{region}:{accountId}:outpost/{outpostId}/bucket/{bucketName} // - example: arn:aws:s3-outposts:us-west-2:012345678901:outpost/op-1234567890123456/bucket/mybucket // // Other outpost ARN formats may be supported and added in the future. // func ParseOutpostARNResource(a arn.ARN, resParts []string) (OutpostARN, error) { if len(a.Region) == 0 { return nil, InvalidARNError{ARN: a, Reason: "region not set"} } if len(a.AccountID) == 0 { return nil, InvalidARNError{ARN: a, Reason: "account-id not set"} } // verify if outpost id is present and valid if len(resParts) == 0 \|\| len(strings.TrimSpace(resParts[0])) == 0 { return nil, InvalidARNError{ARN: a, Reason: "outpost resource-id not set"} } // verify possible resource type exists if len(resParts) < 3 { return nil, InvalidARNError{ ARN: a, Reason: "incomplete outpost resource type. Expected bucket or access-point resource to be present", } } // Since we know this is a OutpostARN fetch outpostID outpostID := strings.TrimSpace(resParts[0]) switch resParts[1] { case "accesspoint": accesspointARN, err := ParseAccessPointResource(a, resParts[2:]) if err != nil { return OutpostAccessPointARN{}, err } return OutpostAccessPointARN{ AccessPointARN: accesspointARN, OutpostID: outpostID, }, nil case "bucket": bucketName, err := parseBucketResource(a, resParts[2:]) if err != nil { return nil, err } return OutpostBucketARN{ ARN: a, BucketName: bucketName, OutpostID: outpostID, }, nil default: return nil, InvalidARNError{ARN: a, Reason: "unknown resource set for outpost ARN"} } } // OutpostAccessPointARN represents outpost access point ARN. type OutpostAccessPointARN struct { AccessPointARN OutpostID string } // GetOutpostID returns the outpost id of outpost access point arn func (o OutpostAccessPointARN) GetOutpostID() string { return o.OutpostID } // OutpostBucketARN represents the outpost bucket ARN. type OutpostBucketARN struct { arn.ARN BucketName string OutpostID string } // GetOutpostID returns the outpost id of outpost bucket arn func (o OutpostBucketARN) GetOutpostID() string { return o.OutpostID } // GetARN retrives the base ARN from outpost bucket ARN resource func (o OutpostBucketARN) GetARN() arn.ARN { return o.ARN } // parseBucketResource attempts to parse the ARN's bucket resource and retrieve the // bucket resource id. // // parseBucketResource only parses the bucket resource id. // func parseBucketResource(a arn.ARN, resParts []string) (bucketName string, err error) { if len(resParts) == 0 { return bucketName, InvalidARNError{ARN: a, Reason: "bucket resource-id not set"} } if len(resParts) > 1 { return bucketName, InvalidARNError{ARN: a, Reason: "sub resource not supported"} } bucketName = strings.TrimSpace(resParts[0]) if len(bucketName) == 0 { return bucketName, InvalidARNError{ARN: a, Reason: "bucket resource-id not set"} } return bucketName, err }	3.62 KB	2025-05-25 12:27
📄 outpost_arn_test.go //go:build go1.7 // +build go1.7 package arn import ( "reflect" "strings" "testing" "github.com/aws/aws-sdk-go/aws/arn" ) func TestParseOutpostAccessPointARNResource(t testing.T) { cases := map[string]struct { ARN arn.ARN ExpectErr string ExpectARN OutpostAccessPointARN }{ "region not set": { ARN: arn.ARN{ Partition: "aws", Service: "s3-outposts", AccountID: "012345678901", Resource: "outpost/myoutpost/accesspoint/myendpoint", }, ExpectErr: "region not set", }, "account-id not set": { ARN: arn.ARN{ Partition: "aws", Service: "s3-outposts", Region: "us-west-2", Resource: "outpost/myoutpost/accesspoint/myendpoint", }, ExpectErr: "account-id not set", }, "resource-id not set": { ARN: arn.ARN{ Partition: "aws", Service: "s3-outposts", Region: "us-west-2", AccountID: "012345678901", Resource: "myoutpost", }, ExpectErr: "resource-id not set", }, "resource-id empty": { ARN: arn.ARN{ Partition: "aws", Service: "s3-outposts", Region: "us-west-2", AccountID: "012345678901", Resource: "outpost:", }, ExpectErr: "resource-id not set", }, "resource not supported": { ARN: arn.ARN{ Partition: "aws", Service: "s3-outposts", Region: "us-west-2", AccountID: "012345678901", Resource: "outpost/myoutpost/accesspoint/endpoint/object/key", }, ExpectErr: "sub resource not supported", }, "access-point not defined": { ARN: arn.ARN{ Partition: "aws", Service: "s3-outposts", Region: "us-west-2", AccountID: "012345678901", Resource: "outpost/myoutpost/endpoint/object/key", }, ExpectErr: "unknown resource set for outpost ARN", }, "valid resource-id": { ARN: arn.ARN{ Partition: "aws", Service: "s3-outposts", Region: "us-west-2", AccountID: "012345678901", Resource: "outpost/myoutpost/accesspoint/myaccesspoint", }, ExpectARN: OutpostAccessPointARN{ AccessPointARN: AccessPointARN{ ARN: arn.ARN{ Partition: "aws", Service: "s3-outposts", Region: "us-west-2", AccountID: "012345678901", Resource: "outpost/myoutpost/accesspoint/myaccesspoint", }, AccessPointName: "myaccesspoint", }, OutpostID: "myoutpost", }, }, } for name, c := range cases { t.Run(name, func(t testing.T) { resParts := SplitResource(c.ARN.Resource) a, err := ParseOutpostARNResource(c.ARN, resParts[1:]) if len(c.ExpectErr) == 0 && err != nil { t.Fatalf("expect no error but got %v", err) } else if len(c.ExpectErr) != 0 && err == nil { t.Fatalf("expect error %q, but got nil", c.ExpectErr) } else if len(c.ExpectErr) != 0 && err != nil { if e, a := c.ExpectErr, err.Error(); !strings.Contains(a, e) { t.Fatalf("expect error %q, got %q", e, a) } return } if e, a := c.ExpectARN, a; !reflect.DeepEqual(e, a) { t.Errorf("expect %v, got %v", e, a) } }) } } func TestParseOutpostBucketARNResource(t testing.T) { cases := map[string]struct { ARN arn.ARN ExpectErr string ExpectARN OutpostBucketARN }{ "region not set": { ARN: arn.ARN{ Partition: "aws", Service: "s3-outposts", AccountID: "012345678901", Resource: "outpost/myoutpost/bucket/mybucket", }, ExpectErr: "region not set", }, "resource-id empty": { ARN: arn.ARN{ Partition: "aws", Service: "s3-outposts", Region: "us-west-2", AccountID: "012345678901", Resource: "outpost:", }, ExpectErr: "resource-id not set", }, "resource not supported": { ARN: arn.ARN{ Partition: "aws", Service: "s3-outposts", Region: "us-west-2", AccountID: "012345678901", Resource: "outpost/myoutpost/bucket/mybucket/object/key", }, ExpectErr: "sub resource not supported", }, "bucket not defined": { ARN: arn.ARN{ Partition: "aws", Service: "s3-outposts", Region: "us-west-2", AccountID: "012345678901", Resource: "outpost/myoutpost/endpoint/object/key", }, ExpectErr: "unknown resource set for outpost ARN", }, "valid resource-id": { ARN: arn.ARN{ Partition: "aws", Service: "s3-outposts", Region: "us-west-2", AccountID: "012345678901", Resource: "outpost/myoutpost/bucket/mybucket", }, ExpectARN: OutpostBucketARN{ ARN: arn.ARN{ Partition: "aws", Service: "s3-outposts", Region: "us-west-2", AccountID: "012345678901", Resource: "outpost/myoutpost/bucket/mybucket", }, BucketName: "mybucket", OutpostID: "myoutpost", }, }, } for name, c := range cases { t.Run(name, func(t testing.T) { resParts := SplitResource(c.ARN.Resource) a, err := ParseOutpostARNResource(c.ARN, resParts[1:]) if len(c.ExpectErr) == 0 && err != nil { t.Fatalf("expect no error but got %v", err) } else if len(c.ExpectErr) != 0 && err == nil { t.Fatalf("expect error %q, but got nil", c.ExpectErr) } else if len(c.ExpectErr) != 0 && err != nil { if e, a := c.ExpectErr, err.Error(); !strings.Contains(a, e) { t.Fatalf("expect error %q, got %q", e, a) } return } if e, a := c.ExpectARN, a; !reflect.DeepEqual(e, a) { t.Errorf("expect %v, got %v", e, a) } }) } } func TestParseBucketResource(t testing.T) { cases := map[string]struct { ARN arn.ARN ExpectErr string ExpectBucketName string }{ "resource-id empty": { ARN: arn.ARN{ Partition: "aws", Service: "s3", Region: "us-west-2", AccountID: "012345678901", Resource: "bucket:", }, ExpectErr: "bucket resource-id not set", }, "resource not supported": { ARN: arn.ARN{ Partition: "aws", Service: "s3", Region: "us-west-2", AccountID: "012345678901", Resource: "bucket/mybucket/object/key", }, ExpectErr: "sub resource not supported", }, "valid resource-id": { ARN: arn.ARN{ Partition: "aws", Service: "s3", Region: "us-west-2", AccountID: "012345678901", Resource: "bucket/mybucket", }, ExpectBucketName: "mybucket", }, } for name, c := range cases { t.Run(name, func(t testing.T) { resParts := SplitResource(c.ARN.Resource) a, err := parseBucketResource(c.ARN, resParts[1:]) if len(c.ExpectErr) == 0 && err != nil { t.Fatalf("expect no error but got %v", err) } else if len(c.ExpectErr) != 0 && err == nil { t.Fatalf("expect error %q, but got nil", c.ExpectErr) } else if len(c.ExpectErr) != 0 && err != nil { if e, a := c.ExpectErr, err.Error(); !strings.Contains(a, e) { t.Fatalf("expect error %q, got %q", e, a) } return } if e, a := c.ExpectBucketName, a; !reflect.DeepEqual(e, a) { t.Errorf("expect %v, got %v", e, a) } }) } }	6.74 KB	2025-05-25 12:27
📄 s3_object_lambda_arn.go package arn // S3ObjectLambdaARN represents an ARN for the s3-object-lambda service type S3ObjectLambdaARN interface { Resource isS3ObjectLambdasARN() } // S3ObjectLambdaAccessPointARN is an S3ObjectLambdaARN for the Access Point resource type type S3ObjectLambdaAccessPointARN struct { AccessPointARN } func (s S3ObjectLambdaAccessPointARN) isS3ObjectLambdasARN() {}	375 B	2025-05-25 12:27

Terminal