(ctx context.Context, t *testing.T, contact string, owner string)
| 382 | } |
| 383 | |
| 384 | func searchMessages(ctx context.Context, t *testing.T, contact string, owner string) []httpsms.Message { |
| 385 | t.Helper() |
| 386 | |
| 387 | url := fmt.Sprintf("%s/v1/messages?contact=%s&owner=%s&limit=20&skip=0", apiBaseURL, contact, owner) |
| 388 | req, err := http.NewRequestWithContext(ctx, http.MethodGet, url, nil) |
| 389 | require.NoError(t, err) |
| 390 | req.Header.Set("x-api-key", userAPIKey) |
| 391 | |
| 392 | resp, err := http.DefaultClient.Do(req) |
| 393 | require.NoError(t, err) |
| 394 | defer resp.Body.Close() |
| 395 | |
| 396 | body, err := io.ReadAll(resp.Body) |
| 397 | require.NoError(t, err) |
| 398 | require.Equal(t, http.StatusOK, resp.StatusCode, "search messages failed: %s", string(body)) |
| 399 | |
| 400 | var result struct { |
| 401 | Data []httpsms.Message `json:"data"` |
| 402 | } |
| 403 | require.NoError(t, json.Unmarshal(body, &result)) |
| 404 | return result.Data |
| 405 | } |
| 406 | |
| 407 | func findBulkEntry(entries []BulkMessageEntry, requestID string) *BulkMessageEntry { |
| 408 | for i := range entries { |
no test coverage detected