impl/memory: Implement Queries

service/datastore/serialize/serialize.go

 // 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.
 
 package serialize
 
 import (
         "bytes"
         "errors"
         "fmt"
@@ skipping 199 matching lines @@
         }
         return time.Unix(int64(v/1e6), int64((v%1e6)*1e3)).UTC(), nil
 }
 
 // WriteProperty writes a Property to the buffer. `context` behaves the same
 // way that it does for WriteKey, but only has an effect if `p` contains a
 // Key as its Value.
 func WriteProperty(buf Buffer, context KeyContext, p ds.Property) (err error) {
         defer recoverTo(&err)
         typb := byte(p.Type())
-        if p.IndexSetting() == ds.NoIndex {
+        if p.IndexSetting() != ds.NoIndex {
                 typb |= 0x80
         }
         panicIf(buf.WriteByte(typb))
         switch p.Type() {
         case ds.PTNull, ds.PTBoolTrue, ds.PTBoolFalse:
         case ds.PTInt:
                 _, err = cmpbin.WriteInt(buf, p.Value().(int64))
         case ds.PTFloat:
                 _, err = cmpbin.WriteFloat64(buf, p.Value().(float64))
         case ds.PTString:
@@ skipping 19 matching lines @@
 // ReadProperty reads a Property from the buffer. `context`, `appid`, and
 // `namespace` behave the same way they do for ReadKey, but only have an
 // effect if the decoded property has a Key value.
 func ReadProperty(buf Buffer, context KeyContext, appid, namespace string) (p ds.Property, err error) {
         val := interface{}(nil)
         typb, err := buf.ReadByte()
         if err != nil {
                 return
         }
         is := ds.ShouldIndex
-        if (typb & 0x80) != 0 {
+        if (typb & 0x80) == 0 {
                 is = ds.NoIndex
         }
         switch ds.PropertyType(typb & 0x7f) {
         case ds.PTNull:
         case ds.PTBoolTrue:
                 val = true
         case ds.PTBoolFalse:
                 val = false
         case ds.PTInt:
                 val, _, err = cmpbin.ReadInt(buf)
@@ skipping 286 matching lines @@
         }
 }
 
 func recoverTo(err *error) {
         if r := recover(); r != nil {
                 if rerr := r.(parseError); rerr != nil {
                         *err = error(rerr)
                 }
         }
 }