-
-
Notifications
You must be signed in to change notification settings - Fork 179
/
scheme.go
38 lines (32 loc) · 890 Bytes
/
scheme.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
package client
import (
"net/url"
"strings"
"github.com/go-errors/errors"
)
const STORAGE_SCHEME = "ss"
var ErrInvalidURL = errors.New("URL must match pattern ss:///bucket/[prefix]")
func ParseStorageURL(objectURL string) (string, error) {
parsed, err := url.Parse(objectURL)
if err != nil {
return "", errors.Errorf("failed to parse storage url: %w", err)
}
if strings.ToLower(parsed.Scheme) != STORAGE_SCHEME || len(parsed.Path) == 0 || len(parsed.Host) > 0 {
return "", errors.New(ErrInvalidURL)
}
return parsed.Path, nil
}
func SplitBucketPrefix(objectPath string) (string, string) {
if objectPath == "" || objectPath == "/" {
return "", ""
}
start := 0
if objectPath[0] == '/' {
start = 1
}
sep := strings.IndexByte(objectPath[start:], '/')
if sep < 0 {
return objectPath[start:], ""
}
return objectPath[start : sep+start], objectPath[sep+start+1:]
}