Migrate all tests from aresponses to KMock

Signed-off-by: Sergey Vasilyev <nolar@nolar.info>

Author: nolar

docs/testing.rst

@@ -40,3 +40,30 @@ exit code and output are available to the test (for additional assertions).
 .. note::
     The operator runs against the cluster which is currently authenticated ---
     same as if would be executed with `kopf run`.
+
+
+Mock server
+===========
+
+KMock is a supplimentary project to run a local mock server for any HTTP API, and for Kubernetes API in particular — with extended supported of Kubernetes API endpoints, resource discovery, and implicit in-memory object persistence.
+
+Use KMock when you need to run a very lightweight simulation of the Kubernetes API without deploying the heavy Kubernetes cluster nearby, for example when migrating to/from Kopf.
+
+
+.. code-block:: python
+
+    import kmock
+    import requests
+
+    def test_object_patching(kmock: kmock.KubernetesEmulator) -> None:
+        kmock.objects['kopf.dev/v1/kopfexamples', 'ns1', 'name1'] = {'spec': 123}
+        requests.patch(str(kmock.url) + '/kopf.dev/v1/namespaces/ns1/name1', json={'spec': 456})
+        assert len(kmock.requests) == 1
+        assert kmock.requests[0].method == 'patch'
+        assert kmock.objects['kopf.dev/v1/kopfexamples', 'ns1', 'name1'] == {'spec': 456}
+
+KMock's detailed documentation is out of scope of Kopf's documentation. The project and its documentation can be found at:
+
+* https://kmock.readthedocs.io/
+* https://github.com/nolar/kmock
+* https://pypi.org/project/kmock/

kopf/_cogs/aiokits/aiotasks.py

@@ -344,6 +344,13 @@ async def spawn(
             await self._pending_coros.put(SchedulerJob(coro=coro, name=name))
             self._condition.notify_all()  # -> task_spawner()
 
+        # Give the spawner some asyncio cycles to actually spawn and maybe end the task instantly.
+        # This barely ever happens with real worker(); it is mainly for tests in `test_queueing.py`:
+        # Depending on luck, they were arriving to `_wait_for_depletion()` with their mocked workers
+        # either "done", or "pending", thus giving looptime==0 or looptime==exit_timeout (randomly).
+        # With this extra sleep, such mocked workers are now "done" and the looptime==0.
+        await asyncio.sleep(0)
+
     def _can_spawn(self) -> bool:
         return (not self._pending_coros.empty() and
                 (self._limit is None or len(self._running_tasks) < self._limit))

pyproject.toml

@@ -70,13 +70,13 @@ docs = [
     "furo",
 ]
 test = [
-    "aresponses",
     "astpath[xpath]",
     "certbuilder",
     "certvalidator",
     "codecov",
     "coverage>=7.12.0",
     "freezegun",
+    "kmock>=0.3",
     "looptime>=0.7",
     "lxml",
     "pyngrok",

tests/admission/test_webhook_detection.py

@@ -7,7 +7,7 @@
 # so we mock all external(!) libraries to return the results as we expect them.
 # This reduces the quality of the tests, but makes them simple.
 @pytest.fixture(autouse=True)
-def pathmock(mocker, fake_vault, enforced_context, aresponses, hostname):
+def pathmock(mocker, fake_vault):
     mocker.patch('ssl.get_server_certificate', return_value='')
     mocker.patch('certvalidator.ValidationContext')
     validator = mocker.patch('certvalidator.CertificateValidator')
@@ -17,14 +17,14 @@ def pathmock(mocker, fake_vault, enforced_context, aresponses, hostname):
     return pathmock
 
 
-async def test_no_detection(hostname, aresponses):
-    aresponses.add(hostname, '/version', 'get', {'gitVersion': 'v1.2.3'})
+async def test_no_detection(kmock):
+    kmock['get /version'] << {'gitVersion': 'v1.2.3'}
     hostname = await ClusterDetector().guess_host()
     assert hostname is None
 
 
-async def test_dependencies(hostname, aresponses, no_certvalidator):
-    aresponses.add(hostname, '/version', 'get', {'gitVersion': 'v1.2.3'})
+async def test_dependencies(kmock, no_certvalidator):
+    kmock['get /version'] << {'gitVersion': 'v1.2.3'}
     with pytest.raises(ImportError) as err:
         await ClusterDetector().guess_host()
     assert "pip install certvalidator" in str(err.value)
@@ -60,46 +60,41 @@ async def test_k3d_via_subject_org(pathmock):
     assert hostname == 'host.k3d.internal'
 
 
-async def test_k3d_via_version_infix(hostname, aresponses):
-    aresponses.add(hostname, '/version', 'get', {'gitVersion': 'v1.20.4+k3s1'})
+async def test_k3d_via_version_infix(kmock):
+    kmock['get /version'] << {'gitVersion': 'v1.20.4+k3s1'}
     hostname = await ClusterDetector().guess_host()
     assert hostname == 'host.k3d.internal'
 
 
-async def test_server_detects(responder, aresponses, hostname, caplog, assert_logs):
-    caplog.set_level(0)
-    aresponses.add(hostname, '/version', 'get', {'gitVersion': 'v1.20.4+k3s1'})
+async def test_server_detects(kmock, responder, assert_logs):
+    kmock['get /version'] << {'gitVersion': 'v1.20.4+k3s1'}
     server = WebhookAutoServer(insecure=True)
     async with server:
         async for _ in server(responder.fn):
             break  # do not sleep
     assert_logs(["Cluster detection found the hostname: host.k3d.internal"])
 
 
-async def test_server_works(
-        responder, aresponses, hostname, caplog, assert_logs):
-    caplog.set_level(0)
-    aresponses.add(hostname, '/version', 'get', {'gitVersion': 'v1.20.4'})
+async def test_server_works(kmock, responder, assert_logs):
+    kmock['get /version'] << {'gitVersion': 'v1.20.4'}
     server = WebhookAutoServer(insecure=True)
     async with server:
         async for _ in server(responder.fn):
             break  # do not sleep
     assert_logs(["Cluster detection failed, running a simple local server"])
 
 
-async def test_tunnel_detects(responder, pyngrok_mock, aresponses, hostname, caplog, assert_logs):
-    caplog.set_level(0)
-    aresponses.add(hostname, '/version', 'get', {'gitVersion': 'v1.20.4+k3s1'})
+async def test_tunnel_detects(kmock, responder, pyngrok_mock, assert_logs):
+    kmock['get /version'] << {'gitVersion': 'v1.20.4+k3s1'}
     server = WebhookAutoTunnel()
     async with server:
         async for _ in server(responder.fn):
             break  # do not sleep
     assert_logs(["Cluster detection found the hostname: host.k3d.internal"])
 
 
-async def test_tunnel_works(responder, pyngrok_mock, aresponses, hostname, caplog, assert_logs):
-    caplog.set_level(0)
-    aresponses.add(hostname, '/version', 'get', {'gitVersion': 'v1.20.4'})
+async def test_tunnel_works(kmock, responder, pyngrok_mock, assert_logs):
+    kmock['get /version'] << {'gitVersion': 'v1.20.4'}
     server = WebhookAutoTunnel()
     async with server:
         async for _ in server(responder.fn):