Changeset View
Changeset View
Standalone View
Standalone View
swh/search/tests/test_cli.py
| Show First 20 Lines • Show All 141 Lines • ▼ Show 20 Lines | ): | ||||
| # Check the output | # Check the output | ||||
| expected_output = "Processed 1 messages.\nDone.\n" | expected_output = "Processed 1 messages.\nDone.\n" | ||||
| assert result.exit_code == 0, result.output | assert result.exit_code == 0, result.output | ||||
| assert result.output == expected_output | assert result.output == expected_output | ||||
| swh_search.flush() | swh_search.flush() | ||||
| # Both search returns the visit | |||||
| actual_page = swh_search.origin_search(url_pattern="foobar", with_visit=False) | actual_page = swh_search.origin_search(url_pattern="foobar", with_visit=False) | ||||
| assert actual_page.next_page_token is None | assert actual_page.next_page_token is None | ||||
| assert actual_page.results == [origin_foobar] | assert actual_page.results == [origin_foobar] | ||||
| # Not considered visited unless the visit is full | |||||
| actual_page = swh_search.origin_search(url_pattern="foobar", with_visit=True) | actual_page = swh_search.origin_search(url_pattern="foobar", with_visit=True) | ||||
| assert actual_page.next_page_token is None | assert actual_page.next_page_token is None | ||||
| assert actual_page.results == [origin_foobar] | assert actual_page.results == [] | ||||
| def test__journal_client__origin_visit_status( | def test__journal_client__origin_visit_status( | ||||
| swh_search, elasticsearch_host, kafka_prefix: str, kafka_server | swh_search, elasticsearch_host, kafka_prefix: str, kafka_server | ||||
| ): | ): | ||||
| """Subscribing to origin-visit-status should result in swh-search indexation | """Subscribing to origin-visit-status should result in swh-search indexation | ||||
| """ | """ | ||||
| ▲ Show 20 Lines • Show All 246 Lines • Show Last 20 Lines | |||||