2014-09-23 20:39:12 +00:00
|
|
|
package backend
|
|
|
|
|
2016-01-26 20:49:33 +00:00
|
|
|
import "errors"
|
2014-09-23 20:39:12 +00:00
|
|
|
|
2016-01-26 20:49:33 +00:00
|
|
|
// ErrNoIDPrefixFound is returned by Find() when no ID for the given prefix
|
|
|
|
// could be found.
|
|
|
|
var ErrNoIDPrefixFound = errors.New("no ID found")
|
2014-11-24 21:09:22 +00:00
|
|
|
|
2016-01-26 20:49:33 +00:00
|
|
|
// ErrMultipleIDMatches is returned by Find() when multiple IDs with the given
|
|
|
|
// prefix are found.
|
|
|
|
var ErrMultipleIDMatches = errors.New("multiple IDs with prefix found")
|
2014-11-24 20:12:32 +00:00
|
|
|
|
2015-03-28 10:50:23 +00:00
|
|
|
// Find loads the list of all blobs of type t and searches for names which
|
|
|
|
// start with prefix. If none is found, nil and ErrNoIDPrefixFound is returned.
|
|
|
|
// If more than one is found, nil and ErrMultipleIDMatches is returned.
|
|
|
|
func Find(be Lister, t Type, prefix string) (string, error) {
|
|
|
|
done := make(chan struct{})
|
|
|
|
defer close(done)
|
2014-11-24 20:12:32 +00:00
|
|
|
|
2015-03-28 10:50:23 +00:00
|
|
|
match := ""
|
2014-11-24 20:12:32 +00:00
|
|
|
|
|
|
|
// TODO: optimize by sorting list etc.
|
2015-03-28 10:50:23 +00:00
|
|
|
for name := range be.List(t, done) {
|
|
|
|
if prefix == name[:len(prefix)] {
|
|
|
|
if match == "" {
|
|
|
|
match = name
|
2014-11-24 20:12:32 +00:00
|
|
|
} else {
|
2015-03-28 10:50:23 +00:00
|
|
|
return "", ErrMultipleIDMatches
|
2014-11-24 20:12:32 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2015-03-28 10:50:23 +00:00
|
|
|
if match != "" {
|
2014-11-24 20:12:32 +00:00
|
|
|
return match, nil
|
|
|
|
}
|
|
|
|
|
2015-03-28 10:50:23 +00:00
|
|
|
return "", ErrNoIDPrefixFound
|
2014-11-24 20:12:32 +00:00
|
|
|
}
|
|
|
|
|
2016-01-26 20:49:33 +00:00
|
|
|
const minPrefixLength = 8
|
|
|
|
|
2014-11-24 21:09:22 +00:00
|
|
|
// PrefixLength returns the number of bytes required so that all prefixes of
|
2015-03-28 10:50:23 +00:00
|
|
|
// all names of type t are unique.
|
2014-12-21 16:02:49 +00:00
|
|
|
func PrefixLength(be Lister, t Type) (int, error) {
|
2015-03-28 10:50:23 +00:00
|
|
|
done := make(chan struct{})
|
|
|
|
defer close(done)
|
|
|
|
|
2014-11-24 21:09:22 +00:00
|
|
|
// load all IDs of the given type
|
2015-03-28 10:50:23 +00:00
|
|
|
list := make([]string, 0, 100)
|
|
|
|
for name := range be.List(t, done) {
|
|
|
|
list = append(list, name)
|
2014-11-24 21:09:22 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
// select prefixes of length l, test if the last one is the same as the current one
|
|
|
|
outer:
|
2016-01-26 20:49:33 +00:00
|
|
|
for l := minPrefixLength; l < IDSize; l++ {
|
2015-03-28 10:50:23 +00:00
|
|
|
var last string
|
2014-11-24 21:09:22 +00:00
|
|
|
|
2015-03-28 10:50:23 +00:00
|
|
|
for _, name := range list {
|
|
|
|
if last == name[:l] {
|
2014-11-24 21:09:22 +00:00
|
|
|
continue outer
|
|
|
|
}
|
2015-03-28 10:50:23 +00:00
|
|
|
last = name[:l]
|
2014-11-24 21:09:22 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
return l, nil
|
|
|
|
}
|
|
|
|
|
|
|
|
return IDSize, nil
|
|
|
|
}
|