Edge server tests, provisioning scripts and APIs

.gitattributes

@@ -3,3 +3,6 @@ dataset/server/**/*.jpg filter=lfs diff=lfs merge=lfs -text
 dataset/server/**/*.png filter=lfs diff=lfs merge=lfs -text
 dataset/server/**/*.blob filter=lfs diff=lfs merge=lfs -text
 dataset/couchbase-server/**/*.zip filter=lfs diff=lfs merge=lfs -text
+resources/images/20mb.jpg filter=lfs diff=lfs merge=lfs -text
+resources/images/test.png filter=lfs diff=lfs merge=lfs -text
+resources/images/test2.png filter=lfs diff=lfs merge=lfs -text

.github/workflows/python_verify.yml

@@ -48,4 +48,4 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - uses: actions/checkout@v4
-      - uses: astral-sh/ruff-action@v3
+      - uses: astral-sh/ruff-action@v3

client/pyproject.toml

@@ -26,6 +26,7 @@ dependencies = [
     "aiohttp==3.11.11",
     "aiosignal==1.3.2",
     "async-timeout==5.0.1",
+    "asyncssh==2.19.0",
     "attrs==24.3.0",
     "bcrypt==4.2.1",
     "certifi==2024.12.14",
@@ -57,6 +58,7 @@ dependencies = [
     "propcache==0.2.1",
     "protobuf==5.29.3",
     "pycparser==2.22",
+    "pyjson5==2.0.0",
     "PyNaCl==1.5.0",
     "pytest==8.3.4",
     "pytest-asyncio==0.25.2",

client/src/cbltest/__init__.py

@@ -1,11 +1,14 @@
 from json import dumps
 
 from .api.couchbaseserver import CouchbaseServer
+from .api.edgeserver import EdgeServer
 from .api.syncgateway import SyncGateway
 from .api.testserver import TestServer
 from .assertions import _assert_not_null
 from .configparser import (
     CouchbaseServerInfo,
+    EdgeServerInfo,
+    HTTPClientInfo,
     ParsedConfig,
     SyncGatewayInfo,
     TestServerInfo,
@@ -63,6 +66,14 @@ def load_balancers(self) -> list[str]:
         """Gets the list of Load Balancers available"""
         return self.__config.load_balancers
 
+    @property
+    def edge_servers(self) -> list[EdgeServer]:
+        return self.__edge_servers
+
+    @property
+    def http_clients(self) -> list[str]:
+        return self.__http_clients
+
     @staticmethod
     async def create(
         config_path: str,
@@ -140,6 +151,17 @@ def __init__(
                         cbs_info.hostname, cbs_info.admin_user, cbs_info.admin_password
                     )
                 )
+        self.__edge_servers: list[EdgeServer] = []
+        if not test_server_only:
+            for es in self.__config.edge_servers:
+                es_info = EdgeServerInfo(es)
+                self.__edge_servers.append(EdgeServer(es_info.hostname))
+
+        self.__http_clients: list[str] = []
+        if not test_server_only:
+            for http in self.__config.http_clients:
+                h_info = HTTPClientInfo(http)
+                self.__http_clients.append(h_info.hostname)
 
     async def close(self) -> None:
         """