123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081 |
- package redriver
- import (
- "fmt"
- "net/url"
- "strings"
- "github.com/aws/aws-sdk-go-v2/aws/arn"
- )
- func ARNFromURL(qURL string) (arn.ARN, error) {
- a := arn.ARN{}
- u, err := url.Parse(qURL)
- if err != nil {
- return a, fmt.Errorf("queue URL %q is not a valid URL: %w", qURL, err)
- }
- path := u.EscapedPath()
- pathParts := strings.Split(strings.Trim(path, "/"), "/")
- if len(pathParts) != 2 {
- return a, fmt.Errorf("queue path %q does not have exactly 2 parts", path)
- }
- hostParts := strings.Split(u.Host, ".")
- if len(hostParts) != 4 { // <service>.<region>.amazonws.com
- return a, fmt.Errorf("queue host %q does not have exactly 4 parts", u.Host)
- }
- a = arn.ARN{
- Partition: "aws",
- Service: hostParts[0],
- Region: hostParts[1],
- AccountID: pathParts[0],
- Resource: pathParts[1],
- }
- return a, nil
- }
- func NameFromURL(qURL string) (name string, err error) {
- u, err := url.Parse(qURL)
- if err != nil {
- return "", fmt.Errorf("queue URL %q is not a valid URL: %w", qURL, err)
- }
- path := u.EscapedPath()
- parts := strings.Split(strings.Trim(path, "/"), "/")
- if len(parts) != 2 {
- return "", fmt.Errorf("queue path %q does not have exactly 2 parts", path)
- }
- return parts[1], nil
- }
- func NameFromARN(qARN arn.ARN) string {
- return qARN.Resource
- }
- func NameFromARNString(qARN string) (name string, err error) {
- a, err := arn.Parse(qARN)
- if err != nil {
- return "", fmt.Errorf("queue \"ARN\" %q is not an valid ARN", qARN)
- }
- return NameFromARN(a), nil
- }
- func URLFromARNString(qARN string) (name string, err error) {
- a, err := arn.Parse(qARN)
- if err != nil {
- return "", fmt.Errorf("queue \"ARN\" %q is not an valid ARN", qARN)
- }
- return URLFromARN(a)
- }
- func URLFromARN(qARN arn.ARN) (name string, err error) {
- path, err := url.JoinPath("/", qARN.AccountID, qARN.Resource)
- if err != nil {
- return "", fmt.Errorf("incorrect queue ARN: %w", err)
- }
- u := url.URL{
- Scheme: "https",
- Host: fmt.Sprintf("%s.%s.%s", qARN.Service, qARN.Region, "amazonws.com"),
- Path: path,
- }
- return u.String(), nil
- }
|