1package systemviewsbridge
2
3import (
4 "context"
5 "encoding/json"
6 "errors"
7 "testing"
8 "time"
9
10 "github.com/bnema/dumber/internal/application/dto"
11 "github.com/bnema/dumber/internal/application/port"
12 systemviewsbridgemocks "github.com/bnema/dumber/internal/infrastructure/systemviewsbridge/mocks"
13 "github.com/stretchr/testify/mock"
14)
15
16func TestBuildMessageEnvelope(t *testing.T) {
17 t.Parallel()
18
19 payload := struct {
20 RequestID string `json:"requestId"`
21 Limit int `json:"limit"`
22 }{RequestID: "req-1", Limit: 25}
23
24 got, err := buildMessageEnvelope("history_timeline", payload)
25 if err != nil {
26 t.Fatalf("buildMessageEnvelope() error = %v", err)
27 }
28
29 var msg port.WebUIMessage
30 if err := json.Unmarshal(got, &msg); err != nil {
31 t.Fatalf("unmarshal envelope: %v", err)
32 }
33
34 if msg.Type != "history_timeline" {
35 t.Fatalf("msg.Type = %q, want %q", msg.Type, "history_timeline")
36 }
37
38 if gotPayload := string(msg.Payload); gotPayload != `{"requestId":"req-1","limit":25}` {
39 t.Fatalf("msg.Payload = %s, want %s", gotPayload, `{"requestId":"req-1","limit":25}`)
40 }
41}
42
43func TestClientSendPrefersNativeTransport(t *testing.T) {
44 t.Parallel()
45
46 native := newTransportRecorder(t, true, []byte(`{"transport":"native"}`))
47 fetch := newTransportRecorder(t, true, []byte(`{"transport":"fetch"}`))
48
49 client := NewClient(native, fetch)
50 got, err := client.Send(context.Background(), "favorite_list", struct {
51 RequestID string `json:"requestId"`
52 }{RequestID: "req-2"})
53 if err != nil {
54 t.Fatalf("Send() error = %v", err)
55 }
56
57 if string(got) != `{"transport":"native"}` {
58 t.Fatalf("Send() = %s, want %s", got, `{"transport":"native"}`)
59 }
60
61 if !native.called {
62 t.Fatal("native transport was not used")
63 }
64 if fetch.called {
65 t.Fatal("fetch transport was used unexpectedly")
66 }
67
68 var msg port.WebUIMessage
69 if err := json.Unmarshal(native.last, &msg); err != nil {
70 t.Fatalf("unmarshal sent envelope: %v", err)
71 }
72 if msg.Type != "favorite_list" {
73 t.Fatalf("sent type = %q, want %q", msg.Type, "favorite_list")
74 }
75}
76
77func TestClientSendFallsBackToFetchTransport(t *testing.T) {
78 t.Parallel()
79
80 native := newTransportRecorder(t, false, []byte(`{"transport":"native"}`))
81 fetch := newTransportRecorder(t, true, []byte(`{"transport":"fetch"}`))
82
83 client := NewClient(native, fetch)
84 got, err := client.Send(context.Background(), "favorite_list", struct {
85 RequestID string `json:"requestId"`
86 }{RequestID: "req-3"})
87 if err != nil {
88 t.Fatalf("Send() error = %v", err)
89 }
90
91 if string(got) != `{"transport":"fetch"}` {
92 t.Fatalf("Send() = %s, want %s", got, `{"transport":"fetch"}`)
93 }
94
95 if native.called {
96 t.Fatal("native transport was used unexpectedly")
97 }
98 if !fetch.called {
99 t.Fatal("fetch transport was not used")
100 }
101}
102
103func TestClientTimelineDecodesEntries(t *testing.T) {
104 t.Parallel()
105
106 native := newTransportRecorder(t, true, []byte(`{"requestId":"req-9","success":true,"data":[{"id":1,"url":"https://example.com","title":"Example"}]}`))
107 client := NewClient(native, nil)
108
109 entries, err := client.Timeline(context.Background(), 25, 0)
110 if err != nil {
111 t.Fatalf("Timeline() error = %v", err)
112 }
113 if len(entries) != 1 {
114 t.Fatalf("Timeline() len = %d, want 1", len(entries))
115 }
116 if entries[0].URL != "https://example.com" || entries[0].Title != "Example" {
117 t.Fatalf("Timeline() entry = %+v", entries[0])
118 }
119
120 var msg port.WebUIMessage
121 if err := json.Unmarshal(native.last, &msg); err != nil {
122 t.Fatalf("unmarshal sent envelope: %v", err)
123 }
124 if msg.Type != "history_timeline" {
125 t.Fatalf("sent type = %q, want %q", msg.Type, "history_timeline")
126 }
127 if gotPayload := string(msg.Payload); gotPayload == "" {
128 t.Fatal("sent payload was empty")
129 }
130}
131
132func TestClientTimelineWindowOmitsZeroCursor(t *testing.T) {
133 t.Parallel()
134
135 native := newTransportRecorder(t, true, []byte(`{"requestId":"req-window","success":true}`))
136 client := NewClient(native, nil)
137
138 _, err := client.TimelineWindow(context.Background(), time.Time{}, 0, "")
139 if err != nil {
140 t.Fatalf("TimelineWindow() error = %v", err)
141 }
142
143 var msg port.WebUIMessage
144 if err := json.Unmarshal(native.last, &msg); err != nil {
145 t.Fatalf("unmarshal sent envelope: %v", err)
146 }
147 if msg.Type != "history_timeline_window" {
148 t.Fatalf("sent type = %q, want %q", msg.Type, "history_timeline_window")
149 }
150 var payload map[string]any
151 if err := json.Unmarshal(msg.Payload, &payload); err != nil {
152 t.Fatalf("unmarshal payload: %v", err)
153 }
154 if _, ok := payload["before"]; ok {
155 t.Fatalf("zero TimelineWindow cursor should be omit before, payload = %s", msg.Payload)
156 }
157 if _, ok := payload["beforeId"]; ok {
158 t.Fatalf("zero TimelineWindow cursor should omit beforeId, payload = %s", msg.Payload)
159 }
160}
161
162func TestClientTimelineWindowSendsCompleteCursor(t *testing.T) {
163 t.Parallel()
164
165 native := newTransportRecorder(t, true, []byte(`{"requestId":"req-window","success":true}`))
166 client := NewClient(native, nil)
167 before := time.Date(2026, 4, 25, 9, 0, 0, 0, time.UTC)
168
169 _, err := client.TimelineWindow(context.Background(), before, 42, "example.com")
170 if err != nil {
171 t.Fatalf("TimelineWindow() error = %v", err)
172 }
173
174 var msg port.WebUIMessage
175 if err := json.Unmarshal(native.last, &msg); err != nil {
176 t.Fatalf("unmarshal sent envelope: %v", err)
177 }
178 var payload map[string]any
179 if err := json.Unmarshal(msg.Payload, &payload); err != nil {
180 t.Fatalf("unmarshal payload: %v", err)
181 }
182 if payload["before"] != before.Format(time.RFC3339Nano) {
183 t.Fatalf("before = %v, want %s", payload["before"], before.Format(time.RFC3339Nano))
184 }
185 if payload["beforeId"] != float64(42) {
186 t.Fatalf("beforeId = %v, want 42", payload["beforeId"])
187 }
188}
189
190func TestClientTimelineWindowRejectsPartialCursor(t *testing.T) {
191 t.Parallel()
192
193 native := newTransportRecorder(t, true, []byte(`{"requestId":"req-window","success":true}`))
194 client := NewClient(native, nil)
195 before := time.Date(2026, 4, 25, 9, 0, 0, 0, time.UTC)
196
197 if _, err := client.TimelineWindow(context.Background(), before, 0, ""); err == nil {
198 t.Fatal("TimelineWindow(before without beforeID) error = nil")
199 }
200 if _, err := client.TimelineWindow(context.Background(), time.Time{}, 42, ""); err == nil {
201 t.Fatal("TimelineWindow(beforeID without before) error = nil")
202 }
203 if _, err := client.TimelineWindow(context.Background(), time.Time{}, -1, ""); err == nil {
204 t.Fatal("TimelineWindow(negative beforeID without before) error = nil")
205 }
206 if native.called {
207 t.Fatal("TimelineWindow sent request for invalid partial cursor")
208 }
209}
210
211func TestClientDeleteRangeRejectsEmptyRange(t *testing.T) {
212 t.Parallel()
213
214 transport := newTransportRecorder(t, true, []byte(`{"requestId":"req-range-empty","success":true}`))
215 client := NewClient(transport, nil)
216
217 err := client.DeleteRange(context.Background(), " ")
218 if err == nil {
219 t.Fatal("DeleteRange() error = nil, want validation error")
220 }
221 if transport.called {
222 t.Fatal("DeleteRange() sent a request for an invalid range")
223 }
224}
225
226func TestClientDeleteRangeSendsRange(t *testing.T) {
227 t.Parallel()
228
229 native := newTransportRecorder(t, true, []byte(`{"requestId":"req-10","success":true}`))
230 client := NewClient(native, nil)
231
232 if err := client.DeleteRange(context.Background(), "week"); err != nil {
233 t.Fatalf("DeleteRange() error = %v", err)
234 }
235
236 var msg port.WebUIMessage
237 if err := json.Unmarshal(native.last, &msg); err != nil {
238 t.Fatalf("unmarshal sent envelope: %v", err)
239 }
240 if msg.Type != "history_delete_range" {
241 t.Fatalf("sent type = %q, want %q", msg.Type, "history_delete_range")
242 }
243}
244
245func TestClientListDecodesFavorites(t *testing.T) {
246 t.Parallel()
247
248 native := newTransportRecorder(t, true, []byte(`{"requestId":"req-11","success":true,"data":[{"id":1,"url":"https://example.com","title":"Example"}]}`))
249 client := NewClient(native, nil)
250
251 favorites, err := client.List(context.Background())
252 if err != nil {
253 t.Fatalf("List() error = %v", err)
254 }
255 if len(favorites) != 1 {
256 t.Fatalf("List() len = %d, want 1", len(favorites))
257 }
258 if favorites[0].URL != "https://example.com" || favorites[0].Title != "Example" {
259 t.Fatalf("List() favorite = %+v", favorites[0])
260 }
261
262 var msg port.WebUIMessage
263 if err := json.Unmarshal(native.last, &msg); err != nil {
264 t.Fatalf("unmarshal sent envelope: %v", err)
265 }
266 if msg.Type != "favorite_list" {
267 t.Fatalf("sent type = %q, want %q", msg.Type, "favorite_list")
268 }
269}
270
271func TestClientListTagsDecodesTags(t *testing.T) {
272 t.Parallel()
273
274 native := newTransportRecorder(t, true, []byte(`{"requestId":"req-13","success":true,"data":[{"id":5,"name":"Go","color":"#00ff00"}]}`))
275 client := NewClient(native, nil)
276
277 tags, err := client.ListTags(context.Background())
278 if err != nil {
279 t.Fatalf("ListTags() error = %v", err)
280 }
281 if len(tags) != 1 {
282 t.Fatalf("ListTags() len = %d, want 1", len(tags))
283 }
284 if tags[0].Name != "Go" || tags[0].Color != "#00ff00" {
285 t.Fatalf("ListTags() tag = %+v", tags[0])
286 }
287
288 var msg port.WebUIMessage
289 if err := json.Unmarshal(native.last, &msg); err != nil {
290 t.Fatalf("unmarshal sent envelope: %v", err)
291 }
292 if msg.Type != "tag_list" {
293 t.Fatalf("sent type = %q, want %q", msg.Type, "tag_list")
294 }
295}
296
297func TestClientCurrentAndDefaultDecodeConfigPayload(t *testing.T) {
298 t.Parallel()
299
300 resp := []byte(`{"requestId":"req-14","success":true,"data":{"engine_type":"webkit","default_search_engine":"DuckDuckGo"}}`)
301
302 currentTransport := newTransportRecorder(t, true, resp)
303 currentClient := NewClient(currentTransport, nil)
304 current, err := currentClient.Current(context.Background())
305 if err != nil {
306 t.Fatalf("Current() error = %v", err)
307 }
308 if current.EngineType != "webkit" || current.DefaultSearchEngine != "DuckDuckGo" {
309 t.Fatalf("Current() = %+v", current)
310 }
311
312 var msg port.WebUIMessage
313 if unmarshalErr := json.Unmarshal(currentTransport.last, &msg); unmarshalErr != nil {
314 t.Fatalf("unmarshal sent envelope: %v", unmarshalErr)
315 }
316 if msg.Type != "/api/config" {
317 t.Fatalf("sent type = %q, want %q", msg.Type, "/api/config")
318 }
319
320 defaultTransport := newTransportRecorder(t, true, resp)
321 defaultClient := NewClient(defaultTransport, nil)
322 defaultCfg, err := defaultClient.Default(context.Background())
323 if err != nil {
324 t.Fatalf("Default() error = %v", err)
325 }
326 if defaultCfg.EngineType != "webkit" || defaultCfg.DefaultSearchEngine != "DuckDuckGo" {
327 t.Fatalf("Default() = %+v", defaultCfg)
328 }
329
330 if err := json.Unmarshal(defaultTransport.last, &msg); err != nil {
331 t.Fatalf("unmarshal sent envelope: %v", err)
332 }
333 if msg.Type != "/api/config/default" {
334 t.Fatalf("sent type = %q, want %q", msg.Type, "/api/config/default")
335 }
336}
337
338func TestClientConfigActionsUseExpectedMessageTypes(t *testing.T) {
339 t.Parallel()
340
341 tests := []struct {
342 name string
343 call func(*testing.T, *Client) error
344 want string
345 payload any
346 }{
347 {
348 name: "save config",
349 call: func(_ *testing.T, client *Client) error {
350 return client.Save(context.Background(), dto.WebUIConfig{DefaultSearchEngine: "DuckDuckGo"})
351 },
352 want: "save_config",
353 payload: dto.WebUIConfig{DefaultSearchEngine: "DuckDuckGo"},
354 },
355 {
356 name: "get keybindings",
357 call: func(t *testing.T, client *Client) error {
358 got, err := client.GetKeybindings(context.Background())
359 if err != nil {
360 return err
361 }
362 if len(got.Groups) != 1 || got.Groups[0].Mode != "default" {
363 t.Fatalf("GetKeybindings() = %#v", got)
364 }
365 return nil
366 },
367 want: "get_keybindings",
368 },
369 {
370 name: "set keybinding",
371 call: func(t *testing.T, client *Client) error {
372 got, err := client.SetKeybinding(context.Background(), port.SetKeybindingRequest{RequestID: "req-1", Mode: "default", Action: "open", Keys: []string{"ctrl+o"}})
373 if err != nil {
374 return err
375 }
376 if len(got.Conflicts) != 0 {
377 t.Fatalf("SetKeybinding() = %#v", got)
378 }
379 return nil
380 },
381 want: "set_keybinding",
382 payload: port.SetKeybindingRequest{RequestID: "req-1", Mode: "default", Action: "open", Keys: []string{"ctrl+o"}},
383 },
384 {
385 name: "reset keybinding",
386 call: func(_ *testing.T, client *Client) error {
387 return client.ResetKeybinding(context.Background(), port.ResetKeybindingRequest{RequestID: "req-2", Mode: "default", Action: "open"})
388 },
389 want: "reset_keybinding",
390 payload: port.ResetKeybindingRequest{RequestID: "req-2", Mode: "default", Action: "open"},
391 },
392 {
393 name: "reset all keybindings",
394 call: func(_ *testing.T, client *Client) error {
395 return client.ResetAllKeybindings(context.Background())
396 },
397 want: "reset_all_keybindings",
398 },
399 }
400
401 for _, tt := range tests {
402 t.Run(tt.name, func(t *testing.T) {
403 t.Parallel()
404
405 transport := newTransportRecorder(t, true, []byte(`{"requestId":"req-15","success":true,"data":{"status":"success","conflicts":[]}}`))
406 if tt.name == "save config" || tt.name == "reset keybinding" || tt.name == "reset all keybindings" {
407 transport.response = []byte(`{"requestId":"req-15","success":true}`)
408 }
409 if tt.name == "get keybindings" {
410 transport.response = []byte(`{"requestId":"req-15","success":true,"data":{"groups":[{"mode":"default","display_name":"Default","bindings":[{"action":"open","description":"Open","keys":["ctrl+o"],"default_keys":["ctrl+o"],"is_custom":false}]}]}}`)
411 }
412 client := NewClient(transport, nil)
413
414 if err := tt.call(t, client); err != nil {
415 t.Fatalf("call() error = %v", err)
416 }
417
418 var msg port.WebUIMessage
419 if err := json.Unmarshal(transport.last, &msg); err != nil {
420 t.Fatalf("unmarshal sent envelope: %v", err)
421 }
422 if msg.Type != tt.want {
423 t.Fatalf("sent type = %q, want %q", msg.Type, tt.want)
424 }
425 if tt.payload != nil && len(msg.Payload) == 0 {
426 t.Fatal("sent payload was empty")
427 }
428 })
429 }
430}
431
432func TestClientRequestUsesDefaultTimeoutWhenCallerHasNoDeadline(t *testing.T) {
433 t.Parallel()
434
435 transport := &blockingTransport{available: true}
436 client := NewClient(transport, nil, WithRequestTimeout(time.Millisecond))
437
438 _, err := client.Timeline(context.Background(), 25, 0)
439 if !errors.Is(err, context.DeadlineExceeded) {
440 t.Fatalf("Timeline() error = %v, want context deadline exceeded", err)
441 }
442 if !transport.called {
443 t.Fatal("transport was not called")
444 }
445}
446
447func TestClientDomainStatsRejectsNegativeLimit(t *testing.T) {
448 t.Parallel()
449
450 transport := newTransportRecorder(t, true, []byte(`{"requestId":"req-17","success":true,"data":[]}`))
451 client := NewClient(transport, nil)
452
453 _, err := client.DomainStats(context.Background(), -1)
454 if err == nil {
455 t.Fatal("DomainStats() error = nil, want validation error")
456 }
457 if transport.called {
458 t.Fatal("DomainStats() sent a request for a negative limit")
459 }
460}
461
462func TestClientDeleteDomainRejectsEmptyDomain(t *testing.T) {
463 t.Parallel()
464
465 transport := newTransportRecorder(t, true, []byte(`{"requestId":"req-domain-empty","success":true}`))
466 client := NewClient(transport, nil)
467
468 err := client.DeleteDomain(context.Background(), " ")
469 if err == nil {
470 t.Fatal("DeleteDomain() error = nil, want validation error")
471 }
472 if transport.called {
473 t.Fatal("DeleteDomain() sent a request for an empty domain")
474 }
475}
476
477func TestClientDeleteEntryRejectsInvalidID(t *testing.T) {
478 t.Parallel()
479
480 transport := newTransportRecorder(t, true, []byte(`{"requestId":"req-20","success":true}`))
481 client := NewClient(transport, nil)
482
483 err := client.DeleteEntry(context.Background(), 0)
484 if err == nil {
485 t.Fatal("DeleteEntry() error = nil, want validation error")
486 }
487 if transport.called {
488 t.Fatal("DeleteEntry() sent a request for an invalid id")
489 }
490}
491
492func TestClientTagActionsTrimFields(t *testing.T) {
493 t.Parallel()
494
495 createTransport := newTransportRecorder(t, true, []byte(`{"requestId":"req-21","success":true,"data":{"id":5,"name":"Go","color":"#00add8"}}`))
496 client := NewClient(createTransport, nil)
497 if _, err := client.CreateTag(context.Background(), " Go ", " #00add8 "); err != nil {
498 t.Fatalf("CreateTag() error = %v", err)
499 }
500 var msg port.WebUIMessage
501 if err := json.Unmarshal(createTransport.last, &msg); err != nil {
502 t.Fatalf("unmarshal create envelope: %v", err)
503 }
504 var createPayload struct {
505 Name string `json:"name"`
506 Color *string `json:"color"`
507 }
508 if err := json.Unmarshal(msg.Payload, &createPayload); err != nil {
509 t.Fatalf("unmarshal create payload: %v", err)
510 }
511 if createPayload.Name != "Go" || createPayload.Color == nil || *createPayload.Color != "#00add8" {
512 t.Fatalf("CreateTag payload = %#v", createPayload)
513 }
514
515 updateTransport := newTransportRecorder(t, true, []byte(`{"requestId":"req-22","success":true}`))
516 client = NewClient(updateTransport, nil)
517 if err := client.UpdateTag(context.Background(), 5, " Go ", " "); err != nil {
518 t.Fatalf("UpdateTag() error = %v", err)
519 }
520 if err := json.Unmarshal(updateTransport.last, &msg); err != nil {
521 t.Fatalf("unmarshal update envelope: %v", err)
522 }
523 var updatePayload struct {
524 Name *string `json:"name"`
525 Color *string `json:"color"`
526 }
527 if err := json.Unmarshal(msg.Payload, &updatePayload); err != nil {
528 t.Fatalf("unmarshal update payload: %v", err)
529 }
530 if updatePayload.Name == nil || *updatePayload.Name != "Go" || updatePayload.Color != nil {
531 t.Fatalf("UpdateTag payload = %#v", updatePayload)
532 }
533}
534
535type transportRecorder struct {
536 *systemviewsbridgemocks.MockTransport
537
538 available bool
539 called bool
540 last []byte
541 response []byte
542}
543
544func newTransportRecorder(t *testing.T, available bool, response []byte) *transportRecorder {
545 t.Helper()
546
547 recorder := &transportRecorder{
548 MockTransport: systemviewsbridgemocks.NewMockTransport(t),
549 available: available,
550 response: response,
551 }
552 recorder.EXPECT().Available().RunAndReturn(func() bool { return recorder.available }).Maybe()
553 recorder.EXPECT().Send(mock.Anything, mock.Anything).RunAndReturn(recorder.send).Maybe()
554 return recorder
555}
556
557func (t *transportRecorder) send(_ context.Context, body []byte) ([]byte, error) {
558 t.called = true
559 t.last = append(t.last[:0], body...)
560 return t.response, nil
561}
562
563type blockingTransport struct {
564 available bool
565 called bool
566}
567
568func (t *blockingTransport) Available() bool { return t.available }
569
570func (t *blockingTransport) Send(ctx context.Context, _ []byte) ([]byte, error) {
571 t.called = true
572 <-ctx.Done()
573 return nil, ctx.Err()
574}
575
576func TestClientRejectsInvalidFavoriteMutationIDs(t *testing.T) {
577 t.Parallel()
578
579 transport := newTransportRecorder(t, true, []byte(`{"requestId":"req","success":true}`))
580 client := NewClient(transport, nil)
581
582 checks := []struct {
583 name string
584 call func() error
585 }{
586 {name: "delete favorite", call: func() error { return client.DeleteFavorite(context.Background(), 0) }},
587 {name: "set shortcut", call: func() error { return client.SetShortcut(context.Background(), 0, nil) }},
588 {name: "create tag", call: func() error { _, err := client.CreateTag(context.Background(), " ", ""); return err }},
589 {name: "update tag", call: func() error { return client.UpdateTag(context.Background(), 0, "Tag", "") }},
590 {name: "update tag name", call: func() error { return client.UpdateTag(context.Background(), 1, " ", "") }},
591 {name: "delete tag", call: func() error { return client.DeleteTag(context.Background(), 0) }},
592 {name: "assign favorite", call: func() error { return client.AssignTag(context.Background(), 0, 1) }},
593 {name: "assign tag", call: func() error { return client.AssignTag(context.Background(), 1, 0) }},
594 {name: "remove favorite", call: func() error { return client.RemoveTag(context.Background(), 0, 1) }},
595 {name: "remove tag", call: func() error { return client.RemoveTag(context.Background(), 1, 0) }},
596 }
597 for _, check := range checks {
598 t.Run(check.name, func(t *testing.T) {
599 if err := check.call(); err == nil {
600 t.Fatal("error = nil, want validation error")
601 }
602 })
603 }
604 if transport.called {
605 t.Fatal("transport called for invalid favorite mutation IDs")
606 }
607}
608
609func TestClientRejectsNegativeHistoryLimits(t *testing.T) {
610 t.Parallel()
611
612 client := NewClient(newTransportRecorder(t, true, nil), nil)
613
614 if _, err := client.Timeline(context.Background(), -1, 0); err == nil {
615 t.Fatal("Timeline() error = nil, want error")
616 }
617 if _, err := client.Timeline(context.Background(), 1, -1); err == nil {
618 t.Fatal("Timeline() error = nil, want error")
619 }
620 if _, err := client.TimelineByDomain(context.Background(), "", 1, 0); err == nil {
621 t.Fatal("TimelineByDomain() error = nil, want error")
622 }
623 if _, err := client.TimelineByDomain(context.Background(), "example.com", -1, 0); err == nil {
624 t.Fatal("TimelineByDomain() error = nil, want error")
625 }
626 if _, err := client.TimelineByDomain(context.Background(), "example.com", 1, -1); err == nil {
627 t.Fatal("TimelineByDomain() error = nil, want error")
628 }
629 if _, err := client.Search(context.Background(), "example", -1); err == nil {
630 t.Fatal("Search() error = nil, want error")
631 }
632}