Peer to peer topology tests (#303)

* Added code for peer to peer mesh topology test
* Added peer to peer loop topology test case
* Added the markdown files for the p2p topology tests
* Batched documents to avoid payload too large error
* Added disableTLS support in test servers
* Updated api spec for startListener endpoint

Author: sanjivanipatrax

client/src/cbltest/api/listener.py

@@ -17,7 +17,11 @@ class Listener:
     """A class representing the passive side of a replication inside of a test server"""
 
     def __init__(
-        self, database: Database, collections: list[str], port: int | None = None
+        self,
+        database: Database,
+        collections: list[str],
+        port: int | None = None,
+        disable_tls: bool = False,
     ):
         self.database = database
         """The database that the listener will be serving"""
@@ -34,6 +38,9 @@ def __init__(
         value
         """
 
+        self.disable_tls = disable_tls
+        """If True, TLS will be disabled for the listener"""
+
         self.__original_port = port
         self.__index = database._index
         self.__request_factory = database._request_factory
@@ -48,7 +55,7 @@ async def start(self) -> None:
         """Start listening for incoming connections"""
         with self.__tracer.start_as_current_span("start_listener"):
             payload = PostStartListenerRequestBody(
-                self.database.name, self.collections, self.port
+                self.database.name, self.collections, self.port, self.disable_tls
             )
             request = self.__request_factory.create_request(
                 TestServerRequestType.START_LISTENER, payload

client/src/cbltest/api/testserver.py

@@ -1,5 +1,5 @@
 from typing import cast
-from urllib.parse import urljoin
+from urllib.parse import urljoin, urlparse
 
 from opentelemetry.trace import get_tracer
 
@@ -135,5 +135,13 @@ def replication_url(self, db_name: str, port: int):
         ws_scheme = "ws://"  # For now not using secure
 
         _assert_not_null(db_name, "db_name")
-        replication_url = f"{ws_scheme}{self.url}:{port}"
+
+        parsed = urlparse(self.url)
+        if parsed.hostname:
+            hostname = parsed.hostname
+        elif parsed.netloc:
+            hostname = parsed.netloc.split(":")[0]
+        else:
+            hostname = self.url.split("://")[-1].split(":")[0]
+        replication_url = f"{ws_scheme}{hostname}:{port}"
         return urljoin(replication_url, db_name)

client/src/cbltest/v1/requests.py

@@ -711,11 +711,23 @@ def port(self) -> int | None:
         """The desired port to listen on (if None, the OS will choose)"""
         return self.__port
 
-    def __init__(self, db: str, collections: list[str], port: int | None = None):
+    @property
+    def disableTLS(self) -> bool:
+        """If True, TLS will be disabled for the listener"""
+        return self.__disable_tls
+
+    def __init__(
+        self,
+        db: str,
+        collections: list[str],
+        port: int | None = None,
+        disable_tls: bool = False,
+    ):
         super().__init__(1)
         self.__database = db
         self.__collections = collections
         self.__port = port
+        self.__disable_tls = disable_tls
 
     def to_json(self) -> Any:
         json: dict[str, Any] = {
@@ -726,6 +738,9 @@ def to_json(self) -> Any:
         if self.__port is not None:
             json["port"] = self.__port
 
+        if self.__disable_tls:
+            json["disableTLS"] = self.__disable_tls
+
         return json
 
 

servers/c/src/cbl/CBLManager.cpp

@@ -536,7 +536,7 @@ namespace ts::cbl {
 
     /// URLEndpointListener
 
-    string CBLManager::startListener(const string &database, const vector<std::string>&collNames, int port) {
+    string CBLManager::startListener(const string &database, const vector<std::string>&collNames, int port, bool disableTLS) {
         lock_guard <mutex> lock(_mutex);
 
         CBLError error{};
@@ -562,6 +562,7 @@ namespace ts::cbl {
         config.collections = collections.data();
         config.collectionCount = collections.size();
         config.port = port;
+        config.disableTLS = disableTLS;
 
         auto listener = CBLURLEndpointListener_Create(&config, &error);
         if (!listener) {

servers/c/src/cbl/CBLManager.h

@@ -83,7 +83,7 @@ namespace ts::cbl {
 
         /// Listener
 
-        std::string startListener(const std::string &database, const std::vector<std::string>&collections, int port);
+        std::string startListener(const std::string &database, const std::vector<std::string>&collections, int port, bool disableTLS = false);
 
         CBLURLEndpointListener *listener(const std::string &id);
 

servers/c/src/dispatcher/PostStartListener.cpp

@@ -12,8 +12,9 @@ int Dispatcher::handlePOSTStartListener(Request &request, Session *session) {
     }
 
     auto port = GetValue<int>(body, "port", 0);
+    auto disableTLS = GetValue<bool>(body, "disableTLS", false);
 
-    string id = session->cblManager()->startListener(database, collections, port);
+    string id = session->cblManager()->startListener(database, collections, port, disableTLS);
 
     json result;
     result["id"] = id;

servers/dotnet/testserver.logic/Handlers/StartListenerHandler.cs

@@ -16,6 +16,8 @@ internal readonly record struct StartListenerBody
         public required string[] collections { get; init; }
 
         public ushort port { get; init; }
+
+        public bool disableTLS { get; init; } = false;
     }
 
     [HttpHandler("startListener")]
@@ -48,7 +50,8 @@ public static Task StartListenerHandler(int version, Session session, JsonDocume
 
         var listenerConfig = new URLEndpointListenerConfiguration(collectionObjects)
         {
-            Port = deserializedBody.port
+            Port = deserializedBody.port,
+            DisableTLS = deserializedBody.disableTLS
         };
         (var listener, var id) = session.ObjectManager.RegisterObject(() => new URLEndpointListener(listenerConfig));
         listener.Start();

servers/ios/TestServer/ContentTypes/StartListenerRequest.swift

@@ -12,12 +12,14 @@ extension ContentTypes {
         let database: String
         let collections: [String]
         let port: UInt16?
+        let disableTLS: Bool?
 
         public var description: String {
             var result: String = "Endpoint Listener Configuration:\n"
             result += "\tdatabase: \(database)\n"
             result += "\tcollection: \(collections.joined(separator: ", "))\n"
             result += "\tport: \(port ?? 0)\n"
+            result += "\tdisableTLS: \(disableTLS ?? false)\n"
             return result
         }
     }

servers/ios/TestServer/Handlers/StartListener.swift

@@ -16,7 +16,8 @@ extension Handlers {
         Log.log(level: .debug, message: "Starting Listener with config: \(listenerStartRq.description)")
 
         let dbManager = req.databaseManager
-        let id = try dbManager.startListener(dbName: listenerStartRq.database, collections: listenerStartRq.collections, port: listenerStartRq.port)
+        let disableTLS = listenerStartRq.disableTLS ?? false
+        let id = try dbManager.startListener(dbName: listenerStartRq.database, collections: listenerStartRq.collections, port: listenerStartRq.port, disableTLS: disableTLS)
 
         return ContentTypes.Listener(id: id, port: listenerStartRq.port)
     }

servers/ios/TestServer/Utils/DatabaseManager.swift

@@ -85,7 +85,7 @@ class DatabaseManager {
         }
     }
 
-    public func startListener(dbName: String, collections: [String], port: UInt16?) throws -> UUID {
+    public func startListener(dbName: String, collections: [String], port: UInt16?, disableTLS: Bool = false) throws -> UUID {
         var collectionsArr: [Collection] = []
 
         guard let database = databases[dbName]
@@ -105,6 +105,7 @@ class DatabaseManager {
 
         var listenerConfig = URLEndpointListenerConfiguration(collections: collectionsArr)
         listenerConfig.port = port
+        listenerConfig.disableTLS = disableTLS
 
         let listener = URLEndpointListener(config: listenerConfig)