Index: helper/datastore_key.go |
diff --git a/helper/datastore_key.go b/helper/datastore_key.go |
deleted file mode 100644 |
index bfd55edc63dfb418746a57c0baf2e61949d11b1f..0000000000000000000000000000000000000000 |
--- a/helper/datastore_key.go |
+++ /dev/null |
@@ -1,236 +0,0 @@ |
-// Copyright 2015 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-// adapted from github.com/golang/appengine/datastore |
- |
-package helper |
- |
-import ( |
- "bytes" |
- "encoding/base64" |
- "errors" |
- "strconv" |
- "strings" |
- |
- "github.com/luci/gae" |
- pb "github.com/luci/gae/helper/internal/protos/datastore" |
- |
- "github.com/golang/protobuf/proto" |
-) |
- |
-// DSKeyEncode encodes the provided key as a base64-encoded protobuf. |
-// |
-// This encoding is compatible with the SDK-provided encoding and is agnostic |
-// to the underlying implementation of the DSKey. |
-func DSKeyEncode(k gae.DSKey) string { |
- n := 0 |
- for i := k; i != nil; i = i.Parent() { |
- n++ |
- } |
- e := make([]*pb.Path_Element, n) |
- for i := k; i != nil; i = i.Parent() { |
- n-- |
- kind := i.Kind() |
- e[n] = &pb.Path_Element{ |
- Type: &kind, |
- } |
- // At most one of {Name,Id} should be set. |
- // Neither will be set for incomplete keys. |
- if i.StringID() != "" { |
- sid := i.StringID() |
- e[n].Name = &sid |
- } else if i.IntID() != 0 { |
- iid := i.IntID() |
- e[n].Id = &iid |
- } |
- } |
- var namespace *string |
- if k.Namespace() != "" { |
- namespace = proto.String(k.Namespace()) |
- } |
- r, err := proto.Marshal(&pb.Reference{ |
- App: proto.String(k.AppID()), |
- NameSpace: namespace, |
- Path: &pb.Path{ |
- Element: e, |
- }, |
- }) |
- if err != nil { |
- panic(err) |
- } |
- |
- // trim padding |
- return strings.TrimRight(base64.URLEncoding.EncodeToString(r), "=") |
-} |
- |
-// DSKeyToksDecode decodes a base64-encoded protobuf representation of a DSKey |
-// into a tokenized form. This is so that implementations of the gae wrapper |
-// can decode to their own implementation of DSKey. |
-// |
-// This encoding is compatible with the SDK-provided encoding and is agnostic |
-// to the underlying implementation of the DSKey. |
-func DSKeyToksDecode(encoded string) (appID, namespace string, toks []gae.DSKeyTok, err error) { |
- // Re-add padding |
- if m := len(encoded) % 4; m != 0 { |
- encoded += strings.Repeat("=", 4-m) |
- } |
- b, err := base64.URLEncoding.DecodeString(encoded) |
- if err != nil { |
- return |
- } |
- |
- r := &pb.Reference{} |
- if err = proto.Unmarshal(b, r); err != nil { |
- return |
- } |
- |
- appID = r.GetApp() |
- namespace = r.GetNameSpace() |
- toks = make([]gae.DSKeyTok, len(r.Path.Element)) |
- for i, e := range r.Path.Element { |
- toks[i] = gae.DSKeyTok{ |
- Kind: e.GetType(), |
- IntID: e.GetId(), |
- StringID: e.GetName(), |
- } |
- } |
- return |
-} |
- |
-// DSKeyMarshalJSON returns a MarshalJSON-compatible serialization of a DSKey. |
-func DSKeyMarshalJSON(k gae.DSKey) ([]byte, error) { |
- return []byte(`"` + DSKeyEncode(k) + `"`), nil |
-} |
- |
-// DSKeyUnmarshalJSON returns the tokenized version of a DSKey as encoded by |
-// DSKeyMarshalJSON. |
-func DSKeyUnmarshalJSON(buf []byte) (appID, namespace string, toks []gae.DSKeyTok, err error) { |
- if len(buf) < 2 || buf[0] != '"' || buf[len(buf)-1] != '"' { |
- err = errors.New("datastore: bad JSON key") |
- } else { |
- appID, namespace, toks, err = DSKeyToksDecode(string(buf[1 : len(buf)-1])) |
- } |
- return |
-} |
- |
-// DSKeyIncomplete returns true iff k doesn't have an id yet. |
-func DSKeyIncomplete(k gae.DSKey) bool { |
- return k != nil && k.StringID() == "" && k.IntID() == 0 |
-} |
- |
-// DSKeyValid determines if a key is valid, according to a couple rules: |
-// - k is not nil |
-// - k's namespace matches ns |
-// - every token of k: |
-// - (if !allowSpecial) token's kind doesn't start with '__' |
-// - token's kind and appid are non-blank |
-// - token is not incomplete |
-// - all tokens have the same namespace and appid |
-func DSKeyValid(k gae.DSKey, ns string, allowSpecial bool) bool { |
- if k == nil { |
- return false |
- } |
- // since we do "client-side" validation of namespaces in local |
- // implementations, it's convenient to check this here. |
- if k.Namespace() != ns { |
- return false |
- } |
- for ; k != nil; k = k.Parent() { |
- if !allowSpecial && len(k.Kind()) >= 2 && k.Kind()[:2] == "__" { |
- return false |
- } |
- if k.Kind() == "" || k.AppID() == "" { |
- return false |
- } |
- if k.StringID() != "" && k.IntID() != 0 { |
- return false |
- } |
- if k.Parent() != nil { |
- if DSKeyIncomplete(k.Parent()) { |
- return false |
- } |
- if k.Parent().AppID() != k.AppID() || k.Parent().Namespace() != k.Namespace() { |
- return false |
- } |
- } |
- } |
- return true |
-} |
- |
-// DSKeyRoot returns the entity root for the given key. |
-func DSKeyRoot(k gae.DSKey) gae.DSKey { |
- for k != nil && k.Parent() != nil { |
- k = k.Parent() |
- } |
- return k |
-} |
- |
-// DSKeysEqual returns true iff the two keys represent identical key values. |
-func DSKeysEqual(a, b gae.DSKey) (ret bool) { |
- ret = (a.Kind() == b.Kind() && |
- a.StringID() == b.StringID() && |
- a.IntID() == b.IntID() && |
- a.AppID() == b.AppID() && |
- a.Namespace() == b.Namespace()) |
- if !ret { |
- return |
- } |
- ap, bp := a.Parent(), b.Parent() |
- return (ap == nil && bp == nil) || DSKeysEqual(ap, bp) |
-} |
- |
-func marshalDSKey(b *bytes.Buffer, k gae.DSKey) { |
- if k.Parent() != nil { |
- marshalDSKey(b, k.Parent()) |
- } |
- b.WriteByte('/') |
- b.WriteString(k.Kind()) |
- b.WriteByte(',') |
- if k.StringID() != "" { |
- b.WriteString(k.StringID()) |
- } else { |
- b.WriteString(strconv.FormatInt(k.IntID(), 10)) |
- } |
-} |
- |
-// DSKeyString returns a human-readable representation of the key, and is the |
-// typical implementation of DSKey.String() (though it isn't guaranteed to be) |
-func DSKeyString(k gae.DSKey) string { |
- if k == nil { |
- return "" |
- } |
- b := bytes.NewBuffer(make([]byte, 0, 512)) |
- marshalDSKey(b, k) |
- return b.String() |
-} |
- |
-// DSKeySplit splits the key into its constituent parts. Note that if the key is |
-// not DSKeyValid, this method may not provide a round-trip for k. |
-func DSKeySplit(k gae.DSKey) (appID, namespace string, toks []gae.DSKeyTok) { |
- if k == nil { |
- return |
- } |
- |
- if sk, ok := k.(*GenericDSKey); ok { |
- if sk == nil { |
- return |
- } |
- return sk.appID, sk.namespace, sk.toks |
- } |
- |
- n := 0 |
- for i := k; i != nil; i = i.Parent() { |
- n++ |
- } |
- toks = make([]gae.DSKeyTok, n) |
- for i := k; i != nil; i = i.Parent() { |
- n-- |
- toks[n].IntID = i.IntID() |
- toks[n].StringID = i.StringID() |
- toks[n].Kind = i.Kind() |
- } |
- appID = k.AppID() |
- namespace = k.Namespace() |
- return |
-} |