210
211
t.Run("InvalidMaxMessageID", func(t *testing.T) {
213
>
214
>
queueType := persistence.QueueTypeHistoryNormal
215
>
queueName := "test-queue-" + t.Name()
216
>
_, err := queue.CreateQueue(ctx, &persistence.InternalCreateQueueRequest{
217
>
QueueType: queueType,
218
>
QueueName: queueName,
219
>
})
220
>
require.NoError(t, err)
221
>
_, err = queue.RangeDeleteMessages(ctx, &persistence.InternalRangeDeleteMessagesRequest{
222
>
QueueType: queueType,
223
>
QueueName: queueName,
224
>
InclusiveMaxMessageMetadata: persistence.MessageMetadata{
225
>
ID: persistence.FirstQueueMessageID - 1,
226
>
},
227
>
})
228
>
require.Error(t, err)
229
>
assert.ErrorIs(t, err, persistence.ErrInvalidQueueRangeDeleteMaxMessageID)
230
>
assert.ErrorContains(t, err, strconv.Itoa(persistence.FirstQueueMessageID-1))
231
>
assert.ErrorContains(t, err, strconv.Itoa(persistence.FirstQueueMessageID))
232
>
})
233
234
t.Run("HappyPath", func(t *testing.T) {