Skip to content

Commit 335bcd9

Browse files
committed
tests: add coverage of empty store names for delete bulk state item method
Signed-off-by: mikeee <[email protected]>
1 parent e20871a commit 335bcd9

File tree

1 file changed

+52
-0
lines changed

1 file changed

+52
-0
lines changed

client/state_test.go

+52
Original file line numberDiff line numberDiff line change
@@ -209,6 +209,47 @@ func TestDeleteBulkState(t *testing.T) {
209209
require.NoError(t, err)
210210
})
211211

212+
t.Run("delete bulk state item (empty) store", func(t *testing.T) { // save data
213+
// save data
214+
items := make([]*SetStateItem, 0, len(keys))
215+
for _, key := range keys {
216+
items = append(items, &SetStateItem{
217+
Key: key,
218+
Value: []byte(data),
219+
Metadata: map[string]string{},
220+
Etag: &ETag{Value: "1"},
221+
Options: &StateOptions{
222+
Concurrency: StateConcurrencyFirstWrite,
223+
Consistency: StateConsistencyEventual,
224+
},
225+
})
226+
}
227+
err := testClient.SaveBulkState(ctx, store, items...)
228+
require.NoError(t, err)
229+
230+
// confirm data saved
231+
getItems, err := testClient.GetBulkState(ctx, store, keys, nil, 1)
232+
require.NoError(t, err)
233+
assert.Equal(t, len(keys), len(getItems))
234+
235+
// delete
236+
deleteItems := make([]*DeleteStateItem, 0, len(keys))
237+
for _, key := range keys {
238+
deleteItems = append(deleteItems, &DeleteStateItem{
239+
Key: key,
240+
Metadata: map[string]string{},
241+
Etag: &ETag{Value: "1"},
242+
Options: &StateOptions{
243+
Concurrency: StateConcurrencyFirstWrite,
244+
Consistency: StateConsistencyEventual,
245+
},
246+
})
247+
}
248+
249+
err = testClient.DeleteBulkStateItems(ctx, "", deleteItems)
250+
require.Error(t, err)
251+
})
252+
212253
t.Run("delete exist data", func(t *testing.T) {
213254
// save data
214255
items := make([]*SetStateItem, 0, len(keys))
@@ -396,3 +437,14 @@ func TestQueryState(t *testing.T) {
396437
}
397438
})
398439
}
440+
441+
func TestHasRequiredStateArgs(t *testing.T) {
442+
t.Run("empty store should error", func(t *testing.T) {
443+
err := hasRequiredStateArgs("", "key")
444+
require.Error(t, err)
445+
})
446+
t.Run("empty key should error", func(t *testing.T) {
447+
err := hasRequiredStateArgs("storeName", "")
448+
require.Error(t, err)
449+
})
450+
}

0 commit comments

Comments
 (0)