Handle reading keys where the original value sent to the server was a list. Resolves Issue #350

Author: khaf

CHANGELOG.md

@@ -1,6 +1,13 @@
 # Change History
 
 
+## May 28 2021: v4.5.2
+  Minor fix release.
+
+  * **Fixes**
+
+    - Handle reading keys where the original value sent to the server was a list. Resolves Issue #350.
+
 ## May 27 2021: v4.5.1
   Minor fix release.
 

client_test.go

@@ -1292,6 +1292,35 @@ var _ = gg.Describe("Aerospike", func() {
 				}
 			})
 
+			gg.It("must send List key on Put operations", func() {
+				kval := []int{1, 2, 3}
+				key, err := as.NewKey(ns, set, kval)
+				gm.Expect(err).ToNot(gm.HaveOccurred())
+
+				ops1 := []*as.Operation{
+					as.PutOp(bin1),
+					as.PutOp(bin2),
+					as.GetOp(),
+				}
+
+				wpolicy := as.NewWritePolicy(0, 0)
+				wpolicy.SendKey = true
+				rec, err = client.Operate(wpolicy, key, ops1...)
+				gm.Expect(err).ToNot(gm.HaveOccurred())
+
+				recordset, err := client.ScanAll(nil, key.Namespace(), key.SetName())
+				gm.Expect(err).ToNot(gm.HaveOccurred())
+
+				// make sure the result is what we put in
+				for r := range recordset.Results() {
+					gm.Expect(r.Err).ToNot(gm.HaveOccurred())
+					if bytes.Equal(key.Digest(), r.Record.Key.Digest()) {
+						gm.Expect(r.Record.Key.Value()).To(gm.Equal(as.NewListValue([]interface{}{1, 2, 3})))
+						gm.Expect(r.Record.Bins).To(gm.Equal(rec.Bins))
+					}
+				}
+			})
+
 			gg.It("must send key on Touch operations", func() {
 				key, err := as.NewKey(ns, set, randString(50))
 				gm.Expect(err).ToNot(gm.HaveOccurred())

value.go

@@ -1178,23 +1178,30 @@ func bytesToParticle(ptype int, buf []byte, offset int, length int) (interface{}
 	return nil, nil
 }
 
-func bytesToKeyValue(pType int, buf []byte, offset int, len int) (Value, error) {
+func bytesToKeyValue(pType int, buf []byte, offset int, length int) (Value, error) {
 
 	switch pType {
 	case ParticleType.STRING:
-		return NewStringValue(string(buf[offset : offset+len])), nil
+		return NewStringValue(string(buf[offset : offset+length])), nil
 
 	case ParticleType.INTEGER:
-		return NewLongValue(Buffer.VarBytesToInt64(buf, offset, len)), nil
+		return NewLongValue(Buffer.VarBytesToInt64(buf, offset, length)), nil
 
 	case ParticleType.FLOAT:
 		return NewFloatValue(Buffer.BytesToFloat64(buf, offset)), nil
 
 	case ParticleType.BLOB:
-		bytes := make([]byte, len)
-		copy(bytes, buf[offset:offset+len])
+		bytes := make([]byte, length)
+		copy(bytes, buf[offset:offset+length])
 		return NewBytesValue(bytes), nil
 
+	case ParticleType.LIST:
+		v, err := newUnpacker(buf, offset, length).UnpackList()
+		if err != nil {
+			return nil, err
+		}
+		return ListValue(v), nil
+
 	default:
 		return nil, types.NewAerospikeError(types.PARSE_ERROR, fmt.Sprintf("ParticleType %d not recognized. Please file a github issue.", pType))
 	}