chore: verify pointer responses

momento/dictionary_test.go

@@ -485,10 +485,7 @@ var _ = Describe("Dictionary methods", func() {
 				case *DictionaryGetFieldsHit:
 					Expect(result.ValueMap()).To(BeEmpty())
 					for _, value := range result.Responses() {
-						switch value.(type) {
-						case *DictionaryGetFieldHit:
-							Fail("got a hit response for a field that should return a miss")
-						}
+						Expect(value).To(BeAssignableToTypeOf(&DictionaryGetFieldMiss{}))
 					}
 				}
 			})

momento/list_test.go

@@ -2,6 +2,7 @@ package momento_test
 
 import (
 	"fmt"
+	"sort"
 
 	"github.com/google/uuid"
 	. "github.com/momentohq/client-sdk-go/momento"
@@ -148,12 +149,23 @@ var _ = Describe("List methods", func() {
 
 			It("pushes strings and bytes on the happy path", func() {
 				numItems := 10
-				expected := populateList(sharedContext, numItems)
+				values, expected := getValueAndExpectedValueLists(numItems)
+				sort.Sort(sort.Reverse(sort.StringSlice(expected)))
+				for _, value := range values {
+					Expect(
+						sharedContext.Client.ListPushFront(sharedContext.Ctx, &ListPushFrontRequest{
+							CacheName: sharedContext.CacheName,
+							ListName:  sharedContext.CollectionName,
+							Value:     value,
+						}),
+					).To(BeAssignableToTypeOf(&ListPushFrontSuccess{}))
+				}
 				fetchResp, err := sharedContext.Client.ListFetch(sharedContext.Ctx, &ListFetchRequest{
 					CacheName: sharedContext.CacheName,
 					ListName:  sharedContext.CollectionName,
 				})
 				Expect(err).To(BeNil())
+				Expect(fetchResp).To(BeAssignableToTypeOf(&ListFetchHit{}))
 				Expect(fetchResp).To(HaveListLength(numItems))
 				switch result := fetchResp.(type) {
 				case *ListFetchHit:

momento/scalar_test.go

@@ -114,6 +114,15 @@ var _ = Describe("Scalar methods", func() {
 		).Error().To(HaveMomentoErrorCode(InvalidArgumentError))
 	})
 
+	It("returns a miss when the key doesn't exist", func() {
+		Expect(
+			sharedContext.Client.Get(sharedContext.Ctx, &GetRequest{
+				CacheName: sharedContext.CacheName,
+				Key:       String(uuid.NewString()),
+			}),
+		).To(BeAssignableToTypeOf(&GetMiss{}))
+	})
+
 	DescribeTable(`invalid cache names and keys`,
 		func(cacheName string, key Key, value Key) {
 			getResp, err := sharedContext.Client.Get(sharedContext.Ctx, &GetRequest{

momento/set_test.go

@@ -111,6 +111,15 @@ var _ = Describe("Set methods", func() {
 		).Error().To(HaveMomentoErrorCode(InvalidArgumentError))
 	})
 
+	It("gets a miss trying to fetch a nonexistent set", func() {
+		Expect(
+			sharedContext.Client.SetFetch(sharedContext.Ctx, &SetFetchRequest{
+				CacheName: sharedContext.CacheName,
+				SetName:   uuid.NewString(),
+			}),
+		).To(BeAssignableToTypeOf(&SetFetchMiss{}))
+	})
+
 	Describe("add", func() {
 		DescribeTable("add string and byte single elements happy path",
 			func(element Value, expectedStrings []string, expectedBytes [][]byte) {

momento/topic_client.go

@@ -119,6 +119,7 @@ func (c defaultTopicClient) Publish(ctx context.Context, request *TopicPublishRe
 
 	return &responses.TopicPublishSuccess{}, err
 }
+
 func (c defaultTopicClient) Close() {
 	defer c.pubSubClient.Close()
 }

momento/topic_value.go

@@ -1,5 +1,6 @@
 package momento
 
+// TopicValue
 // For now, topics take the same types as normal methods.
 // In the future this might not be so, topics might take
 // different types than methods.