(ctx context.Context, t *testing.T)
| 359 | } |
| 360 | |
| 361 | func fetchBulkMessages(ctx context.Context, t *testing.T) []BulkMessageEntry { |
| 362 | t.Helper() |
| 363 | |
| 364 | url := apiBaseURL + "/v1/bulk-messages" |
| 365 | req, err := http.NewRequestWithContext(ctx, http.MethodGet, url, nil) |
| 366 | require.NoError(t, err) |
| 367 | req.Header.Set("x-api-key", userAPIKey) |
| 368 | |
| 369 | resp, err := http.DefaultClient.Do(req) |
| 370 | require.NoError(t, err) |
| 371 | defer resp.Body.Close() |
| 372 | |
| 373 | body, err := io.ReadAll(resp.Body) |
| 374 | require.NoError(t, err) |
| 375 | require.Equal(t, http.StatusOK, resp.StatusCode, "fetch bulk messages failed: %s", string(body)) |
| 376 | |
| 377 | var result struct { |
| 378 | Data []BulkMessageEntry `json:"data"` |
| 379 | } |
| 380 | require.NoError(t, json.Unmarshal(body, &result)) |
| 381 | return result.Data |
| 382 | } |
| 383 | |
| 384 | func searchMessages(ctx context.Context, t *testing.T, contact string, owner string) []httpsms.Message { |
| 385 | t.Helper() |
no test coverage detected